User: pra
Date: 02/02/17 09:50:44
Modified: src/main/org/jboss/mq/il/oil OILServerILService.java
Log:
Added numbering for worker threads
Revision Changes Path
1.19 +80 -70 jbossmq/src/main/org/jboss/mq/il/oil/OILServerILService.java
Index: OILServerILService.java
===================================================================
RCS file:
/cvsroot/jboss/jbossmq/src/main/org/jboss/mq/il/oil/OILServerILService.java,v
retrieving revision 1.18
retrieving revision 1.19
diff -u -r1.18 -r1.19
--- OILServerILService.java 2 Feb 2002 04:02:23 -0000 1.18
+++ OILServerILService.java 17 Feb 2002 17:50:44 -0000 1.19
@@ -46,7 +46,7 @@
* Implements the ServerILJMXService which is used to manage the JVM IL.
*
* @author Hiram Chirino ([EMAIL PROTECTED])
- * @version $Revision: 1.18 $
+ * @version $Revision: 1.19 $
*/
public final class OILServerILService
extends org.jboss.mq.il.ServerILJMXService
@@ -95,6 +95,11 @@
private InetAddress bindAddress = null;
/**
+ * Number of OIL Worker threads started.
+ */
+ private int threadNumber = 0;
+
+ /**
* This class is used to encapsulate the basic connection and
* work for a connected client thread. The run() method of this
* class processes requests and sends responses to and from a
@@ -192,93 +197,93 @@
switch (code)
{
- case OILConstants.SET_SPY_DISTRIBUTED_CONNECTION:
- connectionToken = (ConnectionToken)in.readObject();
- break;
+ case OILConstants.SET_SPY_DISTRIBUTED_CONNECTION:
+ connectionToken = (ConnectionToken)in.readObject();
+ break;
- case OILConstants.ACKNOWLEDGE:
- AcknowledgementRequest ack = new AcknowledgementRequest();
- ack.readExternal(in);
- server.acknowledge(connectionToken, ack);
- break;
+ case OILConstants.ACKNOWLEDGE:
+ AcknowledgementRequest ack = new AcknowledgementRequest();
+ ack.readExternal(in);
+ server.acknowledge(connectionToken, ack);
+ break;
- case OILConstants.ADD_MESSAGE:
- server.addMessage(connectionToken, SpyMessage.readMessage(in));
- break;
+ case OILConstants.ADD_MESSAGE:
+ server.addMessage(connectionToken, SpyMessage.readMessage(in));
+ break;
- case OILConstants.BROWSE:
- result = server.browse(connectionToken,
(Destination)in.readObject(), (String)in.readObject());
- break;
+ case OILConstants.BROWSE:
+ result = server.browse(connectionToken,
(Destination)in.readObject(), (String)in.readObject());
+ break;
- case OILConstants.CHECK_ID:
- server.checkID((String)in.readObject());
- break;
+ case OILConstants.CHECK_ID:
+ server.checkID((String)in.readObject());
+ break;
- case OILConstants.CONNECTION_CLOSING:
- server.connectionClosing(connectionToken);
- closed = true;
- break;
+ case OILConstants.CONNECTION_CLOSING:
+ server.connectionClosing(connectionToken);
+ closed = true;
+ break;
- case OILConstants.CREATE_QUEUE:
- result = (Queue)server.createQueue(connectionToken,
(String)in.readObject());
- break;
+ case OILConstants.CREATE_QUEUE:
+ result = (Queue)server.createQueue(connectionToken,
(String)in.readObject());
+ break;
- case OILConstants.CREATE_TOPIC:
- result = (Topic)server.createTopic(connectionToken,
(String)in.readObject());
- break;
+ case OILConstants.CREATE_TOPIC:
+ result = (Topic)server.createTopic(connectionToken,
(String)in.readObject());
+ break;
- case OILConstants.DELETE_TEMPORARY_DESTINATION:
- server.deleteTemporaryDestination(connectionToken,
(SpyDestination)in.readObject());
- break;
+ case OILConstants.DELETE_TEMPORARY_DESTINATION:
+ server.deleteTemporaryDestination(connectionToken,
(SpyDestination)in.readObject());
+ break;
- case OILConstants.GET_ID:
- result = server.getID();
- break;
+ case OILConstants.GET_ID:
+ result = server.getID();
+ break;
- case OILConstants.GET_TEMPORARY_QUEUE:
- result =
(TemporaryQueue)server.getTemporaryQueue(connectionToken);
- break;
+ case OILConstants.GET_TEMPORARY_QUEUE:
+ result =
(TemporaryQueue)server.getTemporaryQueue(connectionToken);
+ break;
- case OILConstants.GET_TEMPORARY_TOPIC:
- result =
(TemporaryTopic)server.getTemporaryTopic(connectionToken);
- break;
+ case OILConstants.GET_TEMPORARY_TOPIC:
+ result =
(TemporaryTopic)server.getTemporaryTopic(connectionToken);
+ break;
- case OILConstants.RECEIVE:
- result = server.receive(connectionToken, in.readInt(),
in.readLong());
- break;
+ case OILConstants.RECEIVE:
+ result = server.receive(connectionToken, in.readInt(),
in.readLong());
+ break;
- case OILConstants.SET_ENABLED:
- server.setEnabled(connectionToken, in.readBoolean());
- break;
+ case OILConstants.SET_ENABLED:
+ server.setEnabled(connectionToken, in.readBoolean());
+ break;
- case OILConstants.SUBSCRIBE:
- server.subscribe(connectionToken,
(Subscription)in.readObject());
- break;
+ case OILConstants.SUBSCRIBE:
+ server.subscribe(connectionToken, (Subscription)in.readObject());
+ break;
- case OILConstants.TRANSACT:
- TransactionRequest trans = new TransactionRequest();
- trans.readExternal(in);
- server.transact(connectionToken, trans);
- break;
+ case OILConstants.TRANSACT:
+ TransactionRequest trans = new TransactionRequest();
+ trans.readExternal(in);
+ server.transact(connectionToken, trans);
+ break;
- case OILConstants.UNSUBSCRIBE:
- server.unsubscribe(connectionToken, in.readInt());
- break;
+ case OILConstants.UNSUBSCRIBE:
+ server.unsubscribe(connectionToken, in.readInt());
+ break;
- case OILConstants.DESTROY_SUBSCRIPTION:
-
server.destroySubscription((DurableSubscriptionID)in.readObject());
- break;
+ case OILConstants.DESTROY_SUBSCRIPTION:
+
server.destroySubscription((DurableSubscriptionID)in.readObject());
+ break;
- case OILConstants.CHECK_USER:
- result = server.checkUser((String)in.readObject(),
(String)in.readObject());
- break;
+ case OILConstants.CHECK_USER:
+ result = server.checkUser((String)in.readObject(),
(String)in.readObject());
+ break;
- case OILConstants.PING:
- server.ping(connectionToken, in.readLong());
- break;
+ case OILConstants.PING:
+ server.ping(connectionToken, in.readLong());
+ break;
- default:
- throw new RemoteException("Bad method code !");
+ default:
+ throw new RemoteException("Bad method code !");
}
//Everthing was OK, otherwise
@@ -317,6 +322,11 @@
if (closed)
break;
+
+ //DEBUG-pra
+ e.printStackTrace();
+ System.out.println("Logger: " + log.getClass());
+
log.info("Client request resulted in a server exception: ", e);
try
@@ -449,7 +459,7 @@
try
{
socket.setSoTimeout(0);
- new Thread(new Client(socket), "OIL Worker").start();
+ new Thread(new Client(socket), "OIL Worker-" +
threadNumber++).start();
}
catch(IOException ie)
{
@@ -511,7 +521,7 @@
/* We need to check the socketAddress against "0.0.0.0/0.0.0.0"
because this is not a valid address on Win32 while it is for
*NIX. See BugParade bug #4343286.
- */
+ */
if( socketAddress.toString().equals("0.0.0.0/0.0.0.0") )
socketAddress = InetAddress.getLocalHost();
serverIL = new OILServerIL(socketAddress, serverSocket.getLocalPort());
_______________________________________________
Jboss-development mailing list
[EMAIL PROTECTED]
https://lists.sourceforge.net/lists/listinfo/jboss-development
