diff options
Diffstat (limited to 'plugins/org.eclipse.net4j/src/org/eclipse/internal/net4j/transport/ChannelImpl.java')
-rw-r--r-- | plugins/org.eclipse.net4j/src/org/eclipse/internal/net4j/transport/ChannelImpl.java | 6 |
1 files changed, 4 insertions, 2 deletions
diff --git a/plugins/org.eclipse.net4j/src/org/eclipse/internal/net4j/transport/ChannelImpl.java b/plugins/org.eclipse.net4j/src/org/eclipse/internal/net4j/transport/ChannelImpl.java index 072009fa0e..ccd41801bd 100644 --- a/plugins/org.eclipse.net4j/src/org/eclipse/internal/net4j/transport/ChannelImpl.java +++ b/plugins/org.eclipse.net4j/src/org/eclipse/internal/net4j/transport/ChannelImpl.java @@ -213,7 +213,8 @@ public class ChannelImpl extends AbstractLifecycle implements Channel, BufferPro if (!(this instanceof ControlChannelImpl)) { - Channel.REGISTRY.register(this); + Channel.REGISTRY.put(getID(), this); + Channel.REGISTRY.commit(); } } @@ -222,7 +223,8 @@ public class ChannelImpl extends AbstractLifecycle implements Channel, BufferPro { if (!(this instanceof ControlChannelImpl)) { - Channel.REGISTRY.deregister(getID()); + Channel.REGISTRY.remove(getID()); + Channel.REGISTRY.commit(); } receiveSerializer = null; |