You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by ro...@apache.org on 2014/09/01 22:46:02 UTC
svn commit: r1621882 -
/qpid/jms/trunk/src/main/java/org/apache/qpid/jms/engine/AmqpConnectionDriverNetty.java
Author: robbie
Date: Mon Sep 1 20:46:02 2014
New Revision: 1621882
URL: http://svn.apache.org/r1621882
Log:
QPIDJMS-25: fix write size logging, add logging when write request is not successful
Modified:
qpid/jms/trunk/src/main/java/org/apache/qpid/jms/engine/AmqpConnectionDriverNetty.java
Modified: qpid/jms/trunk/src/main/java/org/apache/qpid/jms/engine/AmqpConnectionDriverNetty.java
URL: http://svn.apache.org/viewvc/qpid/jms/trunk/src/main/java/org/apache/qpid/jms/engine/AmqpConnectionDriverNetty.java?rev=1621882&r1=1621881&r2=1621882&view=diff
==============================================================================
--- qpid/jms/trunk/src/main/java/org/apache/qpid/jms/engine/AmqpConnectionDriverNetty.java (original)
+++ qpid/jms/trunk/src/main/java/org/apache/qpid/jms/engine/AmqpConnectionDriverNetty.java Mon Sep 1 20:46:02 2014
@@ -286,8 +286,6 @@ public class AmqpConnectionDriverNetty
for (EventHandler h : handlers)
{
Events.dispatch(ev, h);
- //TODO: delete
- //processAmqpConnection();
}
_collector.pop();
}
@@ -318,7 +316,7 @@ public class AmqpConnectionDriverNetty
if (pending > 0)
{
final int size = pending - offset;
- logMessage("Size:" + pending);
+ logMessage("Size:" + size);
if (size > 0)
{
ByteBuf buffer = Unpooled.buffer(size);
@@ -348,7 +346,7 @@ public class AmqpConnectionDriverNetty
}
else
{
- // ???
+ logMessage("Write operation FAILED");
}
}
});
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@qpid.apache.org
For additional commands, e-mail: commits-help@qpid.apache.org