activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From clebertsuco...@apache.org
Subject [50/60] [abbrv] activemq-artemis git commit: small tweak
Date Wed, 16 Mar 2016 01:54:14 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/3bd1cdeb
Tree: http://git-wip-us.apache.org/repos/asf/activemq-artemis/tree/3bd1cdeb
Diff: http://git-wip-us.apache.org/repos/asf/activemq-artemis/diff/3bd1cdeb

Branch: refs/heads/refactor-openwire
Commit: 3bd1cdebe016f048e9fde7efeabdaf4ee0ccb48c
Parents: 4bbe983
Author: Clebert Suconic <clebertsuconic@apache.org>
Authored: Fri Mar 4 17:42:01 2016 -0500
Committer: Clebert Suconic <clebertsuconic@apache.org>
Committed: Tue Mar 15 20:45:29 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/3bd1cdeb/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