[qpid-protonj2] branch main updated: PROTON-2393 Fix test peer session tracking of last remote open session

[tabish]

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 <tabish...@gmail.com>
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: commits-unsubscr...@qpid.apache.org
For additional commands, e-mail: commits-h...@qpid.apache.org