1

我目前正在通过网关使用弹簧集成通道，并看到一个非常奇怪（和烦人）的行为。消息在发送后处理得非常晚（超过一分钟）。

由于通道由它自己的线程池异步处理，我猜这些线程根本不活跃。由于发送这些消息非常重要，我想强制在当前线程中同步处理消息。

这可能吗？

我目前的配置：

<int:annotation-config />
<task:executor id="integrationPool" pool-size="0-100" />
<int:poller default="true" task-executor="integrationPool" fixed-rate="50" />

<int:channel id="loggableevents">
    <int:queue />
</int:channel>
<int:channel id="outgoingevents">
    <int:queue />
    <int:interceptors>
        <int:wire-tap channel="loggableevents" />
    </int:interceptors>
</int:channel>

<int:outbound-channel-adapter channel="outgoingevents" method="handleMessage" ref="momadapter" />
<bean id="momadapter" class="my.project.mom.EventSendingMessageHandler" />

<!-- Logging -->
<int:outbound-channel-adapter channel="loggableevents" ref="loggingadapter" method="handleMessage" />
<bean id="loggingadapter" class="my.project.logging.EventLoggingHandler" />

<int:gateway id="eventgateway" service-interface="my.project.mom.EventGateway" default-request-channel="outgoingevents" />

我使用网关是为了方便，直接访问通道会更好吗？

4

2 回答 2

4

只需<queue/>从通道中删除元素，outgoingEvents它将全部在调用线程上运行。

http://static.springsource.org/spring-integration/docs/2.1.2.RELEASE/reference/html/messaging-channels-section.html

于 2012-06-06T14:11:44.873 回答
0

如果您得到这个答案并且正在使用基于接口的网关。使用消息通道是强制性的。在这种情况下，解决方案是使用直接通道。以下代码示例显示了如何使用 java DSL 来执行此操作。

@Bean(name = "spa.import.zipcodes")
public MessageChannel queueRecordsChannel() {
    return MessageChannels.direct().get();
}

查看此页面以获取有关 DirectChannel 的更多信息：http: //docs.spring.io/spring-integration/reference/html/messaging-channels-section.html

于 2015-05-21T14:47:44.470 回答