You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by ma...@apache.org on 2016/10/25 13:19:19 UTC
[04/33] activemq-artemis git commit: ARTEMIS-814: Notify connection
listener of connection created
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/ARTEMIS-780
Commit: b2a5fe19d30ad6114db2c4cc1d560e8be9945cd2
Parents: 2247701
Author: Ulf Lilleengen <lu...@redhat.com>
Authored: Fri Oct 21 15:14:51 2016 +0200
Committer: Clebert Suconic <cl...@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