User: pkendall
Date: 01/05/21 20:17:03
Modified: src/main/org/jbossmq/distributed/server
DistributedJMSServerUIL.java
DistributedJMSServerOIL.java
Log:
Failure on the connection is not an error so just log it normally.
Revision Changes Path
1.3 +5 -17
jbossmq/src/main/org/jbossmq/distributed/server/DistributedJMSServerUIL.java
Index: DistributedJMSServerUIL.java
===================================================================
RCS file:
/cvsroot/jboss/jbossmq/src/main/org/jbossmq/distributed/server/DistributedJMSServerUIL.java,v
retrieving revision 1.2
retrieving revision 1.3
diff -u -r1.2 -r1.3
--- DistributedJMSServerUIL.java 2001/03/02 01:12:54 1.2
+++ DistributedJMSServerUIL.java 2001/05/22 03:17:03 1.3
@@ -13,18 +13,6 @@
import javax.jms.TemporaryTopic;
import javax.jms.TemporaryQueue;
-
-
-
-
-
-
-
-
-
-
-
-
import java.rmi.RemoteException;
import java.net.ServerSocket;
import java.net.Socket;
@@ -53,7 +41,7 @@
* @author Norbert Lataille ([EMAIL PROTECTED])
* @author Hiram Chirino ([EMAIL PROTECTED])
*
- * @version $Revision: 1.2 $
+ * @version $Revision: 1.3 $
*/
public class DistributedJMSServerUIL
implements Runnable, DistributedJMSServerSetup, DistributedJMSServerUILMBean
@@ -169,7 +157,7 @@
server.connectionClosing(spyDistributedConnection);
closed = true;
break;
- case this.m_createQueue:
+ case m_createQueue:
result=(Queue)server.createQueue(spyDistributedConnection, (String)in.readObject());
break;
case m_createTopic:
@@ -178,7 +166,7 @@
case m_deleteTemporaryDestination:
server.deleteTemporaryDestination(spyDistributedConnection,
(SpyDestination)in.readObject());
break;
- case this.m_getID:
+ case m_getID:
result=server.getID();
break;
case m_getTemporaryQueue:
@@ -265,8 +253,8 @@
void failure(String st,Exception e)
{
- Log.error("Closing socket: "+st);
- Log.error(e);
+ Log.log("Closing socket: "+st);
+ Log.log(e);
}
// --
1.4 +3 -13
jbossmq/src/main/org/jbossmq/distributed/server/DistributedJMSServerOIL.java
Index: DistributedJMSServerOIL.java
===================================================================
RCS file:
/cvsroot/jboss/jbossmq/src/main/org/jbossmq/distributed/server/DistributedJMSServerOIL.java,v
retrieving revision 1.3
retrieving revision 1.4
diff -u -r1.3 -r1.4
--- DistributedJMSServerOIL.java 2001/03/02 01:12:54 1.3
+++ DistributedJMSServerOIL.java 2001/05/22 03:17:03 1.4
@@ -13,16 +13,6 @@
import javax.jms.TemporaryTopic;
import javax.jms.TemporaryQueue;
-
-
-
-
-
-
-
-
-
-
import java.rmi.RemoteException;
import java.net.ServerSocket;
import java.net.Socket;
@@ -49,7 +39,7 @@
* @author Norbert Lataille ([EMAIL PROTECTED])
* @author Hiram Chirino ([EMAIL PROTECTED])
*
- * @version $Revision: 1.3 $
+ * @version $Revision: 1.4 $
*/
public class DistributedJMSServerOIL extends DistributedJMSServerUIL
implements DistributedJMSServerOILMBean
@@ -121,7 +111,7 @@
server.connectionClosing(spyDistributedConnection);
closed = true;
break;
- case this.m_createQueue:
+ case m_createQueue:
result=(Queue)server.createQueue(spyDistributedConnection, (String)in.readObject());
break;
case m_createTopic:
@@ -130,7 +120,7 @@
case m_deleteTemporaryDestination:
server.deleteTemporaryDestination(spyDistributedConnection,
(SpyDestination)in.readObject());
break;
- case this.m_getID:
+ case m_getID:
result=server.getID();
break;
case m_getTemporaryQueue:
_______________________________________________
Jboss-development mailing list
[EMAIL PROTECTED]
http://lists.sourceforge.net/lists/listinfo/jboss-development
