Skip to content

Commit

Permalink
ARTEMIS-4523 Using JMS 1.1 for createSession
Browse files Browse the repository at this point in the history
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
  • Loading branch information
clebertsuconic committed Dec 4, 2023
1 parent 3ec0274 commit ed929fb
Showing 1 changed file with 2 additions and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -93,7 +93,7 @@ public void testFastReconnectCreateConsumerNoErrors() throws Exception {
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();

Expand Down Expand Up @@ -153,7 +153,7 @@ public void testFastReconnectCreateConsumerNoErrorsNoClientId() throws Exception
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();
Expand Down

0 comments on commit ed929fb

Please sign in to comment.