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);

+                               

                                

                        }