This is an automated email from the ASF dual-hosted git repository.
cshannon pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/activemq.git
The following commit(s) were added to refs/heads/main by this push:
new 5501c62d4d AMQ-9722 Removed 2 method calls with unused return value
(#1448)
5501c62d4d is described below
commit 5501c62d4d636ffbb9b9dc9b430838172ee33fe2
Author: Dmitry Kryukov <[email protected]>
AuthorDate: Wed Jun 4 16:02:57 2025 +0300
AMQ-9722 Removed 2 method calls with unused return value (#1448)
---
.../src/main/java/org/apache/activemq/broker/region/TopicRegion.java | 1 -
.../main/java/org/apache/activemq/transport/udp/UdpTransportServer.java | 1 -
2 files changed, 2 deletions(-)
diff --git
a/activemq-broker/src/main/java/org/apache/activemq/broker/region/TopicRegion.java
b/activemq-broker/src/main/java/org/apache/activemq/broker/region/TopicRegion.java
index 68b01f4e07..7ec37f4f7e 100644
---
a/activemq-broker/src/main/java/org/apache/activemq/broker/region/TopicRegion.java
+++
b/activemq-broker/src/main/java/org/apache/activemq/broker/region/TopicRegion.java
@@ -289,7 +289,6 @@ public class TopicRegion extends AbstractRegion {
// Now perhaps there other durable subscriptions (via wild card)
// that would match this destination..
- durableSubscriptions.values();
for (DurableTopicSubscription sub : durableSubscriptions.values())
{
// Skip over subscriptions that we already added..
if (dupChecker.contains(sub)) {
diff --git
a/activemq-client/src/main/java/org/apache/activemq/transport/udp/UdpTransportServer.java
b/activemq-client/src/main/java/org/apache/activemq/transport/udp/UdpTransportServer.java
index 2e7163969d..21836040d0 100644
---
a/activemq-client/src/main/java/org/apache/activemq/transport/udp/UdpTransportServer.java
+++
b/activemq-client/src/main/java/org/apache/activemq/transport/udp/UdpTransportServer.java
@@ -154,7 +154,6 @@ public class UdpTransportServer extends
TransportServerSupport {
final UdpTransport transport = new UdpTransport(connectionWireFormat,
address);
final ReliableTransport reliableTransport = new
ReliableTransport(transport, transport);
- reliableTransport.getReplayer();
reliableTransport.setReplayStrategy(replayStrategy);
// Joiner must be on outside as the inbound messages must be processed
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
For further information, visit: https://activemq.apache.org/contact
