@JmsListener不会异步接收消息

问题描述

我是Solace pubsub +经纪人的新手。

我尝试使用主题发送消息，并使用springboot消息监听器接收消息

@JmsListener(destination = "HelloWorld")
public void handle(Message message)
{
    try
    {
        Date receiveTime = new Date();

        if (message instanceof TextMessage)
        {
            TextMessage tm = (TextMessage) message;
            try
            {
                System.out.println("Message Received at " + new SimpleDateFormat("yyyy-MM-dd HH:mm:ss.SSS").format(receiveTime)
                                + " with message content of: " + tm.getText());
                
                for(long index =0; index <10000000000L; index++)
                {
                    
                }
                
                System.out.println("..done....");
            } 
            catch (Exception e)
            {
                e.printstacktrace();
            }
        } 
        else
        {
            System.out.println(message.toString());
        }
    } catch (Exception e)
    {
        // Todo Auto-generated catch block
        e.printstacktrace();
    }
}

发布者每秒持续发送一次消息，但是消费者接收到该消息并对其进行处理，然后接收下一条消息。我希望接收者在发布者推送消息后立即收到消息。

我通过Jms1协议将solace broker与amqp连接，并使用了org.amqphub.spring maven依赖项。

我需要配置其他任何内容以异步接收消息吗？

解决方法

暂无找到可以解决该程序问题的有效方法，小编努力寻找整理中！

如果你已经找到好的解决方法，欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com (将#修改为@）