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 8d3508eaf2 ARTEMIS-4828 remove unused variables
8d3508eaf2 is described below
commit 8d3508eaf2f1fdfd72986e61400a39498315be34
Author: Justin Bertram <[email protected]>
AuthorDate: Wed Jun 19 12:59:53 2024 -0500
ARTEMIS-4828 remove unused variables
---
.../activemq/artemis/core/deployers/impl/FileConfigurationParser.java | 2 --
.../apache/activemq/artemis/core/replication/ReplicationEndpoint.java | 2 --
.../apache/activemq/artemis/core/server/impl/ActiveMQServerImpl.java | 2 +-
3 files changed, 1 insertion(+), 5 deletions(-)
diff --git
a/artemis-server/src/main/java/org/apache/activemq/artemis/core/deployers/impl/FileConfigurationParser.java
b/artemis-server/src/main/java/org/apache/activemq/artemis/core/deployers/impl/FileConfigurationParser.java
index 5dc2e7adeb..e2a0a8874c 100644
---
a/artemis-server/src/main/java/org/apache/activemq/artemis/core/deployers/impl/FileConfigurationParser.java
+++
b/artemis-server/src/main/java/org/apache/activemq/artemis/core/deployers/impl/FileConfigurationParser.java
@@ -2395,8 +2395,6 @@ public final class FileConfigurationParser extends
XMLConfigurationUtil {
int clusterNotificationAttempts = getInteger(e, "notification-attempts",
ActiveMQDefaultConfiguration.getDefaultClusterNotificationAttempts(), GT_ZERO);
- String scaleDownConnector = e.getAttribute("scale-down-connector");
-
String discoveryGroupName = null;
List<String> staticConnectorNames = new ArrayList<>();
diff --git
a/artemis-server/src/main/java/org/apache/activemq/artemis/core/replication/ReplicationEndpoint.java
b/artemis-server/src/main/java/org/apache/activemq/artemis/core/replication/ReplicationEndpoint.java
index 7b363a701b..42a0558803 100644
---
a/artemis-server/src/main/java/org/apache/activemq/artemis/core/replication/ReplicationEndpoint.java
+++
b/artemis-server/src/main/java/org/apache/activemq/artemis/core/replication/ReplicationEndpoint.java
@@ -37,7 +37,6 @@ import org.apache.activemq.artemis.api.core.ActiveMQException;
import org.apache.activemq.artemis.api.core.Interceptor;
import org.apache.activemq.artemis.api.core.Message;
import org.apache.activemq.artemis.api.core.SimpleString;
-import org.apache.activemq.artemis.core.config.Configuration;
import org.apache.activemq.artemis.core.io.SequentialFile;
import org.apache.activemq.artemis.core.journal.EncoderPersister;
import org.apache.activemq.artemis.core.journal.Journal;
@@ -298,7 +297,6 @@ public final class ReplicationEndpoint implements
ChannelHandler, ActiveMQCompon
@Override
public synchronized void start() throws Exception {
- Configuration config = server.getConfiguration();
try {
storageManager = server.getStorageManager();
storageManager.start();
diff --git
a/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/ActiveMQServerImpl.java
b/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/ActiveMQServerImpl.java
index 6625592517..4b77e2458e 100644
---
a/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/ActiveMQServerImpl.java
+++
b/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/ActiveMQServerImpl.java
@@ -3515,7 +3515,7 @@ public class ActiveMQServerImpl implements ActiveMQServer
{
pagingManager.reloadStores();
Set<Long> storedLargeMessages = new HashSet<>();
- JournalLoadInformation[] journalInfo = loadJournals(storedLargeMessages);
+ loadJournals(storedLargeMessages);
if (rebuildCounters) {
pagingManager.rebuildCounters(storedLargeMessages);
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
For further information, visit: https://activemq.apache.org/contact
