Author: kwall
Date: Wed Sep 21 16:01:10 2011
New Revision: 1173738
URL: http://svn.apache.org/viewvc?rev=1173738&view=rev
Log:
QPID-3498: Broker race condition mean that it tries to respond before IoSender
thread is running
Modified:
qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/transport/network/io/IoNetworkConnection.java
qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/transport/network/io/IoSender.java
Modified:
qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/transport/network/io/IoNetworkConnection.java
URL:
http://svn.apache.org/viewvc/qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/transport/network/io/IoNetworkConnection.java?rev=1173738&r1=1173737&r2=1173738&view=diff
==============================================================================
---
qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/transport/network/io/IoNetworkConnection.java
(original)
+++
qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/transport/network/io/IoNetworkConnection.java
Wed Sep 21 16:01:10 2011
@@ -54,8 +54,8 @@ public class IoNetworkConnection impleme
public void start()
{
- _ioReceiver.initiate();
_ioSender.initiate();
+ _ioReceiver.initiate();
}
public Sender<ByteBuffer> getSender()
Modified:
qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/transport/network/io/IoSender.java
URL:
http://svn.apache.org/viewvc/qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/transport/network/io/IoSender.java?rev=1173738&r1=1173737&r2=1173738&view=diff
==============================================================================
---
qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/transport/network/io/IoSender.java
(original)
+++
qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/transport/network/io/IoSender.java
Wed Sep 21 16:01:10 2011
@@ -113,6 +113,10 @@ public final class IoSender implements R
{
throw new SenderClosedException("sender is closed", exception);
}
+ if(!senderThread.isAlive())
+ {
+ throw new SenderException("sender thread not alive");
+ }
final int size = buffer.length;
int remaining = buf.remaining();
---------------------------------------------------------------------
Apache Qpid - AMQP Messaging Implementation
Project: http://qpid.apache.org
Use/Interact: mailto:[email protected]
