Skip to main content
aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
Diffstat (limited to 'plugins/org.eclipse.net4j.jms/src/org/eclipse/net4j/internal/jms/ConnectionImpl.java')
-rw-r--r--plugins/org.eclipse.net4j.jms/src/org/eclipse/net4j/internal/jms/ConnectionImpl.java11
1 files changed, 6 insertions, 5 deletions
diff --git a/plugins/org.eclipse.net4j.jms/src/org/eclipse/net4j/internal/jms/ConnectionImpl.java b/plugins/org.eclipse.net4j.jms/src/org/eclipse/net4j/internal/jms/ConnectionImpl.java
index 8ce5f00a1e..01fabd8c48 100644
--- a/plugins/org.eclipse.net4j.jms/src/org/eclipse/net4j/internal/jms/ConnectionImpl.java
+++ b/plugins/org.eclipse.net4j.jms/src/org/eclipse/net4j/internal/jms/ConnectionImpl.java
@@ -12,7 +12,7 @@ package org.eclipse.net4j.internal.jms;
import org.eclipse.net4j.IChannel;
import org.eclipse.net4j.IConnector;
-import org.eclipse.net4j.ITransportContainer;
+import org.eclipse.net4j.Net4jUtil;
import org.eclipse.net4j.internal.jms.bundle.OM;
import org.eclipse.net4j.internal.jms.protocol.JMSClientProtocol;
import org.eclipse.net4j.internal.jms.protocol.JMSLogonRequest;
@@ -25,6 +25,7 @@ import org.eclipse.net4j.jms.JMSUtil;
import org.eclipse.net4j.util.container.IContainer;
import org.eclipse.net4j.util.container.IContainerDelta;
import org.eclipse.net4j.util.container.IContainerEvent;
+import org.eclipse.net4j.util.container.IManagedContainer;
import org.eclipse.net4j.util.container.IContainerDelta.Kind;
import org.eclipse.net4j.util.event.IListener;
import org.eclipse.net4j.util.lifecycle.ILifecycle;
@@ -60,7 +61,7 @@ public class ConnectionImpl extends Lifecycle implements Connection, IContainer<
private long sendTimeout = 2500;
- private ITransportContainer transportContainer;
+ private IManagedContainer transportContainer;
private IChannel channel;
@@ -93,7 +94,7 @@ public class ConnectionImpl extends Lifecycle implements Connection, IContainer<
private boolean stopped = true;
- public ConnectionImpl(ITransportContainer transportContainer, String connectorType, String connectorDescription,
+ public ConnectionImpl(IManagedContainer transportContainer, String connectorType, String connectorDescription,
String userName, String password) throws JMSException
{
this.transportContainer = transportContainer == null ? JMSUtil.getTransportContainer() : transportContainer;
@@ -107,7 +108,7 @@ public class ConnectionImpl extends Lifecycle implements Connection, IContainer<
this.userName = userName;
this.password = password;
- IConnector connector = transportContainer.getConnector(connectorType, connectorDescription);
+ IConnector connector = Net4jUtil.getConnector(transportContainer, connectorType, connectorDescription);
JMSClientProtocol protocol = new JMSClientProtocol();
protocol.setConnection(this);
channel = connector.openChannel(protocol);
@@ -169,7 +170,7 @@ public class ConnectionImpl extends Lifecycle implements Connection, IContainer<
return session;
}
- public ITransportContainer getTransportContainer()
+ public IManagedContainer getTransportContainer()
{
return transportContainer;
}

Back to the top