文章/答案/技术大牛

发布

社区首页 >问答首页 >在骆驼中每小时不超过一条信息？

问在骆驼中每小时不超过一条信息？
EN

Stack Overflow用户

提问于 2013-10-18 16:02:26

回答 1查看 542关注 0票数 0

我对骆驼有点陌生，所以如果这是个愚蠢的问题，请原谅我！

在“骆驼”一书中，我列出了与队列queue-1相竞争的消费者名单。我希望每个使用者在试图读取队列之间等待1小时，但是一旦一个小时过去，每个使用者都应该持续轮询，直到收到消息为止。一旦它收到一条消息，它应该处理它，然后等待一个小时后再尝试另一次读取，依此类推。

这是我设置的路线：

from("aws-sqs://queue-1?accessKey=ABC&secretKey=XYZ&maxMessagesPerPoll=1")
    .unmarshal().base64()
    .unmarshal().serialization()
    .throttle(1)
    .timePeriodMillis(TimeUnit.HOUR.toMillis(1))
    .bean(new ProcessorBean())
    .marshal().serialization()
    .marshal().base64()
    .to("aws-sqs://queue-2?accessKey=ABC&secretKey=XYZ");

据我理解，路由是同步执行的(设计为异步工作的特定组件除外)。基于这一理解，我认为这条路线符合这些要求。

这能做我想做的吗？为什么或者为什么不？

java

apache-camel

amazon-sqs

回答 1

Stack Overflow用户

回答已采纳

发布于 2013-10-21 08:59:39

您的路由将在队列中使用一条消息，然后等待一个小时。

如果您想要等待一个小时，然后读取消息，请查看ScheduledPollConsumer Options (医生)某些选项允许使用调度器，如基于Quartz2或基于Spring的调度程序。

如果您想要确定：日志组件，请使用.to("log:com.mycompany.order?level=DEBUG")组件。

票数 2

页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持

原文链接：

https://stackoverflow.com/questions/19454043

复制

相似问题

问在骆驼中每小时不超过一条信息？
EN

回答 1

Stack Overflow用户

社区

活动

圈层

关于

腾讯云开发者

热门产品

热门推荐

更多推荐

问在骆驼中每小时不超过一条信息？EN

回答 1

Stack Overflow用户

社区

活动

圈层

关于

腾讯云开发者

热门产品

热门推荐

更多推荐

问在骆驼中每小时不超过一条信息？
EN