登录
当前位置： 首页 > 知识库问答 >
问题：

Spring集成-带消息存储的队列-如何检查数据库中的持久化消息

乐成济
2023-03-14 
<bean id="sessionQueuePersistance"
    class="com.emph.SessionQueuePersistance">
    <constructor-arg name="sessionInboundChannel" ref="sessionInboundChannel" />
</bean>

<int:channel id="sessionInboundChannel">
    <int:queue message-store="sessionStore" />
    <int:interceptors>
        <int:ref bean="messageListener"/>
    </int:interceptors>
</int:channel>

<bean id="messageListener" class="com.emph.MessageListener" />

<!-- int:logging-channel-adapter id="logger" log-full-message="true" level="INFO" /-->

<bean id="sessionStore"
    class="org.springframework.integration.jdbc.store.JdbcChannelMessageStore">
    <property name="dataSource" ref="queueDataSource" />
    <property name="channelMessageStoreQueryProvider" ref="queryProvider" />
    <property name="tablePrefix" value="QUEUE_" />
</bean>

<bean id="queryProvider"
    class="org.springframework.integration.jdbc.store.channel.OracleChannelMessageStoreQueryProvider" />

<bean id="queueDataSource"
    class="org.springframework.jdbc.datasource.DriverManagerDataSource">
    <property name="driverClassName" value="oracle.jdbc.driver.OracleDriver" />
    <property name="url" value="jdbc:oracle:thin:@localhost:1521:XE" />
    <property name="username" value="test" />
    <property name="password" value="test" />
</bean>

<!-- the bridge polls the persisted messages and forwards them to the output 
    channel -->
<int:bridge input-channel="sessionInboundChannel"
    output-channel="sessionOutboundChannel">
    <int:poller fixed-rate="1000" max-messages-per-poll="-1">
        <int:transactional transaction-manager="txManager" />
    </int:poller>
</int:bridge>

<bean id="txManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
    <property name="dataSource" ref="queueDataSource"/>
</bean>

<int:channel id="sessionOutboundChannel">
    <int:dispatcher task-executor="taskExecutor" />
</int:channel>

<bean id="sessionQueueReader" class="com.emph.SessionReader" />

<int:service-activator input-channel="sessionOutboundChannel"
    ref="sessionQueueReader" method="handleMessage" />

<bean id="taskExecutor"
    class="org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor">
    <property name="corePoolSize" value="4" />
    <property name="maxPoolSize" value="4" />
</bean>

关于该事项的测试案例：

public class SessionQueuePersistanceTest {

  public static void main(String[] args) {

    AbstractApplicationContext context =
        new ClassPathXmlApplicationContext("/session-queue-config.xml",
            SessionQueuePersistanceTest.class);

    SessionQueuePersistance sessionQueuePersistance =
        (SessionQueuePersistance) context.getBean("sessionQueuePersistance");

    sessionQueuePersistance.addSessionToQueue("testSession1");
    sessionQueuePersistance.addSessionToQueue("testSession2");
    sessionQueuePersistance.addSessionToQueue("testSession3");
    sessionQueuePersistance.addSessionToQueue("testSession4");
    sessionQueuePersistance.addSessionToQueue("testSession5");
    sessionQueuePersistance.addSessionToQueue("testSession6");
    sessionQueuePersistance.addSessionToQueue("testSession7");
    sessionQueuePersistance.addSessionToQueue("testSession8");
    sessionQueuePersistance.addSessionToQueue("testSession9");

    try {
       TimeUnit.SECONDS.sleep(360);
     }catch(InteruptedException ex){

     }
    context.close();
  }

}

public class SessionQueuePersistance {

  private final QueueChannel sessionInboundChannel;


  public SessionQueuePersistance(QueueChannel sessionInboundChannel) {
    super();
    this.sessionInboundChannel = sessionInboundChannel;
  }

  public boolean addSessionToQueue(String sessionString) {
    Message<?> message = MessageBuilder.withPayload(sessionString).build();
    executorChannel.send(message);
    System.out.println(" --- addSessionToQueue: " + sessionString);
    return true;
  }

}

public class SessionReader {

  public void handleMessage(String inputSession) {
    System.out.println(" --- handling: " + inputSession);
  }

}

我刚接触spring集成，可能在配置中存在误解。

我的用例如下。从SessionQueuePer抵抗Bean我将消息发送到sesionIn边界通道。此通道包装在具有消息存储属性的队列中-消息应该存储在DB中。

日志：

   2015-12-17 09:15:37,726 [INFO ] org.springframework.integration.config.IntegrationRegistrar - No bean named 'integrationHeaderChannelRegistry' has been explicitly defined. Therefore, a default DefaultHeaderChannelRegistry will be created.
2015-12-17 09:15:37,736 [DEBUG] org.springframework.integration.config.IntegrationRegistrar - SpEL function '#jsonPath' isn't registered: there is no jayway json-path.jar on the classpath.
2015-12-17 09:15:37,736 [DEBUG] org.springframework.integration.config.IntegrationRegistrar - SpEL function '#xpath' isn't registered: there is no spring-integration-xml.jar on the classpath.
2015-12-17 09:15:37,806 [INFO ] org.springframework.integration.config.DefaultConfiguringBeanFactoryPostProcessor - No bean named 'errorChannel' has been explicitly defined. Therefore, a default PublishSubscribeChannel will be created.
2015-12-17 09:15:37,816 [INFO ] org.springframework.integration.config.DefaultConfiguringBeanFactoryPostProcessor - No bean named 'taskScheduler' has been explicitly defined. Therefore, a default ThreadPoolTaskScheduler will be created.
2015-12-17 09:15:38,046 [DEBUG] org.springframework.integration.handler.ServiceActivatingHandler - Unable to attempt conversion of Message payload types. Component 'null' has no explicit ConversionService reference, and there is no 'integrationConversionService' bean within the context.
2015-12-17 09:15:38,056 [DEBUG] org.springframework.integration.config.GlobalChannelInterceptorProcessor - No global channel interceptors.
2015-12-17 09:15:38,066 [INFO ] org.springframework.integration.endpoint.PollingConsumer - started org.springframework.integration.config.ConsumerEndpointFactoryBean#0
2015-12-17 09:15:38,066 [INFO ] org.springframework.integration.endpoint.EventDrivenConsumer - Adding {service-activator} as a subscriber to the 'sessionOutboundChannel' channel
2015-12-17 09:15:38,066 [INFO ] org.springframework.integration.channel.ExecutorChannel - Channel 'org.springframework.context.support.ClassPathXmlApplicationContext@5dccce3c.sessionOutboundChannel' has 1 subscriber(s).
2015-12-17 09:15:38,066 [INFO ] org.springframework.integration.endpoint.EventDrivenConsumer - started org.springframework.integration.config.ConsumerEndpointFactoryBean#1
2015-12-17 09:15:38,066 [INFO ] org.springframework.integration.endpoint.EventDrivenConsumer - Adding {logging-channel-adapter:_org.springframework.integration.errorLogger} as a subscriber to the 'errorChannel' channel
2015-12-17 09:15:38,066 [INFO ] org.springframework.integration.channel.PublishSubscribeChannel - Channel 'org.springframework.context.support.ClassPathXmlApplicationContext@5dccce3c.errorChannel' has 1 subscriber(s).
2015-12-17 09:15:38,066 [INFO ] org.springframework.integration.endpoint.EventDrivenConsumer - started _org.springframework.integration.errorLogger
2015-12-17 09:15:38,066 [DEBUG] org.springframework.integration.channel.QueueChannel - preSend on channel 'sessionInboundChannel', message: [Payload String content=testSession1][Headers={id=a60e5680-9025-b62a-1eb9-5f032e9f7997, timestamp=1450340138066}]
2015-12-17 09:15:38,267 [DEBUG] org.springframework.integration.jdbc.store.JdbcChannelMessageStore - Inserting message with id key=a60e5680-9025-b62a-1eb9-5f032e9f7997
2015-12-17 09:15:38,268 [DEBUG] org.springframework.integration.channel.QueueChannel - postSend (sent=true) on channel 'sessionInboundChannel', message: [Payload String content=testSession1][Headers={id=a60e5680-9025-b62a-1eb9-5f032e9f7997, timestamp=1450340138066}]
 --- addSessionToQueue: testSession1
2015-12-17 09:15:38,268 [DEBUG] org.springframework.integration.channel.QueueChannel - preSend on channel 'sessionInboundChannel', message: [Payload String content=testSession2][Headers={id=1e6e2629-6c80-e6a7-7748-1be25aac4e02, timestamp=1450340138268}]
2015-12-17 09:15:38,318 [DEBUG] org.springframework.integration.endpoint.PollingConsumer - Received no Message during the poll, returning 'false'
2015-12-17 09:15:38,349 [DEBUG] org.springframework.integration.jdbc.store.JdbcChannelMessageStore - Inserting message with id key=1e6e2629-6c80-e6a7-7748-1be25aac4e02
2015-12-17 09:15:38,349 [DEBUG] org.springframework.integration.channel.QueueChannel - postSend (sent=true) on channel 'sessionInboundChannel', message: [Payload String content=testSession2][Headers={id=1e6e2629-6c80-e6a7-7748-1be25aac4e02, timestamp=1450340138268}]
 --- addSessionToQueue: testSession2
2015-12-17 09:15:38,349 [DEBUG] org.springframework.integration.channel.QueueChannel - preSend on channel 'sessionInboundChannel', message: [Payload String content=testSession3][Headers={id=5ba804a1-a309-ed55-de9b-744e9b2f5c23, timestamp=1450340138349}]
2015-12-17 09:15:38,369 [DEBUG] org.springframework.integration.jdbc.store.JdbcChannelMessageStore - Inserting message with id key=5ba804a1-a309-ed55-de9b-744e9b2f5c23
2015-12-17 09:15:38,379 [DEBUG] org.springframework.integration.channel.QueueChannel - postSend (sent=true) on channel 'sessionInboundChannel', message: [Payload String content=testSession3][Headers={id=5ba804a1-a309-ed55-de9b-744e9b2f5c23, timestamp=1450340138349}]
 --- addSessionToQueue: testSession3
2015-12-17 09:15:38,379 [DEBUG] org.springframework.integration.channel.QueueChannel - preSend on channel 'sessionInboundChannel', message: [Payload String content=testSession4][Headers={id=58d85c60-4f43-3dbf-fe9d-dc4ab4853315, timestamp=1450340138379}]
2015-12-17 09:15:38,389 [DEBUG] org.springframework.integration.jdbc.store.JdbcChannelMessageStore - Inserting message with id key=58d85c60-4f43-3dbf-fe9d-dc4ab4853315
2015-12-17 09:15:38,399 [DEBUG] org.springframework.integration.channel.QueueChannel - postSend (sent=true) on channel 'sessionInboundChannel', message: [Payload String content=testSession4][Headers={id=58d85c60-4f43-3dbf-fe9d-dc4ab4853315, timestamp=1450340138379}]
 --- addSessionToQueue: testSession4
2015-12-17 09:15:38,399 [DEBUG] org.springframework.integration.channel.QueueChannel - preSend on channel 'sessionInboundChannel', message: [Payload String content=testSession5][Headers={id=75b03190-1dfd-9c32-8339-f23e1ba5afd6, timestamp=1450340138399}]
2015-12-17 09:15:38,409 [DEBUG] org.springframework.integration.jdbc.store.JdbcChannelMessageStore - Inserting message with id key=75b03190-1dfd-9c32-8339-f23e1ba5afd6
2015-12-17 09:15:38,409 [DEBUG] org.springframework.integration.channel.QueueChannel - postSend (sent=true) on channel 'sessionInboundChannel', message: [Payload String content=testSession5][Headers={id=75b03190-1dfd-9c32-8339-f23e1ba5afd6, timestamp=1450340138399}]
 --- addSessionToQueue: testSession5
2015-12-17 09:15:38,409 [DEBUG] org.springframework.integration.channel.QueueChannel - preSend on channel 'sessionInboundChannel', message: [Payload String content=testSession6][Headers={id=f7826aa2-d0f2-008e-9ed5-d8ab7a20a38d, timestamp=1450340138409}]
2015-12-17 09:15:38,429 [DEBUG] org.springframework.integration.jdbc.store.JdbcChannelMessageStore - Inserting message with id key=f7826aa2-d0f2-008e-9ed5-d8ab7a20a38d
2015-12-17 09:15:38,429 [DEBUG] org.springframework.integration.channel.QueueChannel - postSend (sent=true) on channel 'sessionInboundChannel', message: [Payload String content=testSession6][Headers={id=f7826aa2-d0f2-008e-9ed5-d8ab7a20a38d, timestamp=1450340138409}]
 --- addSessionToQueue: testSession6
2015-12-17 09:15:38,429 [DEBUG] org.springframework.integration.channel.QueueChannel - preSend on channel 'sessionInboundChannel', message: [Payload String content=testSession7][Headers={id=85daa925-bdba-eed3-84e2-31a131f9530f, timestamp=1450340138429}]
2015-12-17 09:15:38,439 [DEBUG] org.springframework.integration.jdbc.store.JdbcChannelMessageStore - Inserting message with id key=85daa925-bdba-eed3-84e2-31a131f9530f
2015-12-17 09:15:38,449 [DEBUG] org.springframework.integration.channel.QueueChannel - postSend (sent=true) on channel 'sessionInboundChannel', message: [Payload String content=testSession7][Headers={id=85daa925-bdba-eed3-84e2-31a131f9530f, timestamp=1450340138429}]
 --- addSessionToQueue: testSession7
2015-12-17 09:15:38,449 [DEBUG] org.springframework.integration.channel.QueueChannel - preSend on channel 'sessionInboundChannel', message: [Payload String content=testSession8][Headers={id=aca22ee7-4e04-be38-ef75-0b9ed241af4c, timestamp=1450340138449}]
2015-12-17 09:15:38,459 [DEBUG] org.springframework.integration.jdbc.store.JdbcChannelMessageStore - Inserting message with id key=aca22ee7-4e04-be38-ef75-0b9ed241af4c
2015-12-17 09:15:38,469 [DEBUG] org.springframework.integration.channel.QueueChannel - postSend (sent=true) on channel 'sessionInboundChannel', message: [Payload String content=testSession8][Headers={id=aca22ee7-4e04-be38-ef75-0b9ed241af4c, timestamp=1450340138449}]
 --- addSessionToQueue: testSession8
2015-12-17 09:15:38,469 [DEBUG] org.springframework.integration.channel.QueueChannel - preSend on channel 'sessionInboundChannel', message: [Payload String content=testSession9][Headers={id=5ce08183-8026-53e6-9bf7-55e1a4905e53, timestamp=1450340138469}]
2015-12-17 09:15:38,479 [DEBUG] org.springframework.integration.jdbc.store.JdbcChannelMessageStore - Inserting message with id key=5ce08183-8026-53e6-9bf7-55e1a4905e53
2015-12-17 09:15:38,479 [DEBUG] org.springframework.integration.channel.QueueChannel - postSend (sent=true) on channel 'sessionInboundChannel', message: [Payload String content=testSession9][Headers={id=5ce08183-8026-53e6-9bf7-55e1a4905e53, timestamp=1450340138469}]
 --- addSessionToQueue: testSession9
2015-12-17 09:15:39,111 [DEBUG] org.springframework.integration.jdbc.store.JdbcChannelMessageStore - Message with id '5ce08183-8026-53e6-9bf7-55e1a4905e53' was deleted.
2015-12-17 09:15:39,111 [DEBUG] org.springframework.integration.channel.QueueChannel - postReceive on channel 'sessionInboundChannel', message: [Payload String content=testSession9][Headers={JdbcChannelMessageStore.SAVED=true, JdbcChannelMessageStore.CREATED_DATE=1450340138469, id=5ce08183-8026-53e6-9bf7-55e1a4905e53, timestamp=1450340138469}]
2015-12-17 09:15:39,111 [DEBUG] org.springframework.integration.endpoint.PollingConsumer - Poll resulted in Message: [Payload String content=testSession9][Headers={JdbcChannelMessageStore.SAVED=true, JdbcChannelMessageStore.CREATED_DATE=1450340138469, id=5ce08183-8026-53e6-9bf7-55e1a4905e53, timestamp=1450340138469}]
2015-12-17 09:15:39,111 [DEBUG] org.springframework.integration.handler.BridgeHandler - org.springframework.integration.handler.BridgeHandler#0 received message: [Payload String content=testSession9][Headers={JdbcChannelMessageStore.SAVED=true, JdbcChannelMessageStore.CREATED_DATE=1450340138469, id=5ce08183-8026-53e6-9bf7-55e1a4905e53, timestamp=1450340138469}]
2015-12-17 09:15:39,111 [DEBUG] org.springframework.integration.handler.BridgeHandler - handler 'org.springframework.integration.handler.BridgeHandler#0' sending reply Message: [Payload String content=testSession9][Headers={JdbcChannelMessageStore.SAVED=true, JdbcChannelMessageStore.CREATED_DATE=1450340138469, id=5ce08183-8026-53e6-9bf7-55e1a4905e53, timestamp=1450340138469}]
2015-12-17 09:15:39,111 [DEBUG] org.springframework.integration.channel.ExecutorChannel - preSend on channel 'sessionOutboundChannel', message: [Payload String content=testSession9][Headers={JdbcChannelMessageStore.SAVED=true, JdbcChannelMessageStore.CREATED_DATE=1450340138469, id=5ce08183-8026-53e6-9bf7-55e1a4905e53, timestamp=1450340138469}]
2015-12-17 09:15:39,111 [DEBUG] org.springframework.integration.channel.ExecutorChannel - postSend (sent=true) on channel 'sessionOutboundChannel', message: [Payload String content=testSession9][Headers={JdbcChannelMessageStore.SAVED=true, JdbcChannelMessageStore.CREATED_DATE=1450340138469, id=5ce08183-8026-53e6-9bf7-55e1a4905e53, timestamp=1450340138469}]
2015-12-17 09:15:39,131 [DEBUG] org.springframework.integration.handler.ServiceActivatingHandler - ServiceActivator for [org.springframework.integration.handler.MethodInvokingMessageProcessor@77954f89] received message: [Payload String content=testSession9][Headers={JdbcChannelMessageStore.SAVED=true, JdbcChannelMessageStore.CREATED_DATE=1450340138469, id=5ce08183-8026-53e6-9bf7-55e1a4905e53, timestamp=1450340138469}]
 --- handling started testSession9
2015-12-17 09:15:40,161 [DEBUG] org.springframework.integration.endpoint.PollingConsumer - Received no Message during the poll, returning 'false'
 --- handling finished testSession9
2015-12-17 09:15:41,134 [DEBUG] org.springframework.integration.handler.ServiceActivatingHandler - handler 'ServiceActivator for [org.springframework.integration.handler.MethodInvokingMessageProcessor@77954f89]' produced no reply for request Message: [Payload String content=testSession9][Headers={JdbcChannelMessageStore.SAVED=true, JdbcChannelMessageStore.CREATED_DATE=1450340138469, id=5ce08183-8026-53e6-9bf7-55e1a4905e53, timestamp=1450340138469}]
2015-12-17 09:15:41,194 [DEBUG] org.springframework.integration.endpoint.PollingConsumer - Received no Message during the poll, returning 'false'
2015-12-17 09:15:42,235 [DEBUG] org.springframework.integration.endpoint.PollingConsumer - Received no Message during the poll, returning 'false'
2015-12-17 09:15:43,256 [DEBUG] org.springframework.integration.endpoint.PollingConsumer - Received no Message during the poll, returning 'false'
2015-12-17 09:15:44,277 [DEBUG] org.springframework.integration.endpoint.PollingConsumer - Received no Message during the poll, returning 'false'
2015-12-17 09:15:45,298 [DEBUG] org.springframework.integration.endpoint.PollingConsumer - Received no Message during the poll, returning 'false'
2015-12-17 09:15:46,320 [DEBUG] org.springframework.integration.endpoint.PollingConsumer - Received no Message during the poll, returning 'false'
2015-12-17 09:15:47,341 [DEBUG] org.springframework.integration.endpoint.PollingConsumer - Received no Message during the poll, returning 'false'
2015-12-17 09:15:48,363 [DEBUG] org.springframework.integration.endpoint.PollingConsumer - Received no Message during the poll, returning 'false'
2015-12-17 09:15:49,385 [DEBUG] org.springframework.integration.endpoint.PollingConsumer - Received no Message during the poll, returning 'false'
2015-12-17 09:15:50,406 [DEBUG] org.springframework.integration.endpoint.PollingConsumer - Received no Message during the poll, returning 'false'
2015-12-17 09:15:51,427 [DEBUG] org.springframework.integration.endpoint.PollingConsumer - Received no Message during the poll, returning 'false'
2015-12-17 09:15:52,448 [DEBUG] org.springframework.integration.endpoint.PollingConsumer - Received no Message during the poll, returning 'false'
2015-12-17 09:15:53,469 [DEBUG] org.springframework.integration.endpoint.PollingConsumer - Received no Message during the poll, returning 'false'
2015-12-17 09:15:54,490 [DEBUG] org.springframework.integration.endpoint.PollingConsumer - Received no Message during the poll, returning 'false'
2015-12-17 09:15:55,522 [DEBUG] org.springframework.integration.endpoint.PollingConsumer - Received no Message during the poll, returning 'false'
2015-12-17 09:15:56,556 [DEBUG] org.springframework.integration.endpoint.PollingConsumer - Received no Message during the poll, returning 'false'
2015-12-17 09:15:57,577 [DEBUG] org.springframework.integration.endpoint.PollingConsumer - Received no Message during the poll, returning 'false'
2015-12-17 09:15:58,609 [DEBUG] org.springframework.integration.endpoint.PollingConsumer - Received no Message during the poll, returning 'false'
2015-12-17 09:15:59,641 [DEBUG] org.springframework.integration.endpoint.PollingConsumer - Received no Message during the poll, returning 'false'
2015-12-17 09:16:00,672 [DEBUG] org.springframework.integration.endpoint.PollingConsumer - Received no Message during the poll, returning 'false'
2015-12-17 09:16:01,703 [DEBUG] org.springframework.integration.endpoint.PollingConsumer - Received no Message during the poll, returning 'false'
2015-12-17 09:16:02,724 [DEBUG] org.springframework.integration.endpoint.PollingConsumer - Received no Message during the poll, returning 'false'
2015-12-17 09:16:03,745 [DEBUG] org.springframework.integration.endpoint.PollingConsumer - Received no Message during the poll, returning 'false'
2015-12-17 09:16:04,776 [DEBUG] org.springframework.integration.endpoint.PollingConsumer - Received no Message during the poll, returning 'false'
2015-12-17 09:16:05,797 [DEBUG] org.springframework.integration.endpoint.PollingConsumer - Received no Message during the poll, returning 'false'
2015-12-17 09:16:06,821 [DEBUG] org.springframework.integration.endpoint.PollingConsumer - Received no Message during the poll, returning 'false'
2015-12-17 09:16:07,852 [DEBUG] org.springframework.integration.endpoint.PollingConsumer - Received no Message during the poll, returning 'false'
2015-12-17 09:16:08,874 [DEBUG] org.springframework.integration.endpoint.PollingConsumer - Received no Message during the poll, returning 'false'
2015-12-17 09:16:09,896 [DEBUG] org.springframework.integration.endpoint.PollingConsumer - Received no Message during the poll, returning 'false'
2015-12-17 09:16:10,920 [DEBUG] org.springframework.integration.endpoint.PollingConsumer - Received no Message during the poll, returning 'false'
2015-12-17 09:16:11,952 [DEBUG] org.springframework.integration.endpoint.PollingConsumer - Received no Message during the poll, returning 'false'
2015-12-17 09:16:12,973 [DEBUG] org.springframework.integration.endpoint.PollingConsumer - Received no Message during the poll, returning 'false'
2015-12-17 09:16:13,994 [DEBUG] org.springframework.integration.endpoint.PollingConsumer - Received no Message during the poll, returning 'false'
2015-12-17 09:16:14,487 [INFO ] org.springframework.integration.endpoint.PollingConsumer - stopped org.springframework.integration.config.ConsumerEndpointFactoryBean#0
2015-12-17 09:16:14,487 [DEBUG] org.springframework.integration.endpoint.PollingConsumer - Received no Message during the poll, returning 'false'
2015-12-17 09:16:14,487 [INFO ] org.springframework.integration.endpoint.EventDrivenConsumer - Removing {service-activator} as a subscriber to the 'sessionOutboundChannel' channel
2015-12-17 09:16:14,487 [INFO ] org.springframework.integration.channel.ExecutorChannel - Channel 'org.springframework.context.support.ClassPathXmlApplicationContext@5dccce3c.sessionOutboundChannel' has 0 subscriber(s).
2015-12-17 09:16:14,487 [INFO ] org.springframework.integration.endpoint.EventDrivenConsumer - stopped org.springframework.integration.config.ConsumerEndpointFactoryBean#1
2015-12-17 09:16:14,487 [INFO ] org.springframework.integration.endpoint.EventDrivenConsumer - Removing {logging-channel-adapter:_org.springframework.integration.errorLogger} as a subscriber to the 'errorChannel' channel
2015-12-17 09:16:14,487 [INFO ] org.springframework.integration.channel.PublishSubscribeChannel - Channel 'org.springframework.context.support.ClassPathXmlApplicationContext@5dccce3c.errorChannel' has 0 subscriber(s).
2015-12-17 09:16:14,487 [INFO ] org.springframework.integration.endpoint.EventDrivenConsumer - stopped _org.springframework.integration.errorLogger

共有1个答案

陆昊
2023-03-14

好吧，你没有说任何关于某个定制的ChannelInterceptor的事，但那没关系：根据你的日志，我们看到了

[DEBUG] org.springframework.integration.jdbc.store.JdbcChannelMessageStore - Inserting message with id key=

等等。

所以，一切正常。

我将我的评论复制到这里来结束这个问题：

我不确定该如何工作：您将队列通道注入到会话边界通道，但期望执行通道执行通道。所以，看起来你在这里发布之前修改了很多。所以，请分享整个组织的调试。springframework。运行测试后的集成类别。同时，我看不出你的配置有什么问题。。。

你的回答在这里没有意义。请将其移除。

 类似资料：
  • JMS持久订户持久消息不会持久化到数据库

    我正在使用网络逻辑10.3。我正在尝试配置一个持久订阅，其中包含由 jdbc 存储（在 Oracle DB 中）支持的持久消息。我有一个主题，MDB 正在作为持久订阅者侦听该主题。在场景-1下：如果我发送消息，它会命中MDB。 在场景2中:我挂起了MDB，希望发送到主题的消息只要不被MDB(它是唯一注册的持久订阅者)使用，就会一直存在。但是当我向主题发送消息时，它短暂地出现在那里，然后就消失了(我

  • 持久化数据库存储

    目的 配置 NFS 共享为 OpenShift 节点提供存储,并且配置 OpenShift 持久卷以绑定至数据库 Pod。 环境 openshift v3.11.16/kubernetes v1.11.0 步骤 配置 NFS 共享持久卷1. 登录到 NFS 服务器 # ssh nfs.example.com2. 创建 config-nfs.sh 脚本，内容如下 #!/usr/bin/sh exp

  • 如何在Spring集成中推迟消息的消耗

    我正在开发一个使用Spring Integration 5.0.1和Spring Boot 2.0.0的应用程序。RC1 目前，应用程序响应并运行一些可能需要一段时间才能完成的初始化代码。这不使用任何Spring集成组件。 我还有一些非常基本的集成流，使用JavaDSL编写，并在配置中声明为bean。 有什么方法可以推迟流何时开始消耗消息吗？我希望能够在初始化完成时手动启动它们。 配置似乎是解决方

  • 数据持久化存储

    主要内容：一、数据持久化,二、持久化的形式,三、源码分析,四、总结一、数据持久化 redis做为一种内存型数据库，做持久化，个人感觉略有鸡肋的意思。似乎有一种，别人有，自己不有也不行的感觉。以目前Redis主流的应用方式，如果仔细分析，基本上都是在内存中即可完成，对持久化没要求或者说不大。再举一个反例，如果内存中有几百G甚至更多的数据，真要是整体当机，恢复的时间基本就是灾难。 目前基本应用仍然是以关系型数据库或者其它数据库（如Hadoop，Mysql等）为持久化

  • 内存中数据库如何持久化数据

    我在研究内存数据库的概念。有关这方面的文章说， 内存数据库系统是一种将数据完全存储在主存中的数据库管理系统。 他们讨论了这个概念的优点和缺点。 我的问题是如果这些数据库管理系统将数据完全存储在主存储器中， 停电后所有数据都消失了吗？？？ 还是有办法保护数据？？？

  • 不带订阅服务器的持久性消息队列行为（ActiveMQ）

    我们开发的NMS产品已经被几家电信运营商部署。我们的应用程序（使用ActiveMQ）将向故障队列发布故障通知，消息被设置为持久性。这些消息由第三方JMS客户机使用。并不是所有的客户都有通知客户端来使用事件（有些部署没有任何订阅）。问题是，如果队列从来没有订阅服务器连接到队列，ActiveMQ是否会持久化消息？。

相关问答

主题中的消息持久性如何消费Spring云流默认死信队列的消息？IBM Websphere MQ-查看队列中的消息如何从OpenMRS数据库中检索HL7消息？Python用avro存储库反序列化kafka消息

相关文章

如何在Docker中处理持久性存储（例如数据库）Python中线程的MQ消息队列实现以及消息队列的优点解析如何检查数据库的存在？如何在Spring 3 / Thymeleaf中显示带有参数的本地化消息如何检查数据库列中存在的字符串？

相关阅读

消息队列 MQ 简介消息中间件 RabbitMQ 之 工作队列（2）—消息应答消息队列相关的5个问题Redis和RabbitMQ做消息队列的区别消息队列 RabbitMQ的介绍及安装

相关工具

大块头微信消息局域网内CS模式消息互发基于FMDB的数据库操作"一库" 仓储SPT 对象数据库

相关文档

Windows MSMQ 消息队列［初步文档］小米消息队列 EMQ 开发文档小米消息队列 Talos 开发文档小米结构化数据存储服务 SDS 开发指南Xcode Server 持续集成指南
快捷导航： 新手教程 算法原理 架构设计 Java进阶 数据库进阶 大厂专栏 面试经验 编程笔记 编程问答 所有专题 文档资料 工具软件 电子书籍 小牛导航
在线工具： 房贷计算器 个税计算器 Linux命令查询 Json格式化 正则表达式 颜色转换 AES加解密 SHA1加密 MD5加密 毒鸡汤 字数统计 随机密码生成 进制转换 Base64编解码 励志句子
Copyright © 2019-2024 小牛知识库@xnip.cn. All Rights Reserved.