diff options
| author | orudyy <orudyy@unknown> | 2015-04-02 16:30:07 +0000 |
|---|---|---|
| committer | orudyy <orudyy@unknown> | 2015-04-02 16:30:07 +0000 |
| commit | 4107358e3e6cd033195e6b7e95af6c4111feda88 (patch) | |
| tree | 2ebbdbe879eddf4a6561ad107640069a63c59825 /qpid/java/broker-plugins/amqp-0-8-protocol | |
| parent | 6603e157e9c45772110468a722157e531db06a9f (diff) | |
| download | qpid-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.java | 29 |
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; |
