User: norbert
Date: 00/06/15 16:27:48
Modified: src/java/org/spydermq/distributed/server
ConnectionReceiverOILClient.java
Log:
More work on the OIL
Revision Changes Path
1.4 +4 -6
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.3
retrieving revision 1.4
diff -u -r1.3 -r1.4
--- ConnectionReceiverOILClient.java 2000/06/15 23:21:40 1.3
+++ ConnectionReceiverOILClient.java 2000/06/15 23:27:48 1.4
@@ -44,7 +44,7 @@
try {
socket=new Socket(addr,port);
is=socket.getInputStream();
- os=socket.getOutputStream(); //BufferOutputStream instead
+ os=socket.getOutputStream();
in=new ObjectInputStream(is);
out=new ObjectOutputStream(os);
} catch (Exception e) {
@@ -57,9 +57,7 @@
{
try {
int val=is.read();
- if (val==0) Log.log("Return : OK");
- else {
- Log.log("Return : Exception");
+ if (val==1) {
String st=(String)in.readObject();
throw new RemoteException(st);
}
@@ -67,9 +65,9 @@
Log.error("IOException while reading the answer");
Log.error(e);
throw new RemoteException("Cannot contact the remote object");
- } catch (ClassNotFoundException e) {
+ } /*catch (ClassNotFoundException e) {
throw new RemoteException("ClassNotFoundException");
- }
+ }*/
}
public void receive(SpyDestination dest,SpyMessage mes) throws Exception
