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/7cfdf6b8 Tree: http://git-wip-us.apache.org/repos/asf/activemq-artemis/tree/7cfdf6b8 Diff: http://git-wip-us.apache.org/repos/asf/activemq-artemis/diff/7cfdf6b8 Branch: refs/heads/refactor-openwire Commit: 7cfdf6b83eb7444176c90c67651685cbbbdc2723 Parents: a8179e7 Author: Clebert Suconic <[email protected]> Authored: Wed Mar 16 08:23:45 2016 -0400 Committer: Clebert Suconic <[email protected]> Committed: Wed Mar 16 11:19:15 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/7cfdf6b8/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;
