summaryrefslogtreecommitdiff
path: root/qpid/java/broker-plugins/amqp-0-8-protocol
diff options
context:
space:
mode:
authororudyy <orudyy@unknown>2015-04-02 16:30:07 +0000
committerorudyy <orudyy@unknown>2015-04-02 16:30:07 +0000
commit4107358e3e6cd033195e6b7e95af6c4111feda88 (patch)
tree2ebbdbe879eddf4a6561ad107640069a63c59825 /qpid/java/broker-plugins/amqp-0-8-protocol
parent6603e157e9c45772110468a722157e531db06a9f (diff)
downloadqpid-python-4107358e3e6cd033195e6b7e95af6c4111feda88.tar.gz
QPID-6469: Remove not used method sendResponseAndCloseSender from AMQProtocolEngine.
Remove exception handling code from ProtocolEngine_1_0_0_SASL as it is not used by new i/o layer git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1670933 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid/java/broker-plugins/amqp-0-8-protocol')
-rw-r--r--qpid/java/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/AMQProtocolEngine.java29
1 files changed, 0 insertions, 29 deletions
diff --git a/qpid/java/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/AMQProtocolEngine.java b/qpid/java/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/AMQProtocolEngine.java
index 2178b4f6f3..f1e9f400f4 100644
--- a/qpid/java/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/AMQProtocolEngine.java
+++ b/qpid/java/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/AMQProtocolEngine.java
@@ -1161,35 +1161,6 @@ public class AMQProtocolEngine implements ServerProtocolEngine,
// noop - exception method is not used by new i/o layer
}
- private void sendResponseAndCloseSender(AMQDataBlock dataBlock)
- {
- try
- {
- writeFrame(dataBlock);
- }
- catch(SenderException e)
- {
- if (_logger.isDebugEnabled())
- {
- _logger.debug("Exception occurred on sending response", e);
- }
- }
- finally
- {
- try
- {
- _sender.close();
- }
- catch(SenderException e)
- {
- if (_logger.isDebugEnabled())
- {
- _logger.debug("Exception occurred on sender close", e);
- }
- }
- }
- }
-
public long getReadBytes()
{
return _readBytes;