From eaf2392debf030ccec166c0ab6a6532cf94ab3a0 Mon Sep 17 00:00:00 2001 From: Robert Godfrey Date: Fri, 8 Aug 2014 19:38:24 +0000 Subject: QPID-5746 : [Java Broker] enforce idle disconnect of AMQP 0-8/9/9-1 connections git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1616861 13f79535-47bb-0310-9956-ffa450edef68 --- .../apache/qpid/server/protocol/v0_8/AMQProtocolEngine.java | 11 ++++++++++- 1 file changed, 10 insertions(+), 1 deletion(-) 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 46a9430814..3ae9de8368 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 @@ -1273,7 +1273,16 @@ public class AMQProtocolEngine implements ServerProtocolEngine, AMQProtocolSessi public void readerIdle() { - // TODO - enforce disconnect on lack of inbound data + Subject.doAs(_authorizedSubject, new PrivilegedAction() + { + @Override + public Object run() + { + getEventLogger().message(ConnectionMessages.IDLE_CLOSE()); + _network.close(); + return null; + } + }); } public synchronized void writerIdle() -- cgit v1.2.1