Where communities thrive


  • Join over 1.5M+ people
  • Join over 100K+ communities
  • Free without limits
  • Create your own community
People
Repo info
Activity
    Alexey Anufriev
    @alexey-anufriev

    I have an excepion being thrown from the post-processor, and I would like to have error handler for this case. I can use org.springframework.util.ErrorHandlerfor container, but in fact I would also like to have access to the message itself.

    RabbitListenerErrorHandler will not help in this case as exception happens earlier, before the listener.

    In the ConditionalRejectingErrorHandler I saw this check t instanceof ListenerExecutionFailedException but in my case it is original exception.

    What are the other options?

    2 replies
    Gowtham Babu Tummala
    @gowthamt4
    Hi! Is there any way to autowire the beans in the Listener extending from MessageListener ? I need to perform some business logic inside onMessage(Message message). But I am unable to access Autowire beans inside onMessage method
    20 replies
    maglioneangelo
    @maglioneangelo

    Hello,
    Is there any way to try to create a channel with another Node of a RMQ Cluster in case of some Exception like this one?

    '''
    Caused by: com.rabbitmq.client.ChannelContinuationTimeoutException: Continuation call for method #method<channel.open>(out-of-band=) on channel AMQChannel(amq
    p://sqfo-apps-fix-engine-six@{HOST1}/tradingsystems,655) (#655) timed out
    at com.rabbitmq.client.impl.AMQChannel.wrapTimeoutException(AMQChannel.java:313)
    at com.rabbitmq.client.impl.AMQChannel.privateRpc(AMQChannel.java:295)
    at com.rabbitmq.client.impl.AMQChannel.exnWrappingRpc(AMQChannel.java:141)
    at com.rabbitmq.client.impl.ChannelN.open(ChannelN.java:128)
    at com.rabbitmq.client.impl.ChannelManager.createChannel(ChannelManager.java:182)
    at com.rabbitmq.client.impl.AMQConnection.createChannel(AMQConnection.java:618)
    at org.springframework.amqp.rabbit.connection.SimpleConnection.createChannel(SimpleConnection.java:58)
    ... 32 more
    Caused by: java.util.concurrent.TimeoutException
    at com.rabbitmq.utility.BlockingCell.get(BlockingCell.java:77)
    at com.rabbitmq.utility.BlockingCell.uninterruptibleGet(BlockingCell.java:120)
    at com.rabbitmq.utility.BlockingValueOrException.uninterruptibleGetValue(BlockingValueOrException.java:36)
    at com.rabbitmq.client.impl.AMQChannel$BlockingRpcContinuation.getReply(AMQChannel.java:502)
    at com.rabbitmq.client.impl.AMQChannel.privateRpc(AMQChannel.java:293)
    '''

    It seems that the application try to create a channel always with the same node, instead to switch on some other node.

    forgetaboutme
    @forgetaboutme
    Hi, if I use RabbitAutoConfiguration with a POJO listener (that has a @RabbitListener annotation on function receiveMessage, with an id), how can I access the container that is running the message listener? I would like to intercept an application event (spring boot) in order to stop my container but it seems I cannot get a hold of this container. I tried using the RabbitListenerEndpointRegistry but no success.. even if I define it as a bean, there are no containers attached to it. It seems like the @RabbitListener is not being registered in the RabbitListenerEndpointRegistry that I manually create (bean).
    forgetaboutme
    @forgetaboutme
    I am also using the RabbitAutoConfiguration bean
    3 replies
    Patrik Mihalcin
    @pmihalcin
    Hi all.. is there some easy way how to implement browse feature in AMQP similar to jmsTemplate.browse(...)?
    My goal is to look at messages in given queue and I want to assert those messages if they match some criteria
    84 replies
    Jan Mareš
    @maresja1
    Hello, since upgrading to spring boot 2.4.0 (now on spring boot 2.4.1 amqp 2.3.4, this issue persists), I started having issues with messages not processed. At some random point, it seems the BlockingQueueConsumer only stores the message (manifested by Storing delivery for consumerTag in the logs), but no one picks up the messages from the queue (absence of Received message: in the logs). This leads to lots of unacked messages in RabbitMQ, after which RabbitMQ stops sending messages completely. It happens after hours or days of uptime, randomly. The logs at the time, when this happens do not show anything helpful (regarding some exceptional state). RabbitMQ connection is healthy, therefore the service needs force restart. Everything was work fine on Spring Boot 2.3.x. Any help would be hugely appreciated.
    3 replies
    Priyanshu Shukla
    @priyanshus1
    Hi Community,
    We are using RabbitTemplate.convertSendAndReceiveAsType (Request Response Pattern). We are sometimes noticing in our logs that basicPublish event does not start for around 1 min and thread just sleep for that time.
    We did the investigation but cannot find out a reason so after calling the function it should publish immediately right ? or am I missing something.
    This happens atleast 4-5 times a per day for unique requests.
    Any suggestion for our investigation will be helpful.
    Thanks
    5 replies
    Priyanshu Shukla
    @priyanshus1
    Hi Community,
    In case of RPC mechanism when connection times out does direct-reply to threads(channel) which are waiting for a response also times out ?
    1 reply
    Florian Ruschbaschan
    @floruschbaschan
    Hey all, since we upgraded to SpringBoot 2.3.x and JUnit5, we evaluated @RabbitAvailable for our integration test purposes (RabbitMQ is running as an own docker container). Here we noticed that according to the class comment the check is only implemented for local running brokers ("Test classes annotated with this will not run if there is no broker on localhost.")
    Additionally we saw that BrokerRunningSupport supports overrides by the System Environment. We would rather like to pass our RabbitMQ credentials as runtime arguments. Is there a specific reason why the SystemProperties are not used instead? Any support on this would be much appreciated.
    2 replies
    Aleh
    @AlehGalo
    Hello to everyone. Could you please help me with Spring-ampq + RabbitMQ + spring-boot
    I’m creting Queues/Exchanges/Bindings with the help of spring.
    Queues and exchanges are created successfully but bindings are absent. As a result no messages are transfered to the queue.
    Aleh
    @AlehGalo
    Screenshot 2021-03-03 at 11.25.56.png
    Aleh
    @AlehGalo
    Sorry, my bad

    I was doing

    @Bean
    public Binding bbbBinding() {
    return BindingBuilder.bind(bbbQueue())
    .to(requestExchange())
    .with("*");
    }

    but AMPQ 2.2.6 is changed
    @Bean
    public Binding bbbBinding() {
    return BindingBuilder.bind(bbbQueue())
    .to(requestExchange())
    .with("*”).noargs();
    }
    additional .noargs()
    Gary Russell
    @garyrussell
    Please learn how to use markdown - click the M icon on the right. Add three back ticks on a separate line before and after code snippets.
    It is not clear why you would see such behavior. DEBUG logging will show declaration activity.
    willladislaw
    @willladislaw
    This message was deleted
    1 reply
    Amruta Wandakar
    @amrutawandakar
    Hi all, Hopefully i'm asking my query in right forum. I'm trying to use HttpSession in @RabbitListener(it's receiver project) i'm gteting some eeror while setting up session. error message is
    No thread-bound request found: Are you referring to request attributes outside of an actual web request, or processing a request outside of the originally receiving thread? If you are actually operating within a web request and still receive this message, your code is probably running outside of DispatcherServlet/DispatcherPortlet: In this case, use RequestContextListener or RequestContextFilter to expose the current request.
    can anyone help me out please
    1 reply
    Mohit Darmwal
    @mickmohit
    Hello Team , i facing issues with RabbitListenerTestHarness, it is not working
    Hello Team , i facing issues with RabbitListenerTestHarness, it is not working. Below is my project structure

    Main class

    @Component
    public class ABC {

    @Autowired
    private AmqpTemplate amqpTemplate;

    @RabbitListener(id="id", queues="${queue}")
    public void receiveMessage(String message) {
    publishMsg(message);
    }

    public void publishMsg(String msg){
    amqpTemplate.convertAndSend("exchange", "",msg);
    }

    }
    test class

    @RunWith(SpringRunner.class)
    @SpringBootTest
    public class ABCTest {

    @Autowired
    private RabbitListenerTestHarness harness;

    @Autowired
    private RabbitTemplate rabbitTemplate;
    @Test
    public void testSendtoQueue() throws Exception {
    ABC listener = this.harness.getSpy("id");
    assertNotNull(listener);

    LatchCountDownAndCallRealMethodAnswer answer = this.harness.getLatchAnswerFor("id", 1);
    doAnswer(answer).when(listener).receiveMessage(any(String.class));

    String data = getMockString("src/test/resources/rabbitMQ-data.json");

    this.rabbitTemplate.convertAndSend("Queue-name", data);

    //assertTrue(answer.await(10));
    verify(listener,times(1)).receiveMessage("data");
    }
    }

    and on running above it gives me error as below

    Wanted but not invoked:
    customPublisherSubscriber.receiveMessageFromResponseQ(
    "data"
    );
    -> at aero.sita.sp.spm.service.ABC.testSendtoQueue(CustomPublisherSubscriberTest.java:67)
    Actually, there were zero interactions with this mock.

    at aero.sita.sp.spm.service.ABC.testSendtoQueue(CustomPublisherSubscriberTest.java:67)
    at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
    at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
    at java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
    at java.base/java.lang.reflect.Method.invoke(Method.java:566)
    i was referring to https://github.com/spring-projects/spring-amqp/blob/master/src/reference/asciidoc/testing.adoc.

    I am struggling to understand as i am trying to verify spy object for message received or not, but it is reporting issues related to mock object. Could you please assist me on this.
    Gary Russell
    @garyrussell

    Please learn how to use Gitter markdown (click the M on the right). You need to surround your code with three back-ticks (fences) on separate lines before and after the code).

    What is

    customPublisherSubscriber.receiveMessageFromResponseQ(

    ? I don't see that either in your code or the test.

    Gary Russell
    @garyrussell
    Stack overflow is generally a better venue for questions like this because it's easier to show code, configuration, and logs.
    Mohit Darmwal
    @mickmohit
    @garyrussell i have asked the same over stackoverflow https://stackoverflow.com/questions/66986114/issues-with-rabbitlistenertestharness-it-is-not-working , could you please help me on this
    Priyanshu Shukla
    @priyanshus1
    Hi Community,
    Do we know if Direct-Reply To for RPC is better performant than Fixed Reply Queues ?
    1 reply
    Priyanshu Shukla
    @priyanshus1
    @garyrussell I have set useDirectReplyToContainer to false and set a reply address on rabbitTemplate with a fixed queue created before hand. I wish to control the concurrency for consumers. Do you think this idea works or still consumers will be created per request.
    4 replies
    Priyanshu Shukla
    @priyanshus1
    Hi Community,
    As mentioned in the docs that one can set correlationKey in the rabbit template in order to use custom correlation header.
    But I could not find any information on how to set this custom correlation header information on listener side (on server), server does not seem to reply with correlation header.
    Did I miss something ?
    https://docs.spring.io/spring-amqp/reference/html/#message-correlation-with-a-reply-queue
    2 replies
    Steve Kingsland
    @skingsland

    I have a multi-threaded Spring Boot batch job which appears to be writing messages out-of-order to a RabbitMQ queue, even though the calling code is sequential. E.g. the job's main thread writes message1, before spawning a second thread that writes message2. Anyway, I'm trying to understand the options for guaranteeing that messages are written in order:

    1) setChannelTransacted(true) - doesn't help guarantee order?

    2) use scoped operations - the code for writing messages is spread out across the steps of my batch job so it's hard to find a good transaction boundary, for a single invoke() call;

    3) use ThreadChannelConnectionFactory - only helps guarantee order within a single thread, not across multiple threads;

    4) is there some way I can force the RabbitTemplate (which is shared across threads) to use a single channel/connection for every message it writes, even if it's much slower?

    36 replies
    Dmitrii Bocharov
    @bdshadow
    Hi all!
    Could you, please, help with code formatting for spring-amqp? I use Intellij Idea. I tried to import eclipse-code-formatter.xml but when i format the code, there is still a checkstyle error. The default formatting of IDEA also doesn't work properly. I haven't found anything else here: https://github.com/spring-projects/spring-amqp/blob/main/CONTRIBUTING.adoc (yes i saw some rules there, but wouldn't like to set it manually)
    Are there prepared and working code-formatter rules, which i can just import to IDE?
    5 replies
    Sergio Maziano
    @smaziano
    Hello all...
    Sergio Maziano
    @smaziano

    I need help. Could any of you please help me understand what's going on here:
    This is what I get...

     May 08 21:35:44Z srv01 app_name INFO  o.s.a.r.c.CachingConnectionFactory: Attempting to connect to: [127.0.0.1:5672]
    May 08 21:35:44Z srv01 app_name INFO  o.s.a.r.l.SimpleMessageListenerContainer: Restarting Consumer@f05ac43: tags=[[]], channel=null, acknowledgeMode=MANUAL local queue size=0
    May 08 21:35:44Z srv01 app_name WARN  c.r.c.i.ForgivingExceptionHandler: An unexpected connection driver error occured (Exception message: Socket closed)
    May 08 21:35:49Z srv01 app_name WARN  c.r.c.i.ForgivingExceptionHandler: An unexpected connection driver error occured (Exception message: Socket closed)
    May 08 21:35:49Z srv01 app_name INFO  o.s.a.r.c.CachingConnectionFactory: Attempting to connect to: [127.0.0.1:5672]
    May 08 21:35:55Z srv01 app_name INFO  o.s.a.r.l.SimpleMessageListenerContainer: Restarting Consumer@48b7af3f: tags=[[]], channel=null, acknowledgeMode=AUTO local queue size=0
    May 08 21:35:55Z srv01 app_name ERROR o.s.a.r.l.SimpleMessageListenerContainer: Failed to check/redeclare auto-delete queue(s).#012org.springframework.amqp.AmqpTimeoutException: java.util.concurrent.TimeoutException#012#011at org.springframework.amqp.rabbit.support.RabbitExceptionTranslator.convertRabbitAccessException(RabbitExceptionTranslator.java:73)#012#011at org.springframework.amqp.rabbit.connection.AbstractConnectionFactory.createBareConnection(AbstractConnectionFactory.java:524)#012#011at org.springframework.amqp.rabbit.connection.CachingConnectionFactory.createConnection(CachingConnectionFactory.java:751)#012#011at org.springframework.amqp.rabbit.connection.ConnectionFactoryUtils.createConnection(ConnectionFactoryUtils.java:214)#012#011at org.springframework.amqp.rabbit.core.RabbitTemplate.doExecute(RabbitTemplate.java:2089)#012#011at org.springframework.amqp.rabbit.core.RabbitTemplate.execute(RabbitTemplate.java:2062)#012#011at org.springframework.amqp.rabbit.core.RabbitTemplate.execute(RabbitTemplate.java:2042)#012#011at org.spring...

    but then... It connects

     May 08 21:35:55Z srv01 app_name INFO  o.s.a.r.c.CachingConnectionFactory: Attempting to connect to: [127.0.0.1:5672]
    May 08 21:35:55Z srv01 app_name WARN  c.r.c.i.ForgivingExceptionHandler: An unexpected connection driver error occured (Exception message: Socket closed)
    May 08 21:36:00Z srv01 app_name INFO  o.s.a.r.c.CachingConnectionFactory: Created new connection: rabbitConnectionFactory#5a08b084:187/SimpleConnection@171a3a0c [delegate=amqp://user@127.0.0.1:5672/, localPort= 59784]
    May 08 21:53:35Z srv02 app_name INFO  o.a.c.c.C.[Tomcat].[localhost].[/]: Initializing Spring DispatcherServlet 'dispatcherServlet'
    May 08 21:53:36Z srv02 app_name INFO  o.s.web.servlet.DispatcherServlet: Initializing Servlet 'dispatcherServlet'
    May 08 21:53:36Z srv02 app_name INFO  o.s.web.servlet.DispatcherServlet: Completed initialization in 24 ms
    1 reply
    Mohamed A
    @blueoceandevops
    hi All I am looking for ActiveMQ Message grouping "JMSXGroupID" feature in RabbitMQ... any possible to use "JMSXGroupID" with RabbitMQ?
    1 reply
    Patrik Mihalcin
    @pmihalcin
    Hi all
    I'm planning to use priority queue: https://www.rabbitmq.com/priority.html
    On the consumer side, is there anything, any special settings I need to take into account with regards to Amqp.inboundAdapter I use in my spring integration flow?
    I can't find correlation between Amqp.inboundAdapter and consumer priorities: https://www.rabbitmq.com/consumer-priority.html
    23 replies
    notfab
    @notfab:matrix.org
    [m]
    Ha! looks like I was missing setting the queues on the endpoint... it's always the simple things...
    Bishoy Awad
    @bhawad
    Hello All :)
    I have a rabbitmq deployed and working, having a fanout exchanhge and a single queue. I have a spring service conected to this queue, and this service can horizontally autoscale, but when it does, the newly started instance doesn't get any messages from this queue, and the first instance stays the one that gets all messages from this queue. Am I missing something to make it work?
    5 replies
    Freya Arbjerg
    @freyacodes
    I'm getting a very serious channel leak with CachingConnectionFactory in Spring Rabbit 2.3.7. I think the channel count suddenly spikes. I believe the channels are caused by RPC
    Does this sound like a known bug? I wasn't able to find anything that looked relevant in the issue handler
    I'm now trying to update my backend and crossing fingers that it doesn't suddenly die again in a few hours
    Freya Arbjerg
    @freyacodes
    Had a negotiated limit of 50000
    Freya Arbjerg
    @freyacodes
    It looks like CachingConnectionFactory defaults to creating as many channels as possible as long as the demand is great enough and there isn't a cache size limit. So I've set a limit now
    1 reply
    padmajadav
    @padmajadav

    Hey Team,

    I am trying to write integration testcase using testContainer for RabbitMQ using RabbitMQContainer for rabbittemplate.convertAndSend. Everything works fine for a consumer application where connection has been established at app startup. But for a producer app, where connection gets established when convertAndSend mehtod call - .I am facing connection refused error.

    '@SpringBootTest(properties = "spring.main.allow-bean-definition-overriding=true", webEnvironment = SpringBootTest.WebEnvironment.RANDOM_PORT)
    @ActiveProfiles(profiles = "test")
    @ContextConfiguration(initializers = {EventIT.Initializer.class})
    @Testcontainers
    public class EventIT {

    @Container
    private static final RabbitMQContainer rabbit = new RabbitMQContainer("rabbitmq:3-management")
            .withExposedPorts(5672, 15672).waitingFor(Wait.forLogMessage(".*Server startup complete.*",1));
    
    @Autowired
    private RabbitTemplate rabbitTemplate;
    
    @DisplayName("MessagePost")
    @Test
    public void testProduceMessage() {
        Assertions.assertTrue(rabbit.isRunning());
        rabbitTemplate.convertAndSend("New message");
    }
    
    
    public static class Initializer implements
            ApplicationContextInitializer<ConfigurableApplicationContext> {
        @Override
        public void initialize(ConfigurableApplicationContext configurableApplicationContext) {
            System.out.println("Initialize Padma");
            TestPropertyValues.of(
                    "spring.rabbitmq.host=" + rabbit.getContainerIpAddress(),
                    "spring.rabbitmq.port=" + rabbit.getMappedPort(5672)
            ).applyTo(configurableApplicationContext);
        }
    }

    }'

    10 replies
    cho-kwan-ho
    @cho-kwan-ho

    Hi spring-amqp team,

    I am using @RabbitListener to create a consumer but I don't want to force the queue to already exist. When the app starts, if the queue doesn't exist a com.rabbitmq.client.ShutdownSignalException is thrown with the following error message:

    channel error; protocol method: #method<channel.close>(reply-code=404, reply-text=NOT_FOUND - no queue 'some-queue' in vhost '/', class-id=50, method-id=10)

    I know one simple solution is to make sure the queue already exists, another is to create the queue in the config using @Bean, but I don't want either solution because I don't want the queue to exist in some situations. So all I want is to be able to catch whatever exception is thrown by @RabbitListener and just ignore it, how can I accomplish this please?

    Thank you very much in advance for your insight and help!

    42 replies
    John Hendrikx
    @hjohn
    I'm listening on a headers exchange and want to listen for message where a certain header is present. The documentation for Argument states: "The argument value, an empty string is translated to {@code null} for example to represent a present header test for a headers exchange", however AMQP documentation states "A message is considered matching if the value of the header equals the value specified upon binding". So, I'm wondering, which one is correct here? I already noticed that the mocking framework I use (rabbit-mock fridujo) seems to require a value to match.
    I'm going to test this with a real RabbitMQ next to see what its behavior is.
    John Hendrikx
    @hjohn
    A simple RabbitMQ test via the management interface where I use a binding with a string header with an empty value only matches if the message routed also has an empty value. I don't see a way to put null in the binding, although perhaps programmatically it is possible.
    2 replies
    Lukáš Vasek
    @bilak

    Hello, I'm having a trouble using selector. I'm using JMS with azure's service bus. This is what I did

    @Component
    @Slf4j
    public class MessageTestRunner implements CommandLineRunner {
    
        private static final String QUEUE_NAME = "lva-test-queue";
        private static final String PING_SELECTOR = "selector = 'PING'";
        private static final String PONG_SELECTOR = "selector = 'PONG'";
    
        private static final String SB_SCHEDULED_ENQUEUE_HEADER = "x-opt-scheduled-enqueue-time";
    
    
        private final JmsTemplate jmsTemplate;
    
        public MessageTestRunner(JmsTemplate jmsTemplate) {
            this.jmsTemplate = jmsTemplate;
        }
    
        @Override
        public void run(String... args) throws Exception {
            jmsTemplate.convertAndSend(QUEUE_NAME, ping(), m -> {
                m.setStringProperty("selector", "PING");
                return m;
            });
            jmsTemplate.convertAndSend(QUEUE_NAME, pong(), m -> {
                m.setStringProperty("selector", "PONG");
                return m;
            });
        }
    
        private PingMessage ping() {
            final PingMessage msg = new PingMessage();
            msg.setAt(ZonedDateTime.now());
            return msg;
        }
    
        private PongMessage pong() {
            final PongMessage msg = new PongMessage();
            msg.setAt(ZonedDateTime.now());
            return msg;
        }
    
    
        @JmsListener(destination = QUEUE_NAME, selector = PING_SELECTOR, containerFactory = JMS_FACTORY_NAME)
        public void handle(PingMessage message) {
            log.debug("Handling ping message [{}]", message);
        }
    
        @JmsListener(destination = QUEUE_NAME, selector = PONG_SELECTOR, containerFactory = JMS_FACTORY_NAME)
        public void handle(PongMessage message) {
            log.debug("Handling pong message [{}]", message);
        }
    
    }

    however when I run this code I'm getting converting exception

    org.springframework.jms.listener.adapter.ListenerExecutionFailedException: Listener method could not be invoked with incoming message
    Endpoint handler details:
    Method [public void com.example.MessageTestRunner.handle(com.example.data.model.PingMessage)]
    Bean [com.example.MessageTestRunner@7aae1170]
    ; nested exception is org.springframework.messaging.converter.MessageConversionException: Cannot convert from [com.example.data.model.PongMessage] to [com.example.data.model.PingMessage] for org.springframework.jms.listener.adapter.AbstractAdaptableMessageListener$MessagingMessageConverterAdapter$LazyResolutionMessage@72eb85b7, failedMessage=org.springframework.jms.listener.adapter.AbstractAdaptableMessageListener$MessagingMessageConverterAdapter$LazyResolutionMessage@72eb85b7
        at org.springframework.jms.listener.adapter.MessagingMessageListenerAdapter.invokeHandler(MessagingMessageListenerAdapter.java:118) ~[spring-jms-5.3.10.jar:5.3.10]
        at org.springframework.jms.listener.adapter.MessagingMessageListenerAdapter.onMessage(MessagingMessageListenerAdapter.java:77) ~[spring-jms-5.3.10.jar:5.3.10]
        at org.springframework.jms.listener.AbstractMessageListenerContainer.doInvokeListener(AbstractMessageListenerContainer.java:736) ~[spring-jms-5.3.10.jar:5.3.10]
        at org.springframework.jms.listener.AbstractMessageListenerContainer.invokeListener(AbstractMessageListenerContainer.java:696) ~[spring-jms-5.3.10.jar:5.3.10]
        at org.springframework.jms.listener.AbstractMessageListenerContainer.doExecuteListener(AbstractMessageListenerContainer.java:674) ~[spring-jms-5.3.10.jar:5.3.10]
        at org.springframework.jms.listener.AbstractPollingMessageListenerContainer.doReceiveAndExecute(AbstractPollingMessageListenerContainer.java:318) ~[spring-jms-5.3.10.jar:5.3.10]
        at org.springframework.jms.listener.AbstractPollingMessageListenerContainer.receiveAndExecute(AbstractPollingMessageListenerContainer.java:257) ~[spring-jms-5.3.10.jar:5.3.10]
        at org.springframework.jms.listener.DefaultMessageListenerContainer$AsyncMessageListenerInvoker.invokeListener(DefaultMessageListenerContainer.java:1237) ~[spring-jms-5.3.10.jar:5.3.10]
        at org.springframework.jms.listener.DefaultMessageListenerContainer$AsyncMessageListenerInvoker.executeOngoingLoop(DefaultMessageListenerC
    10 replies