small tweak
Project: http://git-wip-us.apache.org/repos/asf/activemq-artemis/repo Commit: http://git-wip-us.apache.org/repos/asf/activemq-artemis/commit/060e99e0 Tree: http://git-wip-us.apache.org/repos/asf/activemq-artemis/tree/060e99e0 Diff: http://git-wip-us.apache.org/repos/asf/activemq-artemis/diff/060e99e0 Branch: refs/heads/refactor-openwire Commit: 060e99e0bef3c0fa76dbb1ccc481f444231b0d7c Parents: 481e1ef Author: Clebert Suconic <[email protected]> Authored: Fri Mar 4 17:42:01 2016 -0500 Committer: Clebert Suconic <[email protected]> Committed: Wed Mar 16 11:19:15 2016 -0400 ---------------------------------------------------------------------- .../artemis/core/protocol/openwire/OpenWireConnection.java | 7 +++++-- 1 file changed, 5 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/060e99e0/artemis-protocols/artemis-openwire-protocol/src/main/java/org/apache/activemq/artemis/core/protocol/openwire/OpenWireConnection.java ---------------------------------------------------------------------- diff --git a/artemis-protocols/artemis-openwire-protocol/src/main/java/org/apache/activemq/artemis/core/protocol/openwire/OpenWireConnection.java b/artemis-protocols/artemis-openwire-protocol/src/main/java/org/apache/activemq/artemis/core/protocol/openwire/OpenWireConnection.java index 598016d..5880f07 100644 --- a/artemis-protocols/artemis-openwire-protocol/src/main/java/org/apache/activemq/artemis/core/protocol/openwire/OpenWireConnection.java +++ b/artemis-protocols/artemis-openwire-protocol/src/main/java/org/apache/activemq/artemis/core/protocol/openwire/OpenWireConnection.java @@ -224,7 +224,7 @@ public class OpenWireConnection extends AbstractRemotingConnection implements Se try { setLastCommand(command); - response = command.visit(new CommandProcessor()); + response = command.visit(commandProcessorInstance); } catch (Exception e) { if (responseRequired) { @@ -835,10 +835,13 @@ public class OpenWireConnection extends AbstractRemotingConnection implements Se } + CommandProcessor commandProcessorInstance = new CommandProcessor(); + + // This will listen for commands throught the protocolmanager public class CommandProcessor implements CommandVisitor { - public AMQConnectionContext getContext() { + private AMQConnectionContext getContext() { return OpenWireConnection.this.getContext(); }
