Author: rhs
Date: Thu Oct 4 11:49:57 2012
New Revision: 1394000
URL: http://svn.apache.org/viewvc?rev=1394000&view=rev
Log:
added source and target test
Modified:
qpid/proton/trunk/proton-c/bindings/python/proton.py
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
qpid/proton/trunk/proton-j/src/main/scripts/proton.py
qpid/proton/trunk/tests/proton_tests/engine.py
Modified: qpid/proton/trunk/proton-c/bindings/python/proton.py
URL:
http://svn.apache.org/viewvc/qpid/proton/trunk/proton-c/bindings/python/proton.py?rev=1394000&r1=1393999&r2=1394000&view=diff
==============================================================================
--- qpid/proton/trunk/proton-c/bindings/python/proton.py (original)
+++ qpid/proton/trunk/proton-c/bindings/python/proton.py Thu Oct 4 11:49:57
2012
@@ -1372,6 +1372,25 @@ class Link(Endpoint):
def state(self):
return pn_link_state(self._link)
+ def _set_source(self, source):
+ pn_link_set_source(self._link, source)
+ def _get_source(self):
+ return pn_link_get_source(self._link)
+ source = property(_get_source, _set_source)
+
+ def _set_target(self, target):
+ pn_link_set_target(self._link, target)
+ def _get_target(self):
+ return pn_link_get_target(self._link)
+ target = property(_get_target, _set_target)
+
+ @property
+ def remote_source(self):
+ return pn_link_remote_source(self._link)
+ @property
+ def remote_target(self):
+ return pn_link_remote_target(self._link)
+
@property
def session(self):
return wrap_session(pn_link_session(self._link))
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=1394000&r1=1393999&r2=1394000&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
Thu Oct 4 11:49:57 2012
@@ -54,6 +54,8 @@ public interface Link extends Endpoint
*/
boolean advance();
+ String getLocalSourceAddress();
+ String getLocalTargetAddress();
void setLocalSourceAddress(String address);
void setLocalTargetAddress(String address);
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=1394000&r1=1393999&r2=1394000&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 Oct 4 11:49:57 2012
@@ -178,7 +178,7 @@ public abstract class LinkImpl extends E
_remoteTargetAddress = targetAddress;
}
- String getLocalSourceAddress()
+ public String getLocalSourceAddress()
{
return _localSourceAddress;
}
@@ -190,7 +190,7 @@ public abstract class LinkImpl extends E
modified();
}
- String getLocalTargetAddress()
+ public String getLocalTargetAddress()
{
return _localTargetAddress;
}
Modified: qpid/proton/trunk/proton-j/src/main/scripts/proton.py
URL:
http://svn.apache.org/viewvc/qpid/proton/trunk/proton-j/src/main/scripts/proton.py?rev=1394000&r1=1393999&r2=1394000&view=diff
==============================================================================
--- qpid/proton/trunk/proton-j/src/main/scripts/proton.py (original)
+++ qpid/proton/trunk/proton-j/src/main/scripts/proton.py Thu Oct 4 11:49:57
2012
@@ -170,6 +170,25 @@ class Link(Endpoint):
def __init__(self, impl):
self.impl = impl
+ def _set_source(self, source):
+ self.impl.setLocalSourceAddress(source)
+ def _get_source(self):
+ return self.impl.getLocalSourceAddress()
+ source = property(_get_source, _set_source)
+
+ def _set_target(self, target):
+ self.impl.setLocalTargetAddress(target)
+ def _get_target(self):
+ return self.impl.getLocalTargetAddress()
+ target = property(_get_target, _set_target)
+
+ @property
+ def remote_source(self):
+ return self.impl.getRemoteSourceAddress()
+ @property
+ def remote_target(self):
+ return self.impl.getRemoteTargetAddress()
+
@property
def session(self):
return wrap_session(self.impl.getSession())
Modified: qpid/proton/trunk/tests/proton_tests/engine.py
URL:
http://svn.apache.org/viewvc/qpid/proton/trunk/tests/proton_tests/engine.py?rev=1394000&r1=1393999&r2=1394000&view=diff
==============================================================================
--- qpid/proton/trunk/tests/proton_tests/engine.py (original)
+++ qpid/proton/trunk/tests/proton_tests/engine.py Thu Oct 4 11:49:57 2012
@@ -352,6 +352,20 @@ class LinkTest(Test):
self.snd.close()
self.pump()
+ def test_source_target(self):
+ self.snd.source = "source"
+ self.snd.target = "target"
+ self.snd.open()
+ self.pump()
+ assert self.rcv.remote_source == self.snd.source
+ assert self.rcv.remote_target == self.snd.target
+ self.rcv.target = self.rcv.remote_target
+ self.rcv.source = self.rcv.remote_source
+ self.rcv.open()
+ self.pump()
+ assert self.snd.remote_target == self.snd.target
+ assert self.snd.remote_source == self.snd.source
+
class TransferTest(Test):
def setup(self):
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
