[activemq-artemis] branch main updated: ARTEMIS-4453 Removing unused parameter from constructor

[clebertsuconic]

This is an automated email from the ASF dual-hosted git repository.

clebertsuconic pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/activemq-artemis.git


The following commit(s) were added to refs/heads/main by this push:
     new c46c6f11f6 ARTEMIS-4453 Removing unused parameter from constructor
c46c6f11f6 is described below

commit c46c6f11f676b690c37ac5194e829837b322b3dc
Author: Clebert Suconic <clebertsuco...@apache.org>
AuthorDate: Thu Oct 12 12:21:42 2023 -0400

    ARTEMIS-4453 Removing unused parameter from constructor
---
 .../activemq/artemis/core/client/impl/ClientSessionFactoryImpl.java   | 2 +-
 .../apache/activemq/artemis/core/client/impl/ClientSessionImpl.java   | 4 +---
 2 files changed, 2 insertions(+), 4 deletions(-)

diff --git 
a/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/client/impl/ClientSessionFactoryImpl.java
 
b/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/client/impl/ClientSessionFactoryImpl.java
index e4968245d6..86d0b9465d 100644
--- 
a/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/client/impl/ClientSessionFactoryImpl.java
+++ 
b/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/client/impl/ClientSessionFactoryImpl.java
@@ -836,7 +836,7 @@ public class ClientSessionFactoryImpl implements 
ClientSessionFactoryInternal, C
 
       SessionContext context = createSessionChannel(name, username, password, 
xa, autoCommitSends, autoCommitAcks, preAcknowledge, clientID);
 
-      ClientSessionInternal session = new ClientSessionImpl(this, name, 
username, password, xa, autoCommitSends, autoCommitAcks, preAcknowledge, 
serverLocator.isBlockOnAcknowledge(), serverLocator.isAutoGroup(), 
ackBatchSize, serverLocator.getConsumerWindowSize(), 
serverLocator.getConsumerMaxRate(), serverLocator.getConfirmationWindowSize(), 
serverLocator.getProducerWindowSize(), serverLocator.getProducerMaxRate(), 
serverLocator.isBlockOnNonDurableSend(), serverLocator.isBlockOnDurableSe [...]
+      ClientSessionInternal session = new ClientSessionImpl(this, name, 
username, password, xa, autoCommitSends, autoCommitAcks, preAcknowledge, 
serverLocator.isBlockOnAcknowledge(), serverLocator.isAutoGroup(), 
ackBatchSize, serverLocator.getConsumerWindowSize(), 
serverLocator.getConsumerMaxRate(), serverLocator.getConfirmationWindowSize(), 
serverLocator.getProducerWindowSize(), serverLocator.getProducerMaxRate(), 
serverLocator.isBlockOnNonDurableSend(), serverLocator.isBlockOnDurableSe [...]
 
       synchronized (sessions) {
          if (closed || !clientProtocolManager.isAlive()) {
diff --git 
a/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/client/impl/ClientSessionImpl.java
 
b/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/client/impl/ClientSessionImpl.java
index 9d6aeae416..54a2b86cbb 100644
--- 
a/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/client/impl/ClientSessionImpl.java
+++ 
b/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/client/impl/ClientSessionImpl.java
@@ -26,7 +26,6 @@ import java.util.LinkedHashMap;
 import java.util.Map;
 import java.util.Set;
 import java.util.concurrent.Executor;
-import java.util.concurrent.ScheduledExecutorService;
 import java.util.concurrent.atomic.AtomicInteger;
 
 import org.apache.activemq.artemis.api.config.ActiveMQDefaultConfiguration;
@@ -194,8 +193,7 @@ public final class ClientSessionImpl implements 
ClientSessionInternal, FailureLi
                      final Executor executor,
                      final Executor confirmationExecutor,
                      final Executor flowControlExecutor,
-                     final Executor closeExecutor,
-                     final ScheduledExecutorService scheduledThreadPool) 
throws ActiveMQException {
+                     final Executor closeExecutor) throws ActiveMQException {
       this.sessionFactory = sessionFactory;
 
       this.name = name;