activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From clebertsuco...@apache.org
Subject [57/58] [abbrv] activemq-artemis git commit: small tweak
Date Fri, 04 Mar 2016 22:43:41 GMT
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/0759e793
Tree: http://git-wip-us.apache.org/repos/asf/activemq-artemis/tree/0759e793
Diff: http://git-wip-us.apache.org/repos/asf/activemq-artemis/diff/0759e793

Branch: refs/heads/refactor-openwire
Commit: 0759e793d4c14f780b64675cb2ed273e06ab0edd
Parents: d86014e
Author: Clebert Suconic <clebertsuconic@apache.org>
Authored: Fri Mar 4 17:42:01 2016 -0500
Committer: Clebert Suconic <clebertsuconic@apache.org>
Committed: Fri Mar 4 17:42:19 2016 -0500

----------------------------------------------------------------------
 .../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/0759e793/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();
       }
 


Mime
View raw message