Author: rgodfrey
Date: Wed Jun 27 19:14:18 2012
New Revision: 1354674
URL: http://svn.apache.org/viewvc?rev=1354674&view=rev
Log:
NO-JIRA : [Proton-j] fix queued implementation for sender
Modified:
qpid/proton/trunk/proton-j/src/org/apache/qpid/proton/engine/impl/LinkImpl.java
qpid/proton/trunk/proton-j/src/org/apache/qpid/proton/engine/impl/ReceiverImpl.java
qpid/proton/trunk/proton-j/src/org/apache/qpid/proton/engine/impl/TransportImpl.java
Modified:
qpid/proton/trunk/proton-j/src/org/apache/qpid/proton/engine/impl/LinkImpl.java
URL:
http://svn.apache.org/viewvc/qpid/proton/trunk/proton-j/src/org/apache/qpid/proton/engine/impl/LinkImpl.java?rev=1354674&r1=1354673&r2=1354674&view=diff
==============================================================================
---
qpid/proton/trunk/proton-j/src/org/apache/qpid/proton/engine/impl/LinkImpl.java
(original)
+++
qpid/proton/trunk/proton-j/src/org/apache/qpid/proton/engine/impl/LinkImpl.java
Wed Jun 27 19:14:18 2012
@@ -74,6 +74,8 @@ public abstract class LinkImpl extends E
public DeliveryImpl delivery(byte[] tag, int offset, int length)
{
+
+ incrementQueued();
try
{
DeliveryImpl delivery = new DeliveryImpl(tag, this, _tail);
Modified:
qpid/proton/trunk/proton-j/src/org/apache/qpid/proton/engine/impl/ReceiverImpl.java
URL:
http://svn.apache.org/viewvc/qpid/proton/trunk/proton-j/src/org/apache/qpid/proton/engine/impl/ReceiverImpl.java?rev=1354674&r1=1354673&r2=1354674&view=diff
==============================================================================
---
qpid/proton/trunk/proton-j/src/org/apache/qpid/proton/engine/impl/ReceiverImpl.java
(original)
+++
qpid/proton/trunk/proton-j/src/org/apache/qpid/proton/engine/impl/ReceiverImpl.java
Wed Jun 27 19:14:18 2012
@@ -27,14 +27,6 @@ import org.apache.qpid.proton.engine.Seq
public class ReceiverImpl extends LinkImpl implements Receiver
{
-
- @Override
- public DeliveryImpl delivery(byte[] tag, int offset, int length)
- {
- incrementQueued();
- return super.delivery(tag, offset, length);
- }
-
@Override
public boolean advance()
{
Modified:
qpid/proton/trunk/proton-j/src/org/apache/qpid/proton/engine/impl/TransportImpl.java
URL:
http://svn.apache.org/viewvc/qpid/proton/trunk/proton-j/src/org/apache/qpid/proton/engine/impl/TransportImpl.java?rev=1354674&r1=1354673&r2=1354674&view=diff
==============================================================================
---
qpid/proton/trunk/proton-j/src/org/apache/qpid/proton/engine/impl/TransportImpl.java
(original)
+++
qpid/proton/trunk/proton-j/src/org/apache/qpid/proton/engine/impl/TransportImpl.java
Wed Jun 27 19:14:18 2012
@@ -310,7 +310,7 @@ public class TransportImpl extends Endpo
{
SenderImpl sender = (SenderImpl) delivery.getLink();
- sender.incrementQueued();
+ sender.decrementQueued();
TransportLink transportLink = sender.getTransportLink();
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
