如何恢复一个暂停骆驼消费者
-
null
共有1个答案
在挂起使用者之前，可以创建一个虚拟文件。
使用过滤器对虚拟文件进行另一次路由轮询，以检查它是否是在30分钟前创建的。类似于：
from("file:dummyLocation?include=.dummy&delete=true&filter=#filterFileOlderThanThirtyMins)
.to("controlbus:route?routeId=suspendedRoute&action=start")
不过，这只是我的头绪！
-
嗨，我在camel中有一个JMS消费者路由，我的要求是在特定事件时停止/暂停该路由(基于某个字段值)，然后使用调度器恢复该路由。为此，我创建了两个路由，一个是我的原始jms消费者路由，另一个是调度程序路由，它们恢复jms消费者路由，虽然我能够暂停路由，但第二个路由不恢复暂停的路由，它显示的状态为已启动。 以下是我的两条路线 请帮助我如何实现上述场景。
-
我正在使用这个库来实现节点kafka与消费者暂停和恢复方法来处理背压。我已经创建了一个小演示，我可以在其中和，但问题是在后它停止了消费消息。 这是我的代码。 任何人都可以帮助我，我在恢复消费者时做错了什么？当我启动使用者时，它只接收一条消息，并且在恢复后仍然不消耗任何其他消息。
-
我有一个Spring靴Kafka消费者 为了避免重新平衡，我尝试在KafkaContainer上调用pause（）和resume（），但消费者总是在运行 我错过了什么吗？有人能指导我如何正确地达到要求的行为吗？
-
问题内容： 我在viewDidAppear中有一个图像，并用以下代码对其进行了动画处理： 我想在点击时暂停动画，如果再次点击它则继续播放动画。 问题答案： 暂停和恢复动画的2个功能，我从这里开始转换为Swift。 我有一个按钮可以暂停或恢复在中初始化的动画：
-
我已经和ApacheCamel合作了一段时间，做了一些基本的工作，但现在我正在尝试创建一个路由，在该路由中，我可以让多个“消费者”访问同一条路由，或者在路由中添加一个消费者，然后处理消息。 我的想法是拥有一个由事件触发的事件驱动消费者，然后例如从ftp读取文件。我正计划做这样的事情： 所以这个想法是我有一个事件（例如直接或来自消息队列），它具有“fileName”属性，然后使用该属性从ftp下载/
-
我有一个场景，我想“拉”RabbitMQ队列/主题的消息，并一次处理一个。特别是当消费者启动时，队列中已经有消息。我尝试了以下方法，但没有成功（这意味着，这些选项中的每一个都会读取队列，直到队列为空，或者直到另一个线程关闭上下文）。 1.第一次处理后立即停止路由 与1类似，但使用闩锁而不是while loop和sleep。 使用轮询消费者 使用ConsumerTemplate（）-类似于上面的代码