Update of /cvsroot/openjms/openjms/src/main/org/exolab/jms/server/http
In directory sc8-pr-cvs1:/tmp/cvs-serv5642/src/main/org/exolab/jms/server/http
Modified Files:
HttpJmsSessionSender.java
Log Message:
fix for bug 669698 - HttpJmsSessionSender.onMessage() and onMessages() now wait for a reply (an empty Vector) from HttpJmsSessionStub before returning
Index: HttpJmsSessionSender.java
===================================================================
RCS file: /cvsroot/openjms/openjms/src/main/org/exolab/jms/server/http/HttpJmsSessionSender.java,v
retrieving revision 1.4
retrieving revision 1.5
diff -C2 -d -r1.4 -r1.5
*** HttpJmsSessionSender.java 10 Jan 2003 20:38:39 -0000 1.4
--- HttpJmsSessionSender.java 18 Jan 2003 02:13:43 -0000 1.5
***************
*** 125,131 ****
v.add((MessageImpl)message);
pinger_.reset();
! client_.sendWithoutResponse(v, host_, port_);
}
! } catch (IOException err) {
throw new org.exolab.jms.server.ClientDisconnectionException(err.getMessage());
}
--- 125,135 ----
v.add((MessageImpl)message);
pinger_.reset();
! synchronized (client_) {
! client_.send(v, host_, port_);
! Vector reply = (Vector) client_.receive();
! }
}
! } catch (Exception err) {
! err.printStackTrace();
throw new org.exolab.jms.server.ClientDisconnectionException(err.getMessage());
}
***************
*** 145,151 ****
v.add(messages);
pinger_.reset();
! client_.sendWithoutResponse(v, host_, port_);
}
! } catch (IOException err) {
close();
throw new org.exolab.jms.server.ClientDisconnectionException(err.getMessage());
--- 149,158 ----
v.add(messages);
pinger_.reset();
! synchronized (client_) {
! client_.send(v, host_, port_);
! Vector reply = (Vector) client_.receive();
! }
}
! } catch (Exception err) {
close();
throw new org.exolab.jms.server.ClientDisconnectionException(err.getMessage());
***************
*** 182,186 ****
Vector v = new Vector(1);
v.add(session_.getSessionId());
! client_.sendWithoutResponse(v, host_, port_);
}
} catch (IOException err) {
--- 189,195 ----
Vector v = new Vector(1);
v.add(session_.getSessionId());
! synchronized (client_) {
! client_.sendWithoutResponse(v, host_, port_);
! }
}
} catch (IOException err) {
|
