将spring集成jms消息发送到特定队列（动态）

Question

简单的消息发布器如下所示：

@Service("myPublisher")
public class MyPublisher{

   @Publisher(channel = "myChannel")
   public Message<?> sendMessage (Message<?> message) {
      return message;
   }
}

...其配置如下：

<int:channel id="myChannel"/>   
<int-jms:outbound-channel-adapter channel="myChannel" destination="defaultDestination" session-transacted="true"/>
<bean class="org.springframework.integration.aop.PublisherAnnotationBeanPostProcessor"/>

问题是，此发布服务器将消息发送到准备好的默认目标，但我需要将消息发送到不同的队列。在我的情况下，我的应用程序中的每个任务都需要一个消息队列。原因是，如果要中止任务，必须从代理中删除消息。如果一个任务有数千条消息，那么使用选择器接收所有消息不是一个好的做法。我需要从消息代理中删除中止任务的所有消息，而不接收客户端。JMS仅支持消息的发送和接收。我必须使用代理API（QPID）删除消息。问题是，QPID不支持通过选择器删除消息，但它支持删除队列。

我想，我需要一个PublisherFactory，具有这样的功能：

public class PublisherFactory {
    public MyPublisher getPublisher(String destinationName){...};
}

factory.getPublisher("testQueue");

此方法应返回将消息发送到testQueue的发布者。

或具有以下功能的服务：

public class PublisherService {
    public Message<?> sendMessage(Message<?> message, String desinationName){...};
}

service.sendMessage(new Message("test"), "testQueue");

简而言之，我想要的就是一个服务，它可以向特定的目的地发送一条消息。目标名称应设置为方法调用上的参数或工厂上的类变量。

我希望有人能解决我的问题。谢谢：）

Answer 1

<代码>

destination-expression="headers.destination"

从另一边@Publisher的AOP允许构建消息以发布，默认情况下，不仅使用有效负载作为返回值，而且使用更智能的逻辑。例如：

@Publisher(channel="annotationConfigRegistrationTest")
@Payload("#return + #args.lname")
public String setName(String fname, String lname, @Header("x") int num) {
    return fname + " " + lname;
}

在这种情况下，要发布的消息将有一个类似有效负载的返回值，加上一个lname参数。标题（“x”）将向该消息填充一个标题，标题的值为num。

由于您的sendMessage方法返回整个消息

HTH