This is an automated email from the ASF dual-hosted git repository.
tabish pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/qpid-protonj2.git
The following commit(s) were added to refs/heads/main by this push:
new 92a0616 PROTON-2393 Fix test peer session tracking of last remote
open session
92a0616 is described below
commit 92a0616cdae9dddc333220536d4d3a1e4ca72b29
Author: Timothy Bish <[email protected]>
AuthorDate: Thu Sep 23 13:39:10 2021 -0400
PROTON-2393 Fix test peer session tracking of last remote open session
---
.../java/org/apache/qpid/protonj2/test/driver/DriverSessions.java | 6 ++----
.../test/driver/legacy/LegacyCodecOpenFramesTestDataGenerator.java | 4 ++--
2 files changed, 4 insertions(+), 6 deletions(-)
diff --git
a/protonj2-test-driver/src/main/java/org/apache/qpid/protonj2/test/driver/DriverSessions.java
b/protonj2-test-driver/src/main/java/org/apache/qpid/protonj2/test/driver/DriverSessions.java
index dd3fa93..92a07be 100644
---
a/protonj2-test-driver/src/main/java/org/apache/qpid/protonj2/test/driver/DriverSessions.java
+++
b/protonj2-test-driver/src/main/java/org/apache/qpid/protonj2/test/driver/DriverSessions.java
@@ -44,7 +44,7 @@ public class DriverSessions {
}
public SessionTracker getLastRemotelyOpenedSession() {
- return localSessions.get(lastRemotelyOpenedSession);
+ return remoteSessions.get(lastRemotelyOpenedSession);
}
public SessionTracker getLastLocallyOpenedSession() {
@@ -101,14 +101,12 @@ public class DriverSessions {
// Remote has requested that the driver create a new session which
will require a scripted
// response in order to complete the begin cycle. Start tracking
now for future
sessionTracker = new SessionTracker(driver);
-
- localSessions.put(sessionTracker.getLocalChannel(),
sessionTracker);
}
sessionTracker.handleBegin(remoteBegin, remoteChannel);
remoteSessions.put(remoteChannel, sessionTracker);
- lastRemotelyOpenedSession = sessionTracker.getLocalChannel();
+ lastRemotelyOpenedSession = sessionTracker.getRemoteChannel();
return sessionTracker;
}
diff --git
a/protonj2-test-driver/src/test/java/org/apache/qpid/protonj2/test/driver/legacy/LegacyCodecOpenFramesTestDataGenerator.java
b/protonj2-test-driver/src/test/java/org/apache/qpid/protonj2/test/driver/legacy/LegacyCodecOpenFramesTestDataGenerator.java
index 8d75789..24a371a 100644
---
a/protonj2-test-driver/src/test/java/org/apache/qpid/protonj2/test/driver/legacy/LegacyCodecOpenFramesTestDataGenerator.java
+++
b/protonj2-test-driver/src/test/java/org/apache/qpid/protonj2/test/driver/legacy/LegacyCodecOpenFramesTestDataGenerator.java
@@ -54,8 +54,8 @@ public class LegacyCodecOpenFramesTestDataGenerator {
complete.setDesiredCapabilities(Symbol.valueOf("ANONYMOUS-RELAY"),
Symbol.valueOf("DELAYED-DELIVERY"));
complete.setOfferedCapabilities(Symbol.valueOf("SOMETHING"));
- Map<String, Object> properties = new HashMap<>();
- properties.put("queue-prefix", "queue://");
+ Map<Symbol, Object> properties = new HashMap<>();
+ properties.put(Symbol.valueOf("queue-prefix"), "queue://");
complete.setProperties(properties);
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
