Update of /cvsroot/openjms/openjms/src/main/org/exolab/jms/server/mipc
In directory sc8-pr-cvs1:/tmp/cvs-serv31765/src/main/org/exolab/jms/server/mipc
Modified Files:
IpcJmsSessionSender.java
Log Message:
fix for bug 669698 - onMessage() and onMessages() now wait for a reply (any empty Vector) from IpcJmsSessionStub before returning
Index: IpcJmsSessionSender.java
===================================================================
RCS file: /cvsroot/openjms/openjms/src/main/org/exolab/jms/server/mipc/IpcJmsSessionSender.java,v
retrieving revision 1.6
retrieving revision 1.7
diff -C2 -d -r1.6 -r1.7
*** IpcJmsSessionSender.java 10 Jan 2003 20:38:40 -0000 1.6
--- IpcJmsSessionSender.java 18 Jan 2003 02:04:29 -0000 1.7
***************
*** 117,123 ****
synchronized(client_) {
client_.send(v);
}
}
! } catch (IOException err) {
throw new org.exolab.jms.server.ClientDisconnectionException
(err.getMessage());
--- 117,124 ----
synchronized(client_) {
client_.send(v);
+ Vector reply = (Vector) client_.receive();
}
}
! } catch (Exception err) {
throw new org.exolab.jms.server.ClientDisconnectionException
(err.getMessage());
***************
*** 145,151 ****
synchronized(client_) {
client_.send(v);
}
}
! } catch (IOException err) {
// System.err.println("Failure sending message" + err);
throw new org.exolab.jms.server.ClientDisconnectionException
--- 146,153 ----
synchronized(client_) {
client_.send(v);
+ Vector reply = (Vector) client_.receive();
}
}
! } catch (Exception err) {
// System.err.println("Failure sending message" + err);
throw new org.exolab.jms.server.ClientDisconnectionException
|
