diff options
| author | Rafael H. Schloming <rhs@apache.org> | 2009-01-06 02:07:20 +0000 |
|---|---|---|
| committer | Rafael H. Schloming <rhs@apache.org> | 2009-01-06 02:07:20 +0000 |
| commit | 7f42616db97eee3890f07188272b8d028839ebec (patch) | |
| tree | b20a578ebb71521b346a9e4f06db3237ef0b7450 /qpid/java/common/src | |
| parent | 2d0f50dd935642cf84b3fc3eb7fcbb1cf12dcbe8 (diff) | |
| download | qpid-python-7f42616db97eee3890f07188272b8d028839ebec.tar.gz | |
QPID-1557: fixed the cpp.cluster test profile
- pulled out the XA excludes into a separate excludes file
- made the cluster profile exclude the XA tests
- made the build system automatically set all system properties that
start with profile
- added a profile.clustered property that defaults to false
- made the cpp.cluster test profile set the profile.clustered
property to true
- modified the failover tests to exclude some erroneous asserts if
the broker is clustered
- modified the java client to not advertize a non-zero timeout
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@731810 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid/java/common/src')
| -rw-r--r-- | qpid/java/common/src/main/java/org/apache/qpid/transport/Session.java | 9 | ||||
| -rw-r--r-- | qpid/java/common/src/main/java/org/apache/qpid/transport/SessionDelegate.java | 4 |
2 files changed, 11 insertions, 2 deletions
diff --git a/qpid/java/common/src/main/java/org/apache/qpid/transport/Session.java b/qpid/java/common/src/main/java/org/apache/qpid/transport/Session.java index 22561dcc33..1a44ed8973 100644 --- a/qpid/java/common/src/main/java/org/apache/qpid/transport/Session.java +++ b/qpid/java/common/src/main/java/org/apache/qpid/transport/Session.java @@ -179,7 +179,9 @@ public class Session extends SessionInvoker { initReceiver(); sessionAttach(name.getBytes()); - sessionRequestTimeout(expiry); + // XXX: when the broker and client support full session + // recovery we should use expiry as the requested timeout + sessionRequestTimeout(0); } void resume() @@ -734,6 +736,11 @@ public class Session extends SessionInvoker synchronized (commands) { state = CLOSING; + // XXX: we manually set the expiry to zero here to + // simulate full session recovery in brokers that don't + // support it, we should remove this line when there is + // broker support for full session resume: + expiry = 0; sessionRequestTimeout(0); sessionDetach(name.getBytes()); Waiter w = new Waiter(commands, timeout); diff --git a/qpid/java/common/src/main/java/org/apache/qpid/transport/SessionDelegate.java b/qpid/java/common/src/main/java/org/apache/qpid/transport/SessionDelegate.java index 520291e71c..b2c22f22e9 100644 --- a/qpid/java/common/src/main/java/org/apache/qpid/transport/SessionDelegate.java +++ b/qpid/java/common/src/main/java/org/apache/qpid/transport/SessionDelegate.java @@ -64,7 +64,9 @@ public class SessionDelegate @Override public void sessionTimeout(Session ssn, SessionTimeout t) { - ssn.setExpiry(t.getTimeout()); + // XXX: we ignore this right now, we should uncomment this + // when full session resume is supported: + // ssn.setExpiry(t.getTimeout()); } @Override public void sessionCompleted(Session ssn, SessionCompleted cmp) |
