我浏览了 RabbitTemplate 的 API。它只提供从队列中获取消息的接收方法。但是,无法获取具有特定相关 ID 的消息。你能帮我理解我在这里缺少什么吗?
目前,我正在使用来自 ActiveMQ 的 JMS API 使用以下代码接收消息,该代码使用消息选择器 createConsumer。希望对带有 RabbitMQ 的 Spring AMQP 做同样的事情:
private ObjectMessage receiveMessage(final String readQueue, final UUID correlationId, final boolean isBroadcastMessage, final int readTimeout) throws JMSException
{
final ActiveMQConnectionFactory connectionFactory = this.findConnectionFactory(readQueue);
Connection connection = null;
Session session = null;
MessageConsumer consumer = null;
ObjectMessage responseMessage = null;
try
{
connection = connectionFactory.createConnection();
connection.start();
session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
Destination destination = session.createQueue(readQueue);
consumer = session.createConsumer(destination, "correlationId = '" + correlationId + "'");
final Message message = consumer.receive(readTimeout);
}
finally
{
if (consumer != null)
{
consumer.close();
}
if (session != null)
{
session.close();
}
if (connection != null)
{
connection.close();
}
}
return responseMessage;
}