From 503b33b9c8ae17a5dc77b8a306a120ea8cdb31d4 Mon Sep 17 00:00:00 2001 From: Robert Godfrey Date: Wed, 11 Feb 2015 14:52:27 +0000 Subject: some more fixes git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/QPID-6262-JavaBrokerNIO@1658974 13f79535-47bb-0310-9956-ffa450edef68 --- .../org/apache/qpid/transport/network/io/NonBlockingSenderReceiver.java | 2 ++ 1 file changed, 2 insertions(+) (limited to 'qpid/java/common/src') diff --git a/qpid/java/common/src/main/java/org/apache/qpid/transport/network/io/NonBlockingSenderReceiver.java b/qpid/java/common/src/main/java/org/apache/qpid/transport/network/io/NonBlockingSenderReceiver.java index c17ee500b0..ee99233063 100644 --- a/qpid/java/common/src/main/java/org/apache/qpid/transport/network/io/NonBlockingSenderReceiver.java +++ b/qpid/java/common/src/main/java/org/apache/qpid/transport/network/io/NonBlockingSenderReceiver.java @@ -244,7 +244,9 @@ public class NonBlockingSenderReceiver implements ByteBufferSender @Override public void flush() { + _stateChanged.set(true); _connection.getSelector().wakeup(); + } @Override -- cgit v1.2.1