Author: ron.sigal(a)jboss.com
Date: 2009-05-07 17:56:11 -0400 (Thu, 07 May 2009)
New Revision: 5152
Modified:
remoting2/branches/2.2.2-SP11_JBREM-1112/src/main/org/jboss/remoting/LeasePinger.java
Log:
(1) JBREM-1129: Uses LeasePinger.TIME_STAMP; (2) JBREM-1128: removeClient() removes Client
from clients.
Modified:
remoting2/branches/2.2.2-SP11_JBREM-1112/src/main/org/jboss/remoting/LeasePinger.java
===================================================================
---
remoting2/branches/2.2.2-SP11_JBREM-1112/src/main/org/jboss/remoting/LeasePinger.java 2009-05-07
21:53:39 UTC (rev 5151)
+++
remoting2/branches/2.2.2-SP11_JBREM-1112/src/main/org/jboss/remoting/LeasePinger.java 2009-05-07
21:56:11 UTC (rev 5152)
@@ -24,7 +24,9 @@
public static final long DEFAULT_LEASE_PERIOD = 5000;
public static final int DEFAULT_DISCONNECT_TIMEOUT = -1;
- public static final String LEASE_PINGER_ID = "leasePingerId";
+
+ static final String LEASE_PINGER_ID = "leasePingerId";
+ static final String TIME_STAMP = "timeStamp";
// Static
---------------------------------------------------------------------------------------
@@ -207,6 +209,7 @@
}
clientSessionIds.remove(sessionID);
+ clients.remove(sessionID);
}
else
{
@@ -329,7 +332,7 @@
Map requestClients = new ConcurrentHashMap();
requestClients.put(ClientHolder.CLIENT_HOLDER_KEY, clientsClone);
requestClients.put(LeasePinger.LEASE_PINGER_ID, leasePingerId);
- requestClients.put("time",
Long.toString(System.currentTimeMillis()));
+ requestClients.put(TIME_STAMP, Long.toString(System.currentTimeMillis()));
InvocationRequest ir = new InvocationRequest(invokerSessionID, null,
"$PING$", requestClients, null, null);
invoker.invoke(ir);
Show replies by date