Skip to content

Commit a017ca0

Browse files
committed
fix(client): simplify MessageProducer send calls by removing redundant destination parameter
calling send(destination, message) on fixed-destination producers — a JMS spec violation that the old code silently allowed
1 parent 5ebc21a commit a017ca0

File tree

5 files changed

+6
-6
lines changed

5 files changed

+6
-6
lines changed

activemq-broker/src/test/java/org/apache/activemq/bugs/AMQ7085Test.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -62,7 +62,7 @@ public void setUp() throws Exception {
6262
final Message toSend = session.createMessage();
6363
toSend.setStringProperty("foo", "bar");
6464
final MessageProducer producer = session.createProducer(queue);
65-
producer.send(queue, toSend);
65+
producer.send(toSend);
6666
} finally {
6767
conn.close();
6868
}

activemq-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ4361Test.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -113,7 +113,7 @@ public void run() {
113113
lastLoop.set(System.currentTimeMillis());
114114
ObjectMessage objMsg = session.createObjectMessage();
115115
objMsg.setObject(data);
116-
producer.send(destination, objMsg);
116+
producer.send(objMsg);
117117
}
118118
} catch (Exception e) {
119119
publishException.set(e);

activemq-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ6059Test.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -173,7 +173,7 @@ private void sendMessage(Destination destination) throws Exception {
173173
connection.start();
174174
Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
175175
MessageProducer producer = session.createProducer(destination);
176-
producer.send(destination, session.createTextMessage("DLQ message"), DeliveryMode.PERSISTENT, 4, 1000);
176+
producer.send(session.createTextMessage("DLQ message"), DeliveryMode.PERSISTENT, 4, 1000);
177177
connection.stop();
178178
LOG.info("### Send message that will expire.");
179179
}

activemq-unit-tests/src/test/java/org/apache/activemq/bugs/MemoryUsageBlockResumeTest.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -112,7 +112,7 @@ public void run() {
112112
producer.setDeliveryMode(deliveryMode);
113113
for (int idx = 0; idx < toSend; ++idx) {
114114
Message message = session.createTextMessage(new String(buf) + idx);
115-
producer.send(destination, message);
115+
producer.send(message);
116116
messagesSent.incrementAndGet();
117117
LOG.info("After little:" + idx + ", System Memory Usage " + broker.getSystemUsage().getMemoryUsage().getPercentUsage());
118118
}
@@ -132,7 +132,7 @@ public void run() {
132132
producer.setDeliveryMode(deliveryMode);
133133
for (int idx = 0; idx < toSend; ++idx) {
134134
Message message = session.createTextMessage(new String(buf) + idx);
135-
producer.send(destination, message);
135+
producer.send(message);
136136
messagesSent.incrementAndGet();
137137
LOG.info("After little:" + idx + ", System Memory Usage " + broker.getSystemUsage().getMemoryUsage().getPercentUsage());
138138
}

activemq-unit-tests/src/test/java/org/apache/activemq/transport/failover/InitalReconnectDelayTest.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -129,7 +129,7 @@ public void transportResumed() {
129129

130130
LOG.info("Attempting to send... failover should throw on disconnect");
131131
try {
132-
producer.send(destination, message);
132+
producer.send(message);
133133
fail("Expect IOException to bubble up on send");
134134
} catch (jakarta.jms.IllegalStateException producerClosed) {
135135
}

0 commit comments

Comments
 (0)