Return-Path: X-Original-To: apmail-activemq-commits-archive@www.apache.org Delivered-To: apmail-activemq-commits-archive@www.apache.org Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by minotaur.apache.org (Postfix) with SMTP id 71236192E0 for ; Thu, 31 Mar 2016 02:30:55 +0000 (UTC) Received: (qmail 97977 invoked by uid 500); 31 Mar 2016 02:30:55 -0000 Delivered-To: apmail-activemq-commits-archive@activemq.apache.org Received: (qmail 97685 invoked by uid 500); 31 Mar 2016 02:30:55 -0000 Mailing-List: contact commits-help@activemq.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@activemq.apache.org Delivered-To: mailing list commits@activemq.apache.org Received: (qmail 93994 invoked by uid 99); 31 Mar 2016 02:30:45 -0000 Received: from git1-us-west.apache.org (HELO git1-us-west.apache.org) (140.211.11.23) by apache.org (qpsmtpd/0.29) with ESMTP; Thu, 31 Mar 2016 02:30:45 +0000 Received: by git1-us-west.apache.org (ASF Mail Server at git1-us-west.apache.org, from userid 33) id DA9E6E980D; Thu, 31 Mar 2016 02:30:44 +0000 (UTC) Content-Type: text/plain; charset="us-ascii" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit From: clebertsuconic@apache.org To: commits@activemq.apache.org Date: Thu, 31 Mar 2016 02:31:40 -0000 Message-Id: <3727444ae6c44957babc60cdc5c4298a@git.apache.org> In-Reply-To: References: X-Mailer: ASF-Git Admin Mailer Subject: [58/69] [abbrv] activemq-artemis git commit: small tweak 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/36b2930a Tree: http://git-wip-us.apache.org/repos/asf/activemq-artemis/tree/36b2930a Diff: http://git-wip-us.apache.org/repos/asf/activemq-artemis/diff/36b2930a Branch: refs/heads/refactor-openwire Commit: 36b2930a376fa7783beda6b76ffe6cc07594c615 Parents: c96d776 Author: Clebert Suconic Authored: Fri Mar 4 17:42:01 2016 -0500 Committer: Clebert Suconic Committed: Wed Mar 30 22:29:44 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/36b2930a/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(); }