diff options
Diffstat (limited to 'plugins/org.eclipse.emf.cdo/src/org/eclipse/emf/internal/cdo/util/ChannelInjector.java')
-rw-r--r-- | plugins/org.eclipse.emf.cdo/src/org/eclipse/emf/internal/cdo/util/ChannelInjector.java | 6 |
1 files changed, 2 insertions, 4 deletions
diff --git a/plugins/org.eclipse.emf.cdo/src/org/eclipse/emf/internal/cdo/util/ChannelInjector.java b/plugins/org.eclipse.emf.cdo/src/org/eclipse/emf/internal/cdo/util/ChannelInjector.java index c5b8c154b6..fbc04a9020 100644 --- a/plugins/org.eclipse.emf.cdo/src/org/eclipse/emf/internal/cdo/util/ChannelInjector.java +++ b/plugins/org.eclipse.emf.cdo/src/org/eclipse/emf/internal/cdo/util/ChannelInjector.java @@ -13,6 +13,7 @@ package org.eclipse.emf.internal.cdo.util; import org.eclipse.emf.internal.cdo.CDOSessionImpl; import org.eclipse.net4j.connector.IConnector; +import org.eclipse.net4j.signal.failover.NOOPFailOverStrategy; import org.eclipse.net4j.util.StringUtil; import org.eclipse.net4j.util.container.IElementProcessor; import org.eclipse.net4j.util.container.IManagedContainer; @@ -36,10 +37,7 @@ public class ChannelInjector implements IElementProcessor if (element instanceof CDOSessionImpl) { CDOSessionImpl session = (CDOSessionImpl)element; - if (session.getConnector() == null) - { - session.setConnector(getConnector(container, description)); - } + session.getProtocol().setFailOverStrategy(new NOOPFailOverStrategy(getConnector(container, description))); } return element; |