From 29af4a982a5048b07493b8644070095ecf942876 Mon Sep 17 00:00:00 2001 From: Clebert Suconic Date: Mon, 20 Feb 2017 19:33:50 -0500 Subject: [PATCH] NO-JIRA: removing dead code on AMQPSessionContext --- .../protocol/amqp/proton/AMQPSessionContext.java | 16 ---------------- 1 file changed, 16 deletions(-) diff --git a/artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/proton/AMQPSessionContext.java b/artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/proton/AMQPSessionContext.java index 9e0b734db5..bd7b979151 100644 --- a/artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/proton/AMQPSessionContext.java +++ b/artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/proton/AMQPSessionContext.java @@ -89,22 +89,6 @@ public class AMQPSessionContext extends ProtonInitializable { } } - /** - * The consumer object from the broker or the key used to store the sender - * - * @param message - * @param consumer - * @param deliveryCount - * @return the number of bytes sent - */ - public int serverDelivery(Object message, Object consumer, int deliveryCount) throws Exception { - ProtonServerSenderContext protonSender = serverSenders.get(consumer); - if (protonSender != null) { - return protonSender.deliverMessage(message, deliveryCount); - } - return 0; - } - public byte[] getTag() { return Long.toHexString(currentTag++).getBytes(); }