Author: rgodfrey
Date: Wed Oct 17 16:30:24 2012
New Revision: 1399330
URL: http://svn.apache.org/viewvc?rev=1399330&view=rev
Log:
PROTON-81 : Expose send/receive settle mode on links
Modified:
qpid/proton/trunk/proton-j/src/main/java/org/apache/qpid/proton/engine/Link.java
qpid/proton/trunk/proton-j/src/main/java/org/apache/qpid/proton/engine/impl/LinkImpl.java
Modified:
qpid/proton/trunk/proton-j/src/main/java/org/apache/qpid/proton/engine/Link.java
URL:
http://svn.apache.org/viewvc/qpid/proton/trunk/proton-j/src/main/java/org/apache/qpid/proton/engine/Link.java?rev=1399330&r1=1399329&r2=1399330&view=diff
==============================================================================
---
qpid/proton/trunk/proton-j/src/main/java/org/apache/qpid/proton/engine/Link.java
(original)
+++
qpid/proton/trunk/proton-j/src/main/java/org/apache/qpid/proton/engine/Link.java
Wed Oct 17 16:30:24 2012
@@ -21,6 +21,7 @@
package org.apache.qpid.proton.engine;
import java.util.EnumSet;
+import org.apache.qpid.proton.type.UnsignedByte;
import org.apache.qpid.proton.type.transport.Source;
import org.apache.qpid.proton.type.transport.Target;
@@ -73,4 +74,17 @@ public interface Link extends Endpoint
public Session getSession();
+ UnsignedByte getSenderSettleMode();
+
+ void setSenderSettleMode(UnsignedByte senderSettleMode);
+
+ UnsignedByte getRemoteSenderSettleMode();
+
+ void setRemoteSenderSettleMode(UnsignedByte remoteSenderSettleMode);
+
+ UnsignedByte getReceiverSettleMode();
+
+ void setReceiverSettleMode(UnsignedByte receiverSettleMode);
+
+ UnsignedByte getRemoteReceiverSettleMode();
}
Modified:
qpid/proton/trunk/proton-j/src/main/java/org/apache/qpid/proton/engine/impl/LinkImpl.java
URL:
http://svn.apache.org/viewvc/qpid/proton/trunk/proton-j/src/main/java/org/apache/qpid/proton/engine/impl/LinkImpl.java?rev=1399330&r1=1399329&r2=1399330&view=diff
==============================================================================
---
qpid/proton/trunk/proton-j/src/main/java/org/apache/qpid/proton/engine/impl/LinkImpl.java
(original)
+++
qpid/proton/trunk/proton-j/src/main/java/org/apache/qpid/proton/engine/impl/LinkImpl.java
Wed Oct 17 16:30:24 2012
@@ -296,36 +296,43 @@ public abstract class LinkImpl extends E
return _drain;
}
+ @Override
public UnsignedByte getSenderSettleMode()
{
return _senderSettleMode;
}
+ @Override
public void setSenderSettleMode(UnsignedByte senderSettleMode)
{
_senderSettleMode = senderSettleMode;
}
+ @Override
public UnsignedByte getRemoteSenderSettleMode()
{
return _remoteSenderSettleMode;
}
- void setRemoteSenderSettleMode(UnsignedByte remoteSenderSettleMode)
+ @Override
+ public void setRemoteSenderSettleMode(UnsignedByte remoteSenderSettleMode)
{
_remoteSenderSettleMode = remoteSenderSettleMode;
}
+ @Override
public UnsignedByte getReceiverSettleMode()
{
return _receiverSettleMode;
}
+ @Override
public void setReceiverSettleMode(UnsignedByte receiverSettleMode)
{
_receiverSettleMode = receiverSettleMode;
}
+ @Override
public UnsignedByte getRemoteReceiverSettleMode()
{
return _remoteReceiverSettleMode;
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
