|
From: <bob...@us...> - 2003-08-15 07:36:19
|
Update of /cvsroot/ebxmlms/ebxmlms/src/hk/hku/cecid/phoenix/message/handler
In directory sc8-pr-cvs1:/tmp/cvs-serv23758/src/hk/hku/cecid/phoenix/message/handler
Modified Files:
MessageServiceHandler.java
Log Message:
Fix the ping - pong bug that the pong message doesn't send to
the Request which send Ping message.
This situation occur when the Request use a self-Impl. MessageListener.
also store the pong message to the message server when it is generated.
Index: MessageServiceHandler.java
===================================================================
RCS file: /cvsroot/ebxmlms/ebxmlms/src/hk/hku/cecid/phoenix/message/handler/MessageServiceHandler.java,v
retrieving revision 1.173
retrieving revision 1.174
diff -C2 -d -r1.173 -r1.174
*** MessageServiceHandler.java 11 Jul 2003 03:48:59 -0000 1.173
--- MessageServiceHandler.java 15 Aug 2003 07:34:01 -0000 1.174
***************
*** 1507,1511 ****
URL clientUrl = listener.getClientUrl();
final MessageServiceHandlerConfig config;
-
// Not client message listener and it's not using trusted repository
if (clientUrl.getProtocol().equals(MessageListener.PROTOCOL_FILE)) {
--- 1507,1510 ----
***************
*** 4910,4913 ****
--- 4909,4914 ----
logger.debug("Ping message is received");
response = generatePongMessage(ebxmlMessage);
+ messageServer.store(response, appContext,
+ MessageServer.STATE_SENT, true, tx);
logger.debug("Pong message is sent back");
}
***************
*** 4919,4922 ****
--- 4920,4925 ----
mshConnection = (MessageServiceHandlerConnection)
mshConnectionTable.get(appContext);
+ messageServer.store(ebxmlMessage, appContext,
+ MessageServer.STATE_RECEIVED, false, tx);
Delivery delivery = new Delivery(this, appContext,
mshConnection.getMessageServiceHandlerConfig().
|