Author: solomax
Date: Wed Feb 27 06:19:30 2013
New Revision: 1450613
URL: http://svn.apache.org/r1450613
Log:
Cluster: HashMapStore is reverted
Modified:
openmeetings/trunk/singlewebapp/src/org/apache/openmeetings/session/store/HashMapStore.java
Modified:
openmeetings/trunk/singlewebapp/src/org/apache/openmeetings/session/store/HashMapStore.java
URL:
http://svn.apache.org/viewvc/openmeetings/trunk/singlewebapp/src/org/apache/openmeetings/session/store/HashMapStore.java?rev=1450613&r1=1450612&r2=1450613&view=diff
==============================================================================
---
openmeetings/trunk/singlewebapp/src/org/apache/openmeetings/session/store/HashMapStore.java
(original)
+++
openmeetings/trunk/singlewebapp/src/org/apache/openmeetings/session/store/HashMapStore.java
Wed Feb 27 06:19:30 2013
@@ -29,10 +29,8 @@ import java.util.Map;
import org.apache.openmeetings.OpenmeetingsVariables;
import org.apache.openmeetings.persistence.beans.basic.Server;
import org.apache.openmeetings.persistence.beans.room.Client;
-import org.apache.openmeetings.session.ServerUtil;
import org.red5.logging.Red5LoggerFactory;
import org.slf4j.Logger;
-import org.springframework.beans.factory.annotation.Autowired;
/**
* Stores the session in the memory.
@@ -52,8 +50,6 @@ import org.springframework.beans.factory
public class HashMapStore implements IClientPersistenceStore {
protected static final Logger log = Red5LoggerFactory.getLogger(
HashMapStore.class,
OpenmeetingsVariables.webAppRootKey);
- @Autowired
- private ServerUtil serverUtil;
private LinkedHashMap<String, Client> clientsByStreamId = new
LinkedHashMap<String, Client>();
@@ -182,13 +178,6 @@ public class HashMapStore implements ICl
HashSet<Long> rooms = new HashSet<Long>();
for (Client cl : clientsByStreamId.values()) {
Long roomId = cl.getRoom_id();
- Server s = cl.getServer() == null ?
serverUtil.getCurrentServer() : cl.getServer();
- if ((server == null && s != null) || (server != null &&
s == null)) {
- continue;
- }
- if (server != null && s != null && server.getId() !=
s.getId()) {
- continue;
- }
if (roomId != null && roomId > 0 &&
!rooms.contains(roomId)) {
rooms.add(roomId);
}