Switch back to the initial implementation of RegistrationManager to keep sending the same events

git-svn-id: svn+ssh://src.earth.threerings.net/narya/trunk@6363 542714f4-19e9-0310-aa3c-eee0fc999fb1
This commit is contained in:
Charlie Groves
2010-12-10 02:51:05 +00:00
parent 5476241fa4
commit e7dd16adc1
3 changed files with 11 additions and 12 deletions
@@ -36,10 +36,10 @@ public class ConfigRecord extends PersistentRecord
{
// AUTO-GENERATED: FIELDS START
public static final Class<ConfigRecord> _R = ConfigRecord.class;
public static final ColumnExp NODE = colexp(_R, "node");
public static final ColumnExp OBJECT = colexp(_R, "object");
public static final ColumnExp FIELD = colexp(_R, "field");
public static final ColumnExp VALUE = colexp(_R, "value");
public static final ColumnExp<String> NODE = colexp(_R, "node");
public static final ColumnExp<String> OBJECT = colexp(_R, "object");
public static final ColumnExp<String> FIELD = colexp(_R, "field");
public static final ColumnExp<String> VALUE = colexp(_R, "value");
// AUTO-GENERATED: FIELDS END
public static final int SCHEMA_VERSION = 2;
@@ -40,11 +40,11 @@ public class NodeRecord extends PersistentRecord
{
// AUTO-GENERATED: FIELDS START
public static final Class<NodeRecord> _R = NodeRecord.class;
public static final ColumnExp NODE_NAME = colexp(_R, "nodeName");
public static final ColumnExp HOST_NAME = colexp(_R, "hostName");
public static final ColumnExp PUBLIC_HOST_NAME = colexp(_R, "publicHostName");
public static final ColumnExp PORT = colexp(_R, "port");
public static final ColumnExp LAST_UPDATED = colexp(_R, "lastUpdated");
public static final ColumnExp<String> NODE_NAME = colexp(_R, "nodeName");
public static final ColumnExp<String> HOST_NAME = colexp(_R, "hostName");
public static final ColumnExp<String> PUBLIC_HOST_NAME = colexp(_R, "publicHostName");
public static final ColumnExp<Integer> PORT = colexp(_R, "port");
public static final ColumnExp<Timestamp> LAST_UPDATED = colexp(_R, "lastUpdated");
// AUTO-GENERATED: FIELDS END
/** Increment this value if you modify the definition of this persistent
@@ -11,9 +11,8 @@ public class RegistrationManager implements RegistrationProvider
public void registerReceiver (ClientObject caller, Registration reg)
{
if (caller.receivers.containsKey(reg.getKey())) {
caller.updateReceivers(reg);
} else {
caller.addToReceivers(reg);
caller.removeFromReceivers(reg.getKey());
}
caller.addToReceivers(reg);
}
}