cleanup consumer
Project: http://git-wip-us.apache.org/repos/asf/activemq-artemis/repo Commit: http://git-wip-us.apache.org/repos/asf/activemq-artemis/commit/3f04e0af Tree: http://git-wip-us.apache.org/repos/asf/activemq-artemis/tree/3f04e0af Diff: http://git-wip-us.apache.org/repos/asf/activemq-artemis/diff/3f04e0af Branch: refs/heads/refactor-openwire Commit: 3f04e0af435ec0ed5aa97477ccc3c2110aaf2004 Parents: e30a186 Author: Clebert Suconic <[email protected]> Authored: Wed Mar 16 08:23:45 2016 -0400 Committer: Clebert Suconic <[email protected]> Committed: Thu Mar 17 14:10:46 2016 -0400 ---------------------------------------------------------------------- .../artemis/core/protocol/openwire/amq/AMQConsumer.java | 5 ----- 1 file changed, 5 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/3f04e0af/artemis-protocols/artemis-openwire-protocol/src/main/java/org/apache/activemq/artemis/core/protocol/openwire/amq/AMQConsumer.java ---------------------------------------------------------------------- diff --git a/artemis-protocols/artemis-openwire-protocol/src/main/java/org/apache/activemq/artemis/core/protocol/openwire/amq/AMQConsumer.java b/artemis-protocols/artemis-openwire-protocol/src/main/java/org/apache/activemq/artemis/core/protocol/openwire/amq/AMQConsumer.java index 7c2a9bd..8e7ff49 100644 --- a/artemis-protocols/artemis-openwire-protocol/src/main/java/org/apache/activemq/artemis/core/protocol/openwire/amq/AMQConsumer.java +++ b/artemis-protocols/artemis-openwire-protocol/src/main/java/org/apache/activemq/artemis/core/protocol/openwire/amq/AMQConsumer.java @@ -320,11 +320,6 @@ public class AMQConsumer implements BrowserListener { session.deliverMessage(md); } - public boolean handledTransactionalMsg() { - // TODO Auto-generated method stub - return false; - } - //this is called before session commit a local tx public void finishTx() throws Exception { MessageInfo lastMi = null;
