diff options
Diffstat (limited to 'plugins/org.eclipse.net4j/src/org/eclipse/internal/net4j/transport/AbstractConnector.java')
-rw-r--r-- | plugins/org.eclipse.net4j/src/org/eclipse/internal/net4j/transport/AbstractConnector.java | 8 |
1 files changed, 5 insertions, 3 deletions
diff --git a/plugins/org.eclipse.net4j/src/org/eclipse/internal/net4j/transport/AbstractConnector.java b/plugins/org.eclipse.net4j/src/org/eclipse/internal/net4j/transport/AbstractConnector.java index 479a18a608..70b0d10ecc 100644 --- a/plugins/org.eclipse.net4j/src/org/eclipse/internal/net4j/transport/AbstractConnector.java +++ b/plugins/org.eclipse.net4j/src/org/eclipse/internal/net4j/transport/AbstractConnector.java @@ -219,7 +219,8 @@ public abstract class AbstractConnector extends AbstractLifecycle implements Con switch (newState) { case DISCONNECTED: - REGISTRY.deregister(connectorID); + REGISTRY.remove(connectorID); + REGISTRY.commit(); if (finishedConnecting != null) { finishedConnecting.countDown(); @@ -250,7 +251,8 @@ public abstract class AbstractConnector extends AbstractLifecycle implements Con case CONNECTED: finishedConnecting.countDown(); // Just in case of suspicion finishedNegotiating.countDown(); - REGISTRY.register(this); + REGISTRY.put(connectorID, this); + REGISTRY.commit(); break; } @@ -484,7 +486,7 @@ public abstract class AbstractConnector extends AbstractLifecycle implements Con return null; } - ProtocolFactory factory = registry.lookup(protocolID); + ProtocolFactory factory = registry.get(protocolID); if (factory == null) { if (TRACER.isEnabled()) |