From c2da8467320660a98897e5f3a2b7cf1c637146b3 Mon Sep 17 00:00:00 2001 From: Stephane Nicoll Date: Fri, 4 Jul 2014 14:07:50 +0200 Subject: [PATCH] Add support for extra MessageProducer method This commit supports two additional methods of the MessageProducer interface as from JMS 2.0 An integration test infrastructure is necessary to be able to test those scenario: this is taken care of in a separated initiative. Issue: SPR-11950 --- .../jms/connection/CachedMessageProducer.java | 6 ++++++ 1 file changed, 6 insertions(+) diff --git a/spring-jms/src/main/java/org/springframework/jms/connection/CachedMessageProducer.java b/spring-jms/src/main/java/org/springframework/jms/connection/CachedMessageProducer.java index 63ebe12621..c7f14a5ab5 100644 --- a/spring-jms/src/main/java/org/springframework/jms/connection/CachedMessageProducer.java +++ b/spring-jms/src/main/java/org/springframework/jms/connection/CachedMessageProducer.java @@ -282,6 +282,12 @@ class CachedMessageProducer implements MessageProducer, QueueSender, TopicPublis else if (args.length == 3) { return sendWithDestinationAndCompletionListenerMethod.invoke( target, args[0], args[1], deliveryMode, priority, timeToLive, args[2]); + } else if (args.length == 5) { + return sendWithCompletionListenerMethod.invoke( + target, args[0], args[1], args[2], args[3], args[4]); + } else if (args.length == 6) { + return sendWithDestinationAndCompletionListenerMethod.invoke( + target, args[0], args[1], args[2], args[3], args[4], args[5]); } } return method.invoke(CachedMessageProducer.this, args);