You are viewing a plain text version of this content. The canonical link for it is here.
Posted to fx-dev@ws.apache.org by ch...@apache.org on 2005/09/30 04:34:21 UTC
svn commit: r292601 - in
/webservices/sandesha/trunk/src/org/apache/sandesha2: Constants.java
Sender.java
Author: chamikara
Date: Thu Sep 29 19:34:05 2005
New Revision: 292601
URL: http://svn.apache.org/viewcvs?rev=292601&view=rev
Log:
Fixed the sender to retransmit messages, with the retransmission interval given by Constants.WSP.RETRANSMISSION_INTERVAL
Modified:
webservices/sandesha/trunk/src/org/apache/sandesha2/Constants.java
webservices/sandesha/trunk/src/org/apache/sandesha2/Sender.java
Modified: webservices/sandesha/trunk/src/org/apache/sandesha2/Constants.java
URL: http://svn.apache.org/viewcvs/webservices/sandesha/trunk/src/org/apache/sandesha2/Constants.java?rev=292601&r1=292600&r2=292601&view=diff
==============================================================================
--- webservices/sandesha/trunk/src/org/apache/sandesha2/Constants.java (original)
+++ webservices/sandesha/trunk/src/org/apache/sandesha2/Constants.java Thu Sep 29 19:34:05 2005
@@ -88,7 +88,7 @@
}
public interface WSP {
- long RETRANSMISSION_INTERVAL = 3000;
+ long RETRANSMISSION_INTERVAL = 20000;
}
String RM_HEADERS = "rmHeaders";
Modified: webservices/sandesha/trunk/src/org/apache/sandesha2/Sender.java
URL: http://svn.apache.org/viewcvs/webservices/sandesha/trunk/src/org/apache/sandesha2/Sender.java?rev=292601&r1=292600&r2=292601&view=diff
==============================================================================
--- webservices/sandesha/trunk/src/org/apache/sandesha2/Sender.java (original)
+++ webservices/sandesha/trunk/src/org/apache/sandesha2/Sender.java Thu Sep 29 19:34:05 2005
@@ -79,14 +79,17 @@
e2.printStackTrace();
}
- String action = msgCtx.getWSAAction();
- System.out.println ("Action:" + action);
-
try {
new AxisEngine(context).send(msgCtx);
} catch (AxisFault e1) {
e1.printStackTrace();
}
+
+ //changing the values of the sent bean.
+ bean.setLastSentTime(System.currentTimeMillis());
+ bean.setSentCount(bean.getSentCount()+1);
+ mgr.update(bean);
+
}
---------------------------------------------------------------------
To unsubscribe, e-mail: sandesha-dev-unsubscribe@ws.apache.org
For additional commands, e-mail: sandesha-dev-help@ws.apache.org