*** empty log message ***

3 files changed, 3 insertions, 14 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 05521e666c..6947449064 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
@@ -110,7 +110,7 @@ public class ConnectionImpl extends Container<Session> implements Connection
 
     IConnector connector = Net4jUtil.getConnector(transportContainer, connectorType, connectorDescription);
     JMSClientProtocol protocol = new JMSClientProtocol();
-    protocol.setConnection(this);
+    protocol.setInfraStructure(this);
     channel = connector.openChannel(protocol);
     channel.addListener(channelListener);
 
diff --git a/plugins/org.eclipse.net4j.jms/src/org/eclipse/net4j/internal/jms/protocol/JMSClientProtocol.java b/plugins/org.eclipse.net4j.jms/src/org/eclipse/net4j/internal/jms/protocol/JMSClientProtocol.java
index 589eb8684a..68c8a574fb 100644
--- a/plugins/org.eclipse.net4j.jms/src/org/eclipse/net4j/internal/jms/protocol/JMSClientProtocol.java
+++ b/plugins/org.eclipse.net4j.jms/src/org/eclipse/net4j/internal/jms/protocol/JMSClientProtocol.java
@@ -18,9 +18,8 @@ import org.eclipse.net4j.signal.SignalReactor;
 /**
  * @author Eike Stepper
  */
-public class JMSClientProtocol extends SignalProtocol
+public class JMSClientProtocol extends SignalProtocol<ConnectionImpl>
 {
-  private ConnectionImpl connection;
 
   public JMSClientProtocol()
   {
@@ -31,16 +30,6 @@ public class JMSClientProtocol extends SignalProtocol
     return JMSProtocolConstants.PROTOCOL_NAME;
   }
 
-  public ConnectionImpl getConnection()
-  {
-    return connection;
-  }
-
-  public void setConnection(ConnectionImpl connection)
-  {
-    this.connection = connection;
-  }
-
   @Override
   protected SignalReactor doCreateSignalReactor(short signalID)
   {
diff --git a/plugins/org.eclipse.net4j.jms/src/org/eclipse/net4j/internal/jms/protocol/JMSServerMessageIndication.java b/plugins/org.eclipse.net4j.jms/src/org/eclipse/net4j/internal/jms/protocol/JMSServerMessageIndication.java
index 6187c53871..065fd8ade8 100644
--- a/plugins/org.eclipse.net4j.jms/src/org/eclipse/net4j/internal/jms/protocol/JMSServerMessageIndication.java
+++ b/plugins/org.eclipse.net4j.jms/src/org/eclipse/net4j/internal/jms/protocol/JMSServerMessageIndication.java
@@ -41,7 +41,7 @@ public class JMSServerMessageIndication extends Indication
     long consumerID = in.readLong();
     MessageImpl message = MessageUtil.read(in);
     JMSClientProtocol protocol = (JMSClientProtocol)getProtocol();
-    ConnectionImpl connection = protocol.getConnection();
+    ConnectionImpl connection = protocol.getInfraStructure();
     connection.handleMessageFromSignal(sessionID, consumerID, message);
   }
 }