You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@artemis.apache.org by cl...@apache.org on 2026/09/10 17:09:18 UTC
(artemis) 05/11: Remove unused packet handling
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/artemis.git
commit 905ae7b8555178d52b61af262456c3a32c391721
Author: Domenico Francesco Bruscino <br...@apache.org>
AuthorDate: Fri Jul 17 11:50:45 2026 -0400
Remove unused packet handling
(cherry picked from commit 4e32f8e0d13c3413851f7aa574e83bdab346bf1b)
ARTEMIS-6243
---
.../protocol/core/impl/ActiveMQPacketHandler.java | 22 ----------------------
1 file changed, 22 deletions(-)
diff --git a/artemis-server/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/ActiveMQPacketHandler.java b/artemis-server/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/ActiveMQPacketHandler.java
index 2f399498f8..b23903f88c 100644
--- a/artemis-server/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/ActiveMQPacketHandler.java
+++ b/artemis-server/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/ActiveMQPacketHandler.java
@@ -23,7 +23,6 @@ import org.apache.activemq.artemis.api.core.ActiveMQException;
import org.apache.activemq.artemis.api.core.ActiveMQExceptionType;
import org.apache.activemq.artemis.api.core.ActiveMQInternalErrorException;
import org.apache.activemq.artemis.api.core.ActiveMQSecurityException;
-import org.apache.activemq.artemis.api.core.QueueConfiguration;
import org.apache.activemq.artemis.api.core.RoutingType;
import org.apache.activemq.artemis.api.core.SimpleString;
import org.apache.activemq.artemis.core.persistence.OperationContext;
@@ -35,7 +34,6 @@ import org.apache.activemq.artemis.core.protocol.core.ServerSessionPacketHandler
import org.apache.activemq.artemis.core.protocol.core.impl.wireformat.ActiveMQExceptionMessage;
import org.apache.activemq.artemis.core.protocol.core.impl.wireformat.ConnectMessage;
import org.apache.activemq.artemis.core.protocol.core.impl.wireformat.ConnectResponseMessage;
-import org.apache.activemq.artemis.core.protocol.core.impl.wireformat.CreateQueueMessage;
import org.apache.activemq.artemis.core.protocol.core.impl.wireformat.CreateSessionMessage;
import org.apache.activemq.artemis.core.protocol.core.impl.wireformat.CreateSessionMessage_V2;
import org.apache.activemq.artemis.core.protocol.core.impl.wireformat.CreateSessionResponseMessage;
@@ -120,15 +118,6 @@ public class ActiveMQPacketHandler implements ChannelHandler {
channel1.send(new ReattachSessionResponseMessage(-1, false));
break;
}
- case PacketImpl.CREATE_QUEUE: {
- // Create queue can also be fielded here in the case of a replicated store and forward queue creation
-
- CreateQueueMessage request = (CreateQueueMessage) packet;
-
- handleCreateQueue(request);
-
- break;
- }
default: {
ActiveMQServerLogger.LOGGER.invalidPacket(packet);
}
@@ -260,15 +249,4 @@ public class ActiveMQPacketHandler implements ChannelHandler {
}
}
- private void handleCreateQueue(final CreateQueueMessage request) {
- try {
- server.createQueue(QueueConfiguration.of(request.getQueueName())
- .setAddress(request.getAddress())
- .setFilterString(request.getFilterString())
- .setDurable(request.isDurable())
- .setTemporary(request.isTemporary()));
- } catch (Exception e) {
- ActiveMQServerLogger.LOGGER.failedToHandleCreateQueue(e);
- }
- }
}
\ No newline at end of file
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@artemis.apache.org
For additional commands, e-mail: commits-help@artemis.apache.org