Author: rgodfrey
Date: Thu Sep 27 19:52:19 2012
New Revision: 1391190
URL: http://svn.apache.org/viewvc?rev=1391190&view=rev
Log:
PROTON-37 : Fix failing python tests
Modified:
qpid/proton/trunk/proton-j/src/main/java/org/apache/qpid/proton/engine/impl/LinkImpl.java
qpid/proton/trunk/proton-j/src/main/java/org/apache/qpid/proton/engine/impl/SessionImpl.java
qpid/proton/trunk/proton-j/src/main/scripts/jproton.py
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=1391190&r1=1391189&r2=1391190&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
Thu Sep 27 19:52:19 2012
@@ -41,7 +41,7 @@ public abstract class LinkImpl extends E
private int _credit;
private int _unsettled;
- private LinkNode<LinkImpl> _node;
+ private final LinkNode<LinkImpl> _node;
private boolean _drain;
@@ -285,4 +285,5 @@ public abstract class LinkImpl extends E
{
return _drain;
}
+
}
Modified:
qpid/proton/trunk/proton-j/src/main/java/org/apache/qpid/proton/engine/impl/SessionImpl.java
URL:
http://svn.apache.org/viewvc/qpid/proton/trunk/proton-j/src/main/java/org/apache/qpid/proton/engine/impl/SessionImpl.java?rev=1391190&r1=1391189&r2=1391190&view=diff
==============================================================================
---
qpid/proton/trunk/proton-j/src/main/java/org/apache/qpid/proton/engine/impl/SessionImpl.java
(original)
+++
qpid/proton/trunk/proton-j/src/main/java/org/apache/qpid/proton/engine/impl/SessionImpl.java
Thu Sep 27 19:52:19 2012
@@ -61,7 +61,6 @@ public class SessionImpl extends Endpoin
{
sender = new SenderImpl(this, name);
_senders.put(name, sender);
- _connection.addLinkEndpoint(sender);
}
return sender;
}
@@ -73,7 +72,6 @@ public class SessionImpl extends Endpoin
{
receiver = new ReceiverImpl(this, name);
_receivers.put(name, receiver);
- _connection.addLinkEndpoint(receiver);
}
return receiver;
}
Modified: qpid/proton/trunk/proton-j/src/main/scripts/jproton.py
URL:
http://svn.apache.org/viewvc/qpid/proton/trunk/proton-j/src/main/scripts/jproton.py?rev=1391190&r1=1391189&r2=1391190&view=diff
==============================================================================
--- qpid/proton/trunk/proton-j/src/main/scripts/jproton.py (original)
+++ qpid/proton/trunk/proton-j/src/main/scripts/jproton.py Thu Sep 27 19:52:19
2012
@@ -198,6 +198,15 @@ def pn_work_head(c):
def pn_work_next(d):
return d.getWorkNext()
+def pn_link_head(c, m):
+ local, remote = enums(m)
+ return c.linkHead(local, remote)
+
+
+def pn_link_next(l, m):
+ local, remote = enums(m)
+ return l.next(local, remote)
+
def pn_flow(rcv, n):
return rcv.flow(n)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
