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

在SEDAendpoint上没有使用所提供的队列实例的消息

宗政小林
2023-03-14

在以下camel上下文中，我使用提供的ArrayBlockingQueue配置了一个SEDAendpoint：

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
       xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
       xsi:schemaLocation="
        http://www.springframework.org/schema/beans
        http://www.springframework.org/schema/beans/spring-beans.xsd
        http://camel.apache.org/schema/spring http://camel.apache.org/schema/spring/camel-spring.xsd">

    <bean id="arrayQueue" class="java.util.concurrent.ArrayBlockingQueue">
        <constructor-arg index="0" value="10" /><!-- size -->
        <constructor-arg index="1" value="true" /><!-- fairness -->
    </bean>

    <camelContext id="camel" xmlns="http://camel.apache.org/schema/spring">
        <route id="sendRoute">
            <from uri="direct:send"/>
            <to uri="seda:send" />
        </route>
        <route id="sedaRoute">
            <from uri="seda:send?queue=#arrayQueue"/>
            <log message="My message: ${body}" loggingLevel="INFO"/>
        </route>
    </camelContext>
</beans>

但是，发送到endpoint的消息不会被消耗。

2016-06-03 19:53:19,231 TRACE [http-/0.0.0.0:8080-1] camel.impl.SharedProducerServicePool  No free services in pool to acquire for key: Endpoint[direct://send]

2016-06-03 19:53:19,231 TRACE [http-/0.0.0.0:8080-1] camel.support.ServiceSupport  Starting service

2016-06-03 19:53:19,232 DEBUG [http-/0.0.0.0:8080-1] component.direct.DirectProducer  Starting producer: Producer[direct://send]

2016-06-03 19:53:19,232 DEBUG [http-/0.0.0.0:8080-1] camel.impl.ProducerCache  Adding to producer cache with key: Endpoint[direct://send] for producer: Producer[direct://send]

2016-06-03 19:53:19,235 TRACE [http-/0.0.0.0:8080-1] impl.converter.DefaultTypeConverter  Converting java.lang.String -> java.lang.String with value: abc

2016-06-03 19:53:19,235 DEBUG [http-/0.0.0.0:8080-1] camel.impl.ProducerCache  >>>> Endpoint[direct://send] Exchange[Message: abc]

2016-06-03 19:53:19,237 TRACE [http-/0.0.0.0:8080-1] impl.converter.DefaultTypeConverter  Converting java.lang.String -> java.lang.String with value: abc

2016-06-03 19:53:19,237 TRACE [http-/0.0.0.0:8080-1] camel.impl.DefaultUnitOfWork  UnitOfWork created for ExchangeId: ID-DT-DBOZANOVIC-63893-1464976388425-0-1 with Exchange[Message: abc]

2016-06-03 19:53:19,239 TRACE [http-/0.0.0.0:8080-1] impl.converter.DefaultTypeConverter  Converting java.lang.String -> java.lang.String with value: abc

2016-06-03 19:53:19,239 TRACE [http-/0.0.0.0:8080-1] camel.util.EventHelper  Notification of event is disabled: ID-DT-DBOZANOVIC-63893-1464976388425-0-1 exchange created: Exchange[Message: abc]

2016-06-03 19:53:19,240 TRACE [http-/0.0.0.0:8080-1] impl.converter.DefaultTypeConverter  Converting java.lang.String -> java.lang.String with value: abc

2016-06-03 19:53:19,240 TRACE [http-/0.0.0.0:8080-1] camel.processor.CamelInternalProcessor  Processing exchange for exchangeId: ID-DT-DBOZANOVIC-63893-1464976388425-0-1 -> Exchange[Message: abc]

2016-06-03 19:53:19,240 TRACE [http-/0.0.0.0:8080-1] impl.converter.DefaultTypeConverter  Converting java.lang.String -> java.lang.String with value: abc

2016-06-03 19:53:19,240 TRACE [http-/0.0.0.0:8080-1] camel.processor.CamelInternalProcessor  Processing exchange for exchangeId: ID-DT-DBOZANOVIC-63893-1464976388425-0-1 -> Exchange[Message: abc]

2016-06-03 19:53:19,241 TRACE [http-/0.0.0.0:8080-1] impl.converter.DefaultTypeConverter  Converting java.lang.String -> java.lang.String with value: abc

2016-06-03 19:53:19,241 TRACE [http-/0.0.0.0:8080-1] camel.processor.CamelInternalProcessor  Processing exchange for exchangeId: ID-DT-DBOZANOVIC-63893-1464976388425-0-1 -> Exchange[Message: abc]

2016-06-03 19:53:19,241 TRACE [http-/0.0.0.0:8080-1] camel.processor.DefaultErrorHandler  isRunAllowed() -> true (Run allowed if we are not stopped/stopping)

2016-06-03 19:53:19,242 TRACE [http-/0.0.0.0:8080-1] impl.converter.DefaultTypeConverter  Converting java.lang.String -> java.lang.String with value: abc

2016-06-03 19:53:19,242 DEBUG [http-/0.0.0.0:8080-1] camel.processor.SendProcessor  >>>> Endpoint[seda://send] Exchange[Message: abc]

2016-06-03 19:53:19,244 TRACE [http-/0.0.0.0:8080-1] impl.converter.DefaultTypeConverter  Converting java.lang.String -> java.lang.String with value: abc

2016-06-03 19:53:19,245 TRACE [http-/0.0.0.0:8080-1] component.seda.SedaProducer  Adding Exchange to queue: Exchange[Message: abc]

2016-06-03 19:53:19,245 TRACE [http-/0.0.0.0:8080-1] impl.converter.DefaultTypeConverter  Converting java.lang.String -> java.lang.String with value: abc

2016-06-03 19:53:19,245 TRACE [http-/0.0.0.0:8080-1] camel.util.EventHelper  Notification of event is disabled: ID-DT-DBOZANOVIC-63893-1464976388425-0-1 exchange Exchange[Message: abc] sent to: Endpoint[seda://send] took: 3 ms.

2016-06-03 19:53:19,245 TRACE [http-/0.0.0.0:8080-1] impl.converter.DefaultTypeConverter  Converting java.lang.String -> java.lang.String with value: abc

2016-06-03 19:53:19,246 TRACE [http-/0.0.0.0:8080-1] camel.management.InstrumentationProcessor  to: Recording duration: 3 millis for exchange: Exchange[Message: abc]

2016-06-03 19:53:19,246 TRACE [http-/0.0.0.0:8080-1] camel.processor.DefaultErrorHandler  Is exchangeId: ID-DT-DBOZANOVIC-63893-1464976388425-0-1 interrupted? false

2016-06-03 19:53:19,246 TRACE [http-/0.0.0.0:8080-1] camel.processor.DefaultErrorHandler  Is exchangeId: ID-DT-DBOZANOVIC-63893-1464976388425-0-1 done? true

2016-06-03 19:53:19,246 TRACE [http-/0.0.0.0:8080-1] impl.converter.DefaultTypeConverter  Converting java.lang.String -> java.lang.String with value: abc

2016-06-03 19:53:19,246 TRACE [http-/0.0.0.0:8080-1] camel.processor.CamelInternalProcessor  route: Recording duration: 6 millis for exchange: Exchange[Message: abc]

2016-06-03 19:53:19,247 TRACE [http-/0.0.0.0:8080-1] impl.converter.DefaultTypeConverter  Converting java.lang.String -> java.lang.String with value: abc

2016-06-03 19:53:19,247 TRACE [http-/0.0.0.0:8080-1] camel.impl.DefaultUnitOfWork  UnitOfWork done for ExchangeId: ID-DT-DBOZANOVIC-63893-1464976388425-0-1 with Exchange[Message: abc]

2016-06-03 19:53:19,247 TRACE [http-/0.0.0.0:8080-1] impl.converter.DefaultTypeConverter  Converting java.lang.String -> java.lang.String with value: abc

2016-06-03 19:53:19,247 TRACE [http-/0.0.0.0:8080-1] camel.util.EventHelper  Notification of event is disabled: ID-DT-DBOZANOVIC-63893-1464976388425-0-1 exchange completed: Exchange[Message: abc]

2016-06-03 19:53:19,248 TRACE [http-/0.0.0.0:8080-1] impl.converter.DefaultTypeConverter  Converting java.lang.String -> java.lang.String with value: abc

2016-06-03 19:53:19,248 TRACE [http-/0.0.0.0:8080-1] camel.processor.CamelInternalProcessor  Exchange processed and is continued routed synchronously for exchangeId: ID-DT-DBOZANOVIC-63893-1464976388425-0-1 -> Exchange[Message: abc]

2016-06-03 19:53:19,248 TRACE [http-/0.0.0.0:8080-1] impl.converter.DefaultTypeConverter  Converting java.lang.String -> java.lang.String with value: abc

2016-06-03 19:53:19,248 TRACE [http-/0.0.0.0:8080-1] camel.processor.CamelInternalProcessor  Exchange processed and is continued routed synchronously for exchangeId: ID-DT-DBOZANOVIC-63893-1464976388425-0-1 -> Exchange[Message: abc]

2016-06-03 19:53:19,248 TRACE [http-/0.0.0.0:8080-1] impl.converter.DefaultTypeConverter  Converting java.lang.String -> java.lang.String with value: abc

2016-06-03 19:53:19,248 TRACE [http-/0.0.0.0:8080-1] camel.processor.CamelInternalProcessor  Exchange processed and is continued routed synchronously for exchangeId: ID-DT-DBOZANOVIC-63893-1464976388425-0-1 -> Exchange[Message: abc]

2016-06-03 19:53:19,248 TRACE [http-/0.0.0.0:8080-1] impl.converter.DefaultTypeConverter  Converting java.lang.String -> java.lang.String with value: abc

2016-06-03 19:53:19,248 TRACE [http-/0.0.0.0:8080-1] camel.util.EventHelper  Notification of event is disabled: ID-DT-DBOZANOVIC-63893-1464976388425-0-1 exchange Exchange[Message: abc] sent to: Endpoint[direct://send] took: 13 ms.

2016-06-03 19:50:40,333 TRACE [http-/0.0.0.0:8080-1] camel.impl.SharedProducerServicePool  No free services in pool to acquire for key: Endpoint[direct://send]

2016-06-03 19:50:40,334 TRACE [http-/0.0.0.0:8080-1] camel.support.ServiceSupport  Starting service

2016-06-03 19:50:40,334 DEBUG [http-/0.0.0.0:8080-1] component.direct.DirectProducer  Starting producer: Producer[direct://send]

2016-06-03 19:50:40,334 DEBUG [http-/0.0.0.0:8080-1] camel.impl.ProducerCache  Adding to producer cache with key: Endpoint[direct://send] for producer: Producer[direct://send]

2016-06-03 19:50:40,337 TRACE [http-/0.0.0.0:8080-1] impl.converter.DefaultTypeConverter  Converting java.lang.String -> java.lang.String with value: abc

2016-06-03 19:50:40,338 DEBUG [http-/0.0.0.0:8080-1] camel.impl.ProducerCache  >>>> Endpoint[direct://send] Exchange[Message: abc]

2016-06-03 19:50:40,340 TRACE [http-/0.0.0.0:8080-1] impl.converter.DefaultTypeConverter  Converting java.lang.String -> java.lang.String with value: abc

2016-06-03 19:50:40,340 TRACE [http-/0.0.0.0:8080-1] camel.impl.DefaultUnitOfWork  UnitOfWork created for ExchangeId: ID-DT-DBOZANOVIC-63763-1464976228255-0-1 with Exchange[Message: abc]

2016-06-03 19:50:40,341 TRACE [http-/0.0.0.0:8080-1] impl.converter.DefaultTypeConverter  Converting java.lang.String -> java.lang.String with value: abc

2016-06-03 19:50:40,341 TRACE [http-/0.0.0.0:8080-1] camel.util.EventHelper  Notification of event is disabled: ID-DT-DBOZANOVIC-63763-1464976228255-0-1 exchange created: Exchange[Message: abc]

2016-06-03 19:50:40,342 TRACE [http-/0.0.0.0:8080-1] impl.converter.DefaultTypeConverter  Converting java.lang.String -> java.lang.String with value: abc

2016-06-03 19:50:40,342 TRACE [http-/0.0.0.0:8080-1] camel.processor.CamelInternalProcessor  Processing exchange for exchangeId: ID-DT-DBOZANOVIC-63763-1464976228255-0-1 -> Exchange[Message: abc]

2016-06-03 19:50:40,342 TRACE [http-/0.0.0.0:8080-1] impl.converter.DefaultTypeConverter  Converting java.lang.String -> java.lang.String with value: abc

2016-06-03 19:50:40,342 TRACE [http-/0.0.0.0:8080-1] camel.processor.CamelInternalProcessor  Processing exchange for exchangeId: ID-DT-DBOZANOVIC-63763-1464976228255-0-1 -> Exchange[Message: abc]

2016-06-03 19:50:40,343 TRACE [http-/0.0.0.0:8080-1] impl.converter.DefaultTypeConverter  Converting java.lang.String -> java.lang.String with value: abc

2016-06-03 19:50:40,343 TRACE [http-/0.0.0.0:8080-1] camel.processor.CamelInternalProcessor  Processing exchange for exchangeId: ID-DT-DBOZANOVIC-63763-1464976228255-0-1 -> Exchange[Message: abc]

2016-06-03 19:50:40,343 TRACE [http-/0.0.0.0:8080-1] camel.processor.DefaultErrorHandler  isRunAllowed() -> true (Run allowed if we are not stopped/stopping)

2016-06-03 19:50:40,344 TRACE [http-/0.0.0.0:8080-1] impl.converter.DefaultTypeConverter  Converting java.lang.String -> java.lang.String with value: abc

2016-06-03 19:50:40,344 DEBUG [http-/0.0.0.0:8080-1] camel.processor.SendProcessor  >>>> Endpoint[seda://send] Exchange[Message: abc]

2016-06-03 19:50:40,346 TRACE [http-/0.0.0.0:8080-1] impl.converter.DefaultTypeConverter  Converting java.lang.String -> java.lang.String with value: abc

2016-06-03 19:50:40,346 TRACE [http-/0.0.0.0:8080-1] component.seda.SedaProducer  Adding Exchange to queue: Exchange[Message: abc]

2016-06-03 19:50:40,347 TRACE [Camel (camel) thread #0 - seda://send] impl.converter.DefaultTypeConverter  Converting java.lang.String -> java.lang.String with value: abc

2016-06-03 19:50:40,347 TRACE [http-/0.0.0.0:8080-1] impl.converter.DefaultTypeConverter  Converting java.lang.String -> java.lang.String with value: abc

2016-06-03 19:50:40,347 TRACE [Camel (camel) thread #0 - seda://send] component.seda.SedaConsumer  Polled queue 0x753d1721 with timeout 1000 ms. -> Exchange[Message: abc]

2016-06-03 19:50:40,347 TRACE [http-/0.0.0.0:8080-1] camel.util.EventHelper  Notification of event is disabled: ID-DT-DBOZANOVIC-63763-1464976228255-0-1 exchange Exchange[Message: abc] sent to: Endpoint[seda://send] took: 2 ms.

2016-06-03 19:50:40,348 TRACE [http-/0.0.0.0:8080-1] impl.converter.DefaultTypeConverter  Converting java.lang.String -> java.lang.String with value: abc

2016-06-03 19:50:40,348 TRACE [http-/0.0.0.0:8080-1] camel.management.InstrumentationProcessor  to: Recording duration: 3 millis for exchange: Exchange[Message: abc]

2016-06-03 19:50:40,348 TRACE [Camel (camel) thread #0 - seda://send] impl.converter.DefaultTypeConverter  Converting java.lang.String -> java.lang.String with value: abc

2016-06-03 19:50:40,348 TRACE [http-/0.0.0.0:8080-1] camel.processor.DefaultErrorHandler  Is exchangeId: ID-DT-DBOZANOVIC-63763-1464976228255-0-1 interrupted? false

2016-06-03 19:50:40,348 TRACE [http-/0.0.0.0:8080-1] camel.processor.DefaultErrorHandler  Is exchangeId: ID-DT-DBOZANOVIC-63763-1464976228255-0-1 done? true

2016-06-03 19:50:40,348 TRACE [Camel (camel) thread #0 - seda://send] camel.impl.DefaultUnitOfWork  UnitOfWork created for ExchangeId: ID-DT-DBOZANOVIC-63763-1464976228255-0-3 with Exchange[Message: abc]

2016-06-03 19:50:40,348 TRACE [http-/0.0.0.0:8080-1] impl.converter.DefaultTypeConverter  Converting java.lang.String -> java.lang.String with value: abc

2016-06-03 19:50:40,349 TRACE [http-/0.0.0.0:8080-1] camel.processor.CamelInternalProcessor  route: Recording duration: 6 millis for exchange: Exchange[Message: abc]

2016-06-03 19:50:40,348 TRACE [Camel (camel) thread #0 - seda://send] impl.converter.DefaultTypeConverter  Converting java.lang.String -> java.lang.String with value: abc

2016-06-03 19:50:40,349 TRACE [http-/0.0.0.0:8080-1] impl.converter.DefaultTypeConverter  Converting java.lang.String -> java.lang.String with value: abc

2016-06-03 19:50:40,349 TRACE [http-/0.0.0.0:8080-1] camel.impl.DefaultUnitOfWork  UnitOfWork done for ExchangeId: ID-DT-DBOZANOVIC-63763-1464976228255-0-1 with Exchange[Message: abc]

2016-06-03 19:50:40,349 TRACE [Camel (camel) thread #0 - seda://send] camel.util.EventHelper  Notification of event is disabled: ID-DT-DBOZANOVIC-63763-1464976228255-0-3 exchange created: Exchange[Message: abc]

2016-06-03 19:50:40,350 TRACE [http-/0.0.0.0:8080-1] impl.converter.DefaultTypeConverter  Converting java.lang.String -> java.lang.String with value: abc

2016-06-03 19:50:40,350 TRACE [Camel (camel) thread #0 - seda://send] impl.converter.DefaultTypeConverter  Converting java.lang.String -> java.lang.String with value: abc

2016-06-03 19:50:40,350 TRACE [http-/0.0.0.0:8080-1] camel.util.EventHelper  Notification of event is disabled: ID-DT-DBOZANOVIC-63763-1464976228255-0-1 exchange completed: Exchange[Message: abc]

2016-06-03 19:50:40,350 TRACE [Camel (camel) thread #0 - seda://send] camel.processor.CamelInternalProcessor  Processing exchange for exchangeId: ID-DT-DBOZANOVIC-63763-1464976228255-0-3 -> Exchange[Message: abc]

2016-06-03 19:50:40,350 TRACE [http-/0.0.0.0:8080-1] impl.converter.DefaultTypeConverter  Converting java.lang.String -> java.lang.String with value: abc

2016-06-03 19:50:40,350 TRACE [http-/0.0.0.0:8080-1] camel.processor.CamelInternalProcessor  Exchange processed and is continued routed synchronously for exchangeId: ID-DT-DBOZANOVIC-63763-1464976228255-0-1 -> Exchange[Message: abc]

2016-06-03 19:50:40,350 TRACE [Camel (camel) thread #0 - seda://send] impl.converter.DefaultTypeConverter  Converting java.lang.String -> java.lang.String with value: abc

2016-06-03 19:50:40,351 TRACE [http-/0.0.0.0:8080-1] impl.converter.DefaultTypeConverter  Converting java.lang.String -> java.lang.String with value: abc

2016-06-03 19:50:40,351 TRACE [http-/0.0.0.0:8080-1] camel.processor.CamelInternalProcessor  Exchange processed and is continued routed synchronously for exchangeId: ID-DT-DBOZANOVIC-63763-1464976228255-0-1 -> Exchange[Message: abc]

2016-06-03 19:50:40,351 TRACE [Camel (camel) thread #0 - seda://send] camel.processor.CamelInternalProcessor  Processing exchange for exchangeId: ID-DT-DBOZANOVIC-63763-1464976228255-0-3 -> Exchange[Message: abc]

2016-06-03 19:50:40,351 TRACE [http-/0.0.0.0:8080-1] impl.converter.DefaultTypeConverter  Converting java.lang.String -> java.lang.String with value: abc

2016-06-03 19:50:40,351 TRACE [http-/0.0.0.0:8080-1] camel.processor.CamelInternalProcessor  Exchange processed and is continued routed synchronously for exchangeId: ID-DT-DBOZANOVIC-63763-1464976228255-0-1 -> Exchange[Message: abc]

2016-06-03 19:50:40,351 TRACE [Camel (camel) thread #0 - seda://send] camel.processor.DefaultErrorHandler  isRunAllowed() -> true (Run allowed if we are not stopped/stopping)

2016-06-03 19:50:40,351 TRACE [http-/0.0.0.0:8080-1] impl.converter.DefaultTypeConverter  Converting java.lang.String -> java.lang.String with value: abc

2016-06-03 19:50:40,352 TRACE [http-/0.0.0.0:8080-1] camel.util.EventHelper  Notification of event is disabled: ID-DT-DBOZANOVIC-63763-1464976228255-0-1 exchange Exchange[Message: abc] sent to: Endpoint[direct://send] took: 13 ms.

2016-06-03 19:50:40,352 TRACE [Camel (camel) thread #0 - seda://send] impl.converter.DefaultTypeConverter  Converting java.lang.String -> java.lang.String with value: My message: 

2016-06-03 19:50:40,352 TRACE [Camel (camel) thread #0 - seda://send] impl.converter.DefaultTypeConverter  Converting java.lang.String -> java.lang.String with value: abc

2016-06-03 19:50:40,352 TRACE [Camel (camel) thread #0 - seda://send] impl.converter.DefaultTypeConverter  Converting java.lang.String -> java.lang.String with value: My message: abc

2016-06-03 19:50:40,352 INFO  [Camel (camel) thread #0 - seda://send] sedaRoute  My message: abc

2016-06-03 19:50:40,352 TRACE [Camel (camel) thread #0 - seda://send] impl.converter.DefaultTypeConverter  Converting java.lang.String -> java.lang.String with value: abc

2016-06-03 19:50:40,353 TRACE [Camel (camel) thread #0 - seda://send] camel.management.InstrumentationProcessor  log: Recording duration: 1 millis for exchange: Exchange[Message: abc]

2016-06-03 19:50:40,353 TRACE [Camel (camel) thread #0 - seda://send] camel.processor.DefaultErrorHandler  Is exchangeId: ID-DT-DBOZANOVIC-63763-1464976228255-0-3 interrupted? false

2016-06-03 19:50:40,353 TRACE [Camel (camel) thread #0 - seda://send] camel.processor.DefaultErrorHandler  Is exchangeId: ID-DT-DBOZANOVIC-63763-1464976228255-0-3 done? true

2016-06-03 19:50:40,353 TRACE [Camel (camel) thread #0 - seda://send] impl.converter.DefaultTypeConverter  Converting java.lang.String -> java.lang.String with value: abc

2016-06-03 19:50:40,353 TRACE [Camel (camel) thread #0 - seda://send] camel.processor.CamelInternalProcessor  route: Recording duration: 3 millis for exchange: Exchange[Message: abc]

2016-06-03 19:50:40,354 TRACE [Camel (camel) thread #0 - seda://send] impl.converter.DefaultTypeConverter  Converting java.lang.String -> java.lang.String with value: abc

2016-06-03 19:50:40,354 TRACE [Camel (camel) thread #0 - seda://send] camel.impl.DefaultUnitOfWork  UnitOfWork done for ExchangeId: ID-DT-DBOZANOVIC-63763-1464976228255-0-3 with Exchange[Message: abc]

2016-06-03 19:50:40,354 TRACE [Camel (camel) thread #0 - seda://send] impl.converter.DefaultTypeConverter  Converting java.lang.String -> java.lang.String with value: abc

2016-06-03 19:50:40,354 TRACE [Camel (camel) thread #0 - seda://send] camel.util.EventHelper  Notification of event is disabled: ID-DT-DBOZANOVIC-63763-1464976228255-0-3 exchange completed: Exchange[Message: abc]

2016-06-03 19:50:40,355 TRACE [Camel (camel) thread #0 - seda://send] impl.converter.DefaultTypeConverter  Converting java.lang.String -> java.lang.String with value: abc

2016-06-03 19:50:40,355 TRACE [Camel (camel) thread #0 - seda://send] camel.processor.CamelInternalProcessor  Exchange processed and is continued routed synchronously for exchangeId: ID-DT-DBOZANOVIC-63763-1464976228255-0-3 -> Exchange[Message: abc]

2016-06-03 19:50:40,355 TRACE [Camel (camel) thread #0 - seda://send] impl.converter.DefaultTypeConverter  Converting java.lang.String -> java.lang.String with value: abc

2016-06-03 19:50:40,355 TRACE [Camel (camel) thread #0 - seda://send] camel.processor.CamelInternalProcessor  Exchange processed and is continued routed synchronously for exchangeId: ID-DT-DBOZANOVIC-63763-1464976228255-0-3 -> Exchange[Message: abc]

共有1个答案

袁鸿畴
2023-03-14

您需要在两个SEDAendpoint上配置队列。

 类似资料：
  • PHP消息队列用法实例分析

    本文向大家介绍PHP消息队列用法实例分析，包括了PHP消息队列用法实例分析的使用技巧和注意事项，需要的朋友参考一下 本文实例讲述了PHP消息队列用法。分享给大家供大家参考，具体如下： 该消息队列用于linux下，进程通信 队列状态信息：具体参考手册 linux下 用 ipc命令查看 ，用 ipcrm 命令可以删除 更多关于PHP相关内容感兴趣的读者可查看本站专题：《PHP基本语法入门教程》、《PH

  • 在RabbitMQ中，如何使用特定密钥使用多条消息或读取队列中的所有消息或exchange中的所有消息？

    我想使用来自特定队列或具有给定密钥的特定交换的多个消息。 因此，场景如下所示： 发布者发布消息1在队列1发布者发布消息2在队列1发布者发布消息3在队列1发布者发布消息4在队列2发布者发布消息5在队列2...消费者从队列1中消费消息一次获取[消息1，消息2，消息3]，并在一次回调中处理它们 这些消息不是同时出现的，就像事件一样，我希望将它们收集到队列中，打包并发送给第三方。 我也读过这篇文章： ht

  • 带有sedaendpoint的Apache Camel消息确认

    我正在尝试编写一条路由，将消息转发到这样的sedaendpoint 还有另一个从seda终结点消耗的路由： JMS连接工厂的JMS确认模式是CLIENT_ACKNOWLEDGE，我已经使用spring boot配置了该项目。根据配置，一旦第一个驼峰路由结束，它就应该提交事务并将确认发送给message broker。 但是，这种行为是消息确认只在第二条路由完成后发生。我可以在第一个路由中配置什么来

  • 在MQTT代理中有没有为消息提供TTL的方法

    在MQTT规范中，有connect标志，用于管理服务器和客户端上的保留和状态。 clean session规范建议： 因此，每当客户端在断开连接后再次连接时，代理将中继所有未被确认的QoS-1和QoS-2消息。所以，经纪人有一个状态。为了维护每个客户机的状态，服务器将使用一些数据库进行保留。是否有办法为这些消息状态（服务器将存储这些消息状态）留出时间。如何告诉代理删除（即不中继）任何比；比如说5天

  • 使用Lambda函数使用供应商提供的所有对象

    寻找如何使用Javalambda函数，以便消费者可以处理供应商提供的所有对象，并在循环和检查时摆脱显式

  • windows消息和消息队列实例详解

    本文向大家介绍windows消息和消息队列实例详解，包括了windows消息和消息队列实例详解的使用技巧和注意事项，需要的朋友参考一下 本文详细讲述了windows消息和消息队列的原理与应用方法。分享给大家供大家参考。具体分析如下： 与基于MS - DOS的应用程序不同，Windows的应用程序是事件(消息)驱动的。它们不会显式地调用函数（如C运行时库调用）来获取输入，而是等待windows向它们

相关问答

Azure服务总线：队列上没有消息，只有请求Apache Camel在一个ActiveMQ实例上使用多个队列MyBatis没有Spring，事务使用提供的连接使用队列时的ActiveMQ“冻结”消息同一弹性跳闸应用程序的多个实例，但只有 1 个实例使用来自 ActiveMQ 队列的消息

相关文章

使用Hibernate作为提供程序的JPA 2.0-例外：EntityManager没有持久性提供程序消息队列的作用和使用场景PHP使用ActiveMQ实现消息队列的方法详解现实世界中使用JMS /消息队列？队列上有多重队列

相关阅读

Redis和RabbitMQ做消息队列的区别消息队列 RabbitMQ的介绍及安装使用标记的循环队列消息中间件 RabbitMQ 之 死信队列的介绍及实战Redis Stream 流的深度解析与实现高级消息队列

相关工具

ios所支持的所有字体获取网页的所有图片自动文字提示列表ZeroMQ实例程序首列固定的列表

相关文档

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