Apache
/
activemq-artemis
mirror of https://github.com/apache/activemq-artemis.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

ARTEMIS-4523 Using JMS 1.1 for createSession 

if using an older OpenWire client version, this could have issues.
so I'm just updating the test to use the equivalent method in 1.1 to avoid issues
This commit is contained in:
Clebert Suconic 2023-12-04 12:29:57 -05:00
parent 3ec0274356
commit ed929fbd1b
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/openwire/FastReconnectOpenWireTest.java
View File

@ -93,7 +93,7 @@ public class FastReconnectOpenWireTest extends OpenWireTestBase {
executor.execute(() -> {
try {
while (numIterations.decrementAndGet() > 0) {
try (Connection conn = exFact.createConnection(); Session consumerConnectionSession = conn.createSession(Session.SESSION_TRANSACTED); MessageConsumer messageConsumer = consumerConnectionSession.createConsumer(queue)) {
try (Connection conn = exFact.createConnection(); Session consumerConnectionSession = conn.createSession(true, Session.SESSION_TRANSACTED); MessageConsumer messageConsumer = consumerConnectionSession.createConsumer(queue)) {
messageConsumer.receiveNoWait();
@ -153,7 +153,7 @@ public class FastReconnectOpenWireTest extends OpenWireTestBase {
for (int i = 0; i < concurrent; i++) {
executor.execute(() -> {
try (Connection conn = exFact.createConnection();
Session consumerConnectionSession = conn.createSession(Session.SESSION_TRANSACTED);
Session consumerConnectionSession = conn.createSession(true, Session.SESSION_TRANSACTED);
MessageConsumer messageConsumer = consumerConnectionSession.createConsumer(queue)
) {
conn.start();