Spring Integration Wiretap with Annotations (4.3 Spring Integration)

Question

我有一个 Spring Integration (4.3) 应用程序和一个 JMS 接收器，它将接收到的消息发送到 ServiceActivator。

我正在尝试窃听一个频道，并将 JMS 消息发送到 Logger（在本例中也是 Service Activator）

下面的代码有一个奇怪的行为。

发送的每条奇数消息（第一条，第三条） - 它只会发送给记录器。

发送的每条偶数消息（第二条、第四条等） - 只发送到应该做一些工作并在未来将消息发送到下游的 ServiceActivator。

这里是日志

2018-07-23 16:14:43.278 INFO 16532 --- [container-1] zzz : MSG1

通过 barChannel 接收：MSG2

如何更改我的代码，以便所有消息都发送到记录器和应该完成工作的 ServiceActivator？

提前非常感谢

@Bean
public ConnectionFactory jmsConnectionFactory() {
    return new ActiveMQConnectionFactory("tcp://localhost:61616");
}


@Bean
public JmsMessageDrivenEndpoint inbound() {
    JmsMessageDrivenEndpoint jmsMessageDrivenEndpoint = new JmsMessageDrivenEndpoint(container(), listener());
    jmsMessageDrivenEndpoint.setSessionAcknowledgeMode("transacted");
    jmsMessageDrivenEndpoint.setAutoStartup(true);
    return jmsMessageDrivenEndpoint;
}

@Bean
public DefaultMessageListenerContainer container() {
    DefaultMessageListenerContainer container = new DefaultMessageListenerContainer();
    container.setConnectionFactory(jmsConnectionFactory());
    container.setDestinationName("foo.bar");
    return container;
}

@Bean
public ChannelPublishingJmsMessageListener listener() {
    ChannelPublishingJmsMessageListener listener = new ChannelPublishingJmsMessageListener();
    listener.setRequestChannelName("myLogChannel");
    return listener;
}

@ServiceActivator(inputChannel = "myLogChannel")
public void bar(String in) {
    System.out.println("Received via barChannel: " + in);
}

@Bean
public MessageChannel TappingChannel(MessageChannel myLogChannel) {
    DirectChannel d = new DirectChannel();
    d.addInterceptor(new WireTap("myLogChannel"));
    return d;
}

@Bean
@ServiceActivator(inputChannel = "myLogChannel")
public MessageHandler logger() {
    LoggingHandler loggingHandler = new LoggingHandler(LoggingHandler.Level.INFO.name());
    loggingHandler.setLoggerName("zzz");
    return loggingHandler;
}

@Bean
public MessageChannel myLogChannel() {
    return new DirectChannel();
}

编辑：这是有效的原始代码

@Bean
public MessageChannel toRouter() {
    return new DirectChannel();
}

@Bean
public ConnectionFactory jmsConnectionFactory() {
    return new ActiveMQConnectionFactory("tcp://localhost:61616");
}


@Bean
public JmsMessageDrivenEndpoint inbound(ConnectionFactory jmsConnectionFactory) {
    return new JmsMessageDrivenEndpoint(container(jmsConnectionFactory), listener());
}

@Bean
public DefaultMessageListenerContainer container(ConnectionFactory jmsConnectionFactory) {
    DefaultMessageListenerContainer container = new DefaultMessageListenerContainer();
    container.setConnectionFactory(jmsConnectionFactory);
    container.setDestinationName("foo.bar");
    return container;
}

@Bean
public ChannelPublishingJmsMessageListener listener() {
    ChannelPublishingJmsMessageListener listener = new ChannelPublishingJmsMessageListener();
    listener.setRequestChannelName("toRouter");
    return listener;
}

@ServiceActivator(inputChannel = "toRouter")
public void bar(String in) {
    System.out.println("Received via barChannel: " + in);
}

我想对此代码进行窃听记录

Answer 1

你的配置一团糟。

首先，你有两个@ServiceActivator 对应同一个myLogChannel DirectChannel。 默认情况下，它使用循环调度策略。这就是为什么您会在同一频道上看到两个消费者之间的奇偶行为。

您将TappingChannel 分开不会带来任何价值，而且它根本无法使用。没有人向此频道发送消息：您直接发送到listener.setRequestChannelName("myLogChannel");...因此，WireTap 根本不会执行。

我不确定如何为您提供帮助，因为不清楚您将使用什么作为主通道以及应该从窃听器中使用什么。

更新

因此，您需要在此 toRouter 频道上配置 new WireTap("myLogChannel")。