带有队列的spring jms请求响应答案

【问题标题】：spring jms request response with a queue带有队列的spring jms请求响应
【发布时间】：2011-10-20 12:39:32
【问题描述】：

我有一个简单的 spring jms 教程。贷方充当接收者。借款人是作为发送者的行为。借款人发送工资和贷款金额，并等待响应。贷方做出决定并发回“接受”或“拒绝”。

在借款人方面，我正在执行以下操作。

Message sentMessage = (Message)jmsTemplate.execute(new MyProducerCallBack(messageMap, "lenderResponseQueue"));

String filter = "JMSCorrelationID = '" + sentMessage.getJMSMessageID() + "'";
TextMessage tmsg = (TextMessage) jmsTemplate.receiveSelected("lenderResponseQueue", filter);

这是 MyProducerCallBack 中的代码

public Object doInJms(Session session, MessageProducer producer) throws JMSException {
    System.out.println("inside doInJms");

    //create queue to receive accept or decline from lender
    Queue queue = session.createQueue(lenderResponseQueue);

    MapMessage jmsMapMsg = session.createMapMessage();
    populateJMSMapMsg(jmsMapMsg, mapMessage);
    jmsMapMsg.setJMSReplyTo(queue);

    //send salary and loan amount to lender
    producer.send(jmsMapMsg);

    //get the accept or decline from lender
    Message msg = session.createConsumer(queue).receive();

    if(msg instanceof TextMessage){
        System.out.println(((TextMessage)msg).getText());
    }

    return msg;
}

当 Message msg = session.createConsumer(queue).receive();遇到日志抛出如下异常

2011-10-19 20:21:03,458 WARN [org.apache.activemq.ActiveMQSessionExecutor] - Received a message on a connection which is not yet started. 
Have you forgotten to call Connection.start()? Connection: ActiveMQConnection {id=ID:Reverb0253-PC-54217-1319070060323-0:1,clientId=ID:Reverb0253-PC-54217-1319070060323-1:1,started=false} 
Received: MessageDispatch {commandId = 0, responseRequired = false, consumerId = ID:Reverb0253-PC-54217-1319070060323-0:1:1:1, destination = queue://lenderResponseQueue, message = 
ActiveMQTextMessage {commandId = 7, responseRequired = true, messageId = ID:Reverb0253-PC-52978-1319058441747-0:1:1:1:1, originalDestination = null, originalTransactionId = null, producerId = ID:Reverb0253-PC-52978-1319058441747-0:1:1:1, destination = queue://lenderResponseQueue, transactionId = null, expiration = 0, timestamp = 1319058485680, arrival = 0, brokerInTime = 1319058485706, brokerOutTime = 1319070063443, correlationId = ID:Reverb0253-PC-53001-1319058485443-0:1:1:1:1, replyTo = null, persistent = true, type = null, priority = 4, groupID = null, groupSequence = 0, targetConsumerId = null, compressed = false, userID = null, content = null, marshalledProperties = null, dataStructure = null, redeliveryCounter = 5, size = 0, properties = null, readOnlyProperties = true, readOnlyBody = true, droppable = false, text = Accepted!}, redeliveryCounter = 5}

接收队列是 lenderResponseQueue 在 spring 配置文件中不存在。我需要在那里指定吗？这是我的配置文件中的 jmsTemplate

<bean id="jmsTemplate" class="org.springframework.jms.core.JmsTemplate">
    <property name="connectionFactory" ref="queueConnectionFactory"/>
    <property name="destinationResolver" ref="destinationResolver"/>
    <!-- name of destination -->
    <property name="defaultDestinationName" value="lenderRequestQueue"/>
    <!-- amount of time to wait before getting a message -->
    <property name="receiveTimeout" value="0"/>
    <!-- indicate weather queue or topic is used. false = queue or p2p -->
    <property name="pubSubDomain" value="false"/>
</bean>

【问题讨论】：

标签： spring jms

【解决方案1】：

有没有什么具体原因你在执行回调中一个接一个地同时发送和接收：

//send salary and loan amount to lender
producer.send(jmsMapMsg);

//get the accept or decline from lender
Message msg = session.createConsumer(queue).receive();

您通常会在单独的 JmsTemplate.receive() 调用中收到（不在回调中）。这将解耦/取消同步您的回调，并且很可能会解决您的问题：

Received a message on a connection which is not yet started.

【讨论】：

谢谢，这就是问题所在。修复它以单独进行接收并且工作正常。