Skip to content

Commit 73cf36c

Browse files
committed
* Improve AmqpClientMessageProducer.processRequest Javadoc
mentioning that `requestMessage` param is out of use * Be more specific with the type for `UnsupportedOperationException` in the `IntegrationRabbitAmqpMessageListener`
1 parent c05adbb commit 73cf36c

File tree

2 files changed

+3
-2
lines changed

2 files changed

+3
-2
lines changed

spring-integration-amqp/src/main/java/org/springframework/integration/amqp/inbound/AmqpClientMessageProducer.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -182,7 +182,7 @@ public boolean isPaused() {
182182
/**
183183
* Use as {@link java.util.function.BiConsumer} for the {@link IntegrationRabbitAmqpMessageListener}.
184184
* @param messageToSend the message to produce from this endpoint.
185-
* @param requestMessage the request AMQP message.
185+
* @param requestMessage the request AMQP message. Ignored in this implementation.
186186
*/
187187
private void processRequest(Message<?> messageToSend,
188188
org.springframework.amqp.core.@Nullable Message requestMessage) {

spring-integration-amqp/src/main/java/org/springframework/integration/amqp/inbound/IntegrationRabbitAmqpMessageListener.java

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -129,7 +129,8 @@ private Message<?> toSpringMessage(org.springframework.amqp.core.Message message
129129

130130
@Override
131131
public void onMessage(org.springframework.amqp.core.Message message) {
132-
throw new UnsupportedOperationException("The 'RabbitAmqpMessageListener' does not implement 'onMessage()'");
132+
throw new UnsupportedOperationException(
133+
"The 'IntegrationRabbitAmqpMessageListener' does not implement 'onMessage()'");
133134
}
134135

135136
/**

0 commit comments

Comments
 (0)