activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From clebertsuco...@apache.org
Subject [3/5] activemq-artemis git commit: ARTEMIS-814: Notify connection listener of connection created
Date Mon, 24 Oct 2016 13:42:44 GMT
ARTEMIS-814: Notify connection listener of connection created


Project: http://git-wip-us.apache.org/repos/asf/activemq-artemis/repo
Commit: http://git-wip-us.apache.org/repos/asf/activemq-artemis/commit/b2a5fe19
Tree: http://git-wip-us.apache.org/repos/asf/activemq-artemis/tree/b2a5fe19
Diff: http://git-wip-us.apache.org/repos/asf/activemq-artemis/diff/b2a5fe19

Branch: refs/heads/master
Commit: b2a5fe19d30ad6114db2c4cc1d560e8be9945cd2
Parents: 2247701
Author: Ulf Lilleengen <lulf@redhat.com>
Authored: Fri Oct 21 15:14:51 2016 +0200
Committer: Clebert Suconic <clebertsuconic@apache.org>
Committed: Mon Oct 24 09:42:22 2016 -0400

----------------------------------------------------------------------
 .../activemq/artemis/core/remoting/impl/netty/NettyConnector.java   | 1 +
 1 file changed, 1 insertion(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/b2a5fe19/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/remoting/impl/netty/NettyConnector.java
----------------------------------------------------------------------
diff --git a/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/remoting/impl/netty/NettyConnector.java
b/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/remoting/impl/netty/NettyConnector.java
index 346e866..c809b96 100644
--- a/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/remoting/impl/netty/NettyConnector.java
+++ b/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/remoting/impl/netty/NettyConnector.java
@@ -912,6 +912,7 @@ public class NettyConnector extends AbstractConnector {
          if (connections.putIfAbsent(connection.getID(), connection) != null) {
             throw ActiveMQClientMessageBundle.BUNDLE.connectionExists(connection.getID());
          }
+         listener.connectionCreated(component, connection, protocol);
       }
 
       @Override


Mime
View raw message