[openjms-cvs] openjms/src/main/org/exolab/jms/server/mipc IpcJmsSessionSender.java,1.6,1.7

[<tan...@us...>]

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