Skip to main content
aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
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.java8
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())

Back to the top