svn commit: r1029991 - in /synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/endpoints: DynamicLoadbalanceEndpoint.java dispatch/SALSessions.java dispatch/SessionInformation.java

[supun]

Author: supun
Date: Tue Nov  2 10:11:18 2010
New Revision: 1029991

URL: http://svn.apache.org/viewvc?rev=1029991&view=rev
Log:
SYNAPSE-704

Modified:
    
synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/endpoints/DynamicLoadbalanceEndpoint.java
    
synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/endpoints/dispatch/SALSessions.java
    
synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/endpoints/dispatch/SessionInformation.java

Modified: 
synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/endpoints/DynamicLoadbalanceEndpoint.java
URL: 
http://svn.apache.org/viewvc/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/endpoints/DynamicLoadbalanceEndpoint.java?rev=1029991&r1=1029990&r2=1029991&view=diff
==============================================================================
--- 
synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/endpoints/DynamicLoadbalanceEndpoint.java
 (original)
+++ 
synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/endpoints/DynamicLoadbalanceEndpoint.java
 Tue Nov  2 10:11:18 2010
@@ -144,6 +144,7 @@ public class DynamicLoadbalanceEndpoint 
         
         if (sessionInformation != null && currentMember != null) {
             //send message on current session
+            sessionInformation.updateExpiryTime();
             sendToApplicationMember(synCtx, currentMember, false);
         } else {
             // prepare for a new session

Modified: 
synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/endpoints/dispatch/SALSessions.java
URL: 
http://svn.apache.org/viewvc/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/endpoints/dispatch/SALSessions.java?rev=1029991&r1=1029990&r2=1029991&view=diff
==============================================================================
--- 
synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/endpoints/dispatch/SALSessions.java
 (original)
+++ 
synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/endpoints/dispatch/SALSessions.java
 Tue Nov  2 10:11:18 2010
@@ -623,7 +623,7 @@ public class SALSessions {
         Endpoint rootEndpoint = endpoints.get(0);
 
         SessionInformation information = new SessionInformation(id,
-                currentMember, expiryTime);
+                currentMember, expiryTime, expireTimeWindow);
 
         if (isClustered) {
             information.setRootEndpointName(getEndpointName(rootEndpoint));

Modified: 
synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/endpoints/dispatch/SessionInformation.java
URL: 
http://svn.apache.org/viewvc/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/endpoints/dispatch/SessionInformation.java?rev=1029991&r1=1029990&r2=1029991&view=diff
==============================================================================
--- 
synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/endpoints/dispatch/SessionInformation.java
 (original)
+++ 
synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/endpoints/dispatch/SessionInformation.java
 Tue Nov  2 10:11:18 2010
@@ -36,6 +36,7 @@ public class SessionInformation implemen
     private String rootEndpointName;
     private List<String> path;
     private long expiryTime;
+    private long expireTimeWindow;
     private transient List<Endpoint> endpointList;
     private transient Member member;
 
@@ -45,10 +46,11 @@ public class SessionInformation implemen
         this.expiryTime = expiryTime;
     }
 
-    public SessionInformation(String id, Member member, long expiryTime) {
+    public SessionInformation(String id, Member member, long expiryTime, long 
expireTimeWindow) {
         this.id = id;
         this.member = member;
         this.expiryTime = expiryTime;
+        this.expireTimeWindow = expireTimeWindow;
     }
 
     public String getId() {
@@ -75,6 +77,10 @@ public class SessionInformation implemen
         this.expiryTime = expiryTime;
     }
 
+    public void updateExpiryTime(){
+        this.expiryTime = System.currentTimeMillis() + expireTimeWindow;    
+    }
+
     public List<Endpoint> getEndpointList() {
         return endpointList;
     }