当前位置: 首页 > 知识库问答 >
问题:

Apache Camelendpoint注入直接路由“endpoint上没有可用的消费者”

司知
2023-03-14

我想使用Camel从ActiveMQ获取一条消息,然后根据消息内容(protobuf)向Twitter发送一条或多条消息。我编写了一个从路由内调用的bean,它使用注入将多条消息发送到“direct:xyz”endpoint。

2012-11-16 09:56:33,376 | WARN  | ication.twitter] | DirectProducer                   | 160 - org.apache.camel.camel-core - 2.10.2 | No consumers available on endpoint: Endpoint[direct://twitter] to process: Exchange[Message: hello world]
<camelContext id="NotificationTwitter"
    trace="false" xmlns="http://camel.apache.org/schema/blueprint">
    <dataFormats>
        <protobuf id="notificationProto" instanceClass="org.abc.schemas.protobuf.NotificationDef$NotificationMsg" />
    </dataFormats>

    <route id="TwitterPreparation">
        <from uri="activemq:notification.twitter" />
        <unmarshal ref="notificationProto" />
        <log logName="abc" loggingLevel="INFO"
            message="Twitter request received: ${body}" />
        <bean ref="NotificationTweeter" method="createTweets" />
    </route>

    <route id="Twitter">
        <from uri="direct:twitter" />
        <log logName="abc" loggingLevel="INFO"
            message="Tweeting: ${body}" />
        <to uri="twitter://timeline/user?consumerKey=itsasecret&amp;consumerSecret=itsasecret&amp;accessToken=itsasecret&amp;accessTokenSecret=itsasecret" />
    </route>
</camelContext>

这个豆子看起来像:-

public class NotificationTweeter {

  @EndpointInject(uri = "direct:twitter")
  private ProducerTemplate producerTemplate;

  public void createTweets(NotificationMsg notification) {

    String tweet = notification.getMessageDetail().getTitle();

    try {
      // only send tweets where the notification message contains the Twitter mechanism
      for (MechanismMsg mechanism : notification.getMechanismList()) {
        if (mechanism.getType() == MechanismTypeEnum.TWITTER) {

          // Cycle round the recipients
          for (RecipientMsg recipient : mechanism.getRecipientList()) {
            tweet = "@" + recipient.getIdentifier() + " " + tweet;

            producerTemplate.sendBody(tweet);
          }

          // TODO exceptions if no recipients found, etc
        }
      }
    } catch (Exception ex) {
      ex.printStackTrace();
    }
  }
}

我在其他路线上也遇到过这个问题(这肯定与Twitter功能无关),但刚刚解决了这个问题。然而,这一次,我想真正理解问题是什么!如有任何帮助,不胜感激,谢谢。

共有1个答案

鄢承运
2023-03-14

根据您的设置,它还可能取决于您所获得的CamelContext。我得到了相同的错误消息,因为我在另一个camelcontext路由中发送消息,而不是我实际使用的路由。

(尽管前面的答案已经被接受,但对于其他搜索错误消息的人来说,这可能是有效的解决方案。)

 类似资料:
  • 我是的新手,正在尝试使用组件。 我在这里简化了代码,但基本上我有一个参与者,它从endpoint使用。 因此,我尝试这种“直接”方法,但在endpoint:endpoint[direct://mycamelendpoint]上没有可用的消费者。Exchange[message:My test message]异常。 我在这里缺少什么配置?

  • 我是阿帕奇骆驼队的新手。我试图将一个交换从java方法发送到一个路由,但它给了我“由:org.apache.camel.component.direct.DirectConsumerNotAvailableException:endpoint上没有可用的消费者”错误。我想知道这个错误到底是什么,我们什么时候得到这个?

  • 我有一个驼峰endpoint,基本上是Kafka消费者从一个主题中读取信息并将其发送到数据库。它工作得很好,但是,我很难对它进行单元测试,因为我无法模拟Kafkaendpoint。有谁能帮我在骆驼路线上嘲笑Kafka的消费者吗?

  • null 订阅目标,不带选择器/筛选器 发送到目标,标题为clientId=ID(服务器将请求的客户端的ID) 客户123: 订阅目标,选择器clientId=123 发送到目标,标头clientId=123 Client123断开连接:删除多播地址和filter clientId=123的协同响应多播队列 服务器向客户端123的TaskRequest发送消息:根据服务器上的客户端,消息发送成功。

  • 消费者使用Spring的JavaConfig类如下: Kafka主题侦听器使用@KafkaListener注释,如下所示: 我的pom包括依赖项: 现在当我打包到war并部署到tomcat时,它不会显示任何错误,即使在调试模式下也不会显示任何错误,只是部署war什么都没有。 请帮助我了解是否缺少触发kafkalistner的某些配置。 谢谢Gary我添加了上下文。xml和web。xml,但我得到了