我想使用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&consumerSecret=itsasecret&accessToken=itsasecret&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功能无关),但刚刚解决了这个问题。然而,这一次,我想真正理解问题是什么!如有任何帮助,不胜感激,谢谢。
根据您的设置,它还可能取决于您所获得的CamelContext
。我得到了相同的错误消息,因为我在另一个camelcontext
路由中发送消息,而不是我实际使用的路由。
(尽管前面的答案已经被接受,但对于其他搜索错误消息的人来说,这可能是有效的解决方案。)
我是的新手,正在尝试使用组件。 我在这里简化了代码,但基本上我有一个参与者,它从endpoint使用。 因此,我尝试这种“直接”方法,但在endpoint:endpoint[direct://mycamelendpoint]上没有可用的消费者。Exchange[message:My test message]异常。 我在这里缺少什么配置?
我是阿帕奇骆驼队的新手。我试图将一个交换从java方法发送到一个路由,但它给了我“由:org.apache.camel.component.direct.DirectConsumerNotAvailableException:endpoint上没有可用的消费者”错误。我想知道这个错误到底是什么,我们什么时候得到这个?
null 这就是我的情况:
我有一个驼峰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,但我得到了