Update of /cvsroot/openjms/openjms/src/main/org/exolab/jms/client/http
In directory sc8-pr-cvs1:/tmp/cvs-serv5642/src/main/org/exolab/jms/client/http
Modified Files:
HttpJmsSessionStub.java
Log Message:
fix for bug 669698 - HttpJmsSessionSender.onMessage() and onMessages() now wait for a reply (an empty Vector) from HttpJmsSessionStub before returning
Index: HttpJmsSessionStub.java
===================================================================
RCS file: /cvsroot/openjms/openjms/src/main/org/exolab/jms/client/http/HttpJmsSessionStub.java,v
retrieving revision 1.9
retrieving revision 1.10
diff -C2 -d -r1.9 -r1.10
*** HttpJmsSessionStub.java 10 Jan 2003 20:37:53 -0000 1.9
--- HttpJmsSessionStub.java 18 Jan 2003 02:13:42 -0000 1.10
***************
*** 1006,1009 ****
--- 1006,1010 ----
public Serializable notify(Object ob, String id) {
Vector v = (Vector)ob;
+ Vector reply = new Vector();
if (listener_ != null) {
***************
*** 1016,1023 ****
listener_.onMessageAvailable(((Long)v.get(1)).longValue());
}
}
- // if size == 1, then this is just a ping. Nothing to do.
}
! return null;
}
--- 1017,1025 ----
listener_.onMessageAvailable(((Long)v.get(1)).longValue());
}
+ } else {
+ // if size == 1, then this is just a ping.
}
}
! return reply;
}
|
