User: juha
Date: 00/11/04 11:24:47
Modified: src/java/org/spydermq/distributed/server
DistributedJMSServerOIL.java
ConnectionReceiverOILClient.java
Log:
Toned down the server complaints for closed sockets.
Bug #156.
Revision Changes Path
1.4 +2 -1
spyderMQ/src/java/org/spydermq/distributed/server/DistributedJMSServerOIL.java
Index: DistributedJMSServerOIL.java
===================================================================
RCS file:
/products/cvs/ejboss/spyderMQ/src/java/org/spydermq/distributed/server/DistributedJMSServerOIL.java,v
retrieving revision 1.3
retrieving revision 1.4
diff -u -r1.3 -r1.4
--- DistributedJMSServerOIL.java 2000/06/20 02:19:13 1.3
+++ DistributedJMSServerOIL.java 2000/11/04 19:24:47 1.4
@@ -98,7 +98,8 @@
try {
code=is.read();
} catch (IOException e) {
- failure("Command read",e);
+ Log.notice("Command read");
+ Log.notice(e);
return;
}
1.8 +10 -9
spyderMQ/src/java/org/spydermq/distributed/server/ConnectionReceiverOILClient.java
Index: ConnectionReceiverOILClient.java
===================================================================
RCS file:
/products/cvs/ejboss/spyderMQ/src/java/org/spydermq/distributed/server/ConnectionReceiverOILClient.java,v
retrieving revision 1.7
retrieving revision 1.8
diff -u -r1.7 -r1.8
--- ConnectionReceiverOILClient.java 2000/06/20 02:19:13 1.7
+++ ConnectionReceiverOILClient.java 2000/11/04 19:24:47 1.8
@@ -16,6 +16,7 @@
import java.io.Serializable;
import java.net.Socket;
import java.net.InetAddress;
+import java.net.SocketException;
public class ConnectionReceiverOILClient
implements ConnectionReceiver, Serializable
@@ -65,9 +66,9 @@
String st=(String)in.readObject();
throw new RemoteException(st);
}
- } catch (IOException e) {
- Log.error("IOException while reading the answer");
- Log.error(e);
+ } catch (IOException e) {
+ Log.notice("IOException while reading the answer");
+ Log.notice(e);
throw new RemoteException("Cannot contact the remote object");
} /*catch (ClassNotFoundException e) {
throw new RemoteException("ClassNotFoundException");
@@ -75,12 +76,12 @@
}
public void receive(SpyDestination dest,SpyMessage mes) throws Exception
- {
- if (socket==null) createConnection();
- os.write(RECEIVE);
- out.writeObject(dest);
- out.writeObject(mes);
- waitAnswer();
+ {
+ if (socket==null) createConnection();
+ os.write(RECEIVE);
+ out.writeObject(dest);
+ out.writeObject(mes);
+ waitAnswer();
}
public void receiveMultiple(SpyDestination dest,SpyMessage mes[]) throws
Exception
