问题标签 [akka-camel]

我的应用程序有一个生产者和一个消费者。我的制作人不定期地生成消息。有时我的队列会是空的，有时我会有一些消息。我想让我的消费者听队列，当有消息时，接受它并处理这个消息。这个过程可能需要几个小时，如果我的消费者没有完成对当前消息的处理，我不希望我的消费者从队列中获取另一条消息。

我认为 AKKA 和 AWS SQS 可以满足我的需求。通过阅读文档和示例，akka-camel 似乎可以简化我的工作。

我在 github 上找到了这个例子。

我对消费者的配置更感兴趣（Thread.sleep 只是为了模拟我的处理）：

堆栈跟踪 ：

我的问题是 akka-camel 在接收方法完成之前从队列中读取消息。

如何让我的消费者在接收新消息之前等待流程结束？如果我使用了错误的工具/库，你能指导我使用新工具吗？

在以下示例中（取自Akka Camel 文档），Jetty HTTP 组件用于接收 HTTP 消息。这是否意味着演员启动了一个新的 Jetty 服务器？

亲爱的阿卡/骆驼大师！

我有以下路线：

(netty4:tcp) -> (别名:actor)

我正在使用 akka-camel 模块，其中：

akka:actor 的类型是 UntypedConsumerActor netty4:tcp 是在 akka:actor 的 getEndopointUri 方法中定义的端点

当我向 tcp 套接字发送字节时，我收到异常，告诉套接字通道已关闭：

我究竟做错了什么？

java的akka​​文档说

http://doc.akka.io/docs/akka/2.4/java/camel.html#Consumer_timeout

Camel 端点和参与者之间的双向通信是通过向参与者发送带有询问模式的请求消息来启动的，并且当响应准备好时参与者回复端点。

接着

http://doc.akka.io/docs/akka/2.4/java/camel.html#Asynchronous_routing

消费者端点使用tell方法向其消费者参与者发送请求消息，参与者使用 getSender() 返回响应。一旦他们准备好了就告诉。

两种说法中哪一种是正确的？ 它是否依赖于骆驼组件？

如果使用tell方法，端点如何知道哪个客户端响应？

谢谢。

我在 Akka 中使用 Apache Camel，并尝试以给定的时间间隔检查消息队列的状态。
我看到队列定期记录其状态，但我希望能够以编程方式进行此检查。

我正在使用Alpakka-FTP，但也许我正在寻找一般的 akka-stream 模式。FTP 连接器可以列出文件或检索它们：

理想情况下，我想创建一个这样的流：

但是我无法使用上面编写的两个函数创建这样的流。我觉得我应该能够使用 a 到达那里Flow，例如

ls仅考虑上面的和fromPath功能，这可能吗？

编辑：

我可以使用一个演员和 来解决这个问题mapAsync，但我仍然觉得它应该更直接。

我正在使用使用 URL“ https://stream.twitter.com/1.1/statuses/filter.json ”的 HTTP POST 方法，并且在正文中我发布了我想从中获取推文的键/值 - 例如“轨道=伦敦”。这工作正常。

现在我正在尝试切换到 AKKA-CAMEL，并且正在使用他们的 Twitter 消费者。我正在使用以下端点 URL：

我收到了来自 twitter 的回复，但它不是 JSON 格式的，而且它与之前的推文信息不同。它只是返回推文文本，但在我获得需要分析的整个元数据之前。

有人知道如何配置 Camel URI 以像以前一样返回 JSON 和整个元数据吗？

谢谢

I want to create a camel akka actor, it will consume from a MQTT server. But when I recive a message from the MQTT server it throws an error and tell me thant the actor doesn't exist.

My actor

My main class

The error:

Where I have to register the actor to catch correctly the message?

我遵循了 Camel in action 一书中的一个例子。如何编组和解组 csv 数据格式。但是，我想用（逗号分隔的分隔符）和拆分正文解组一个 csv 文件。然后，我将.choice根据需要的任务使用基于内容来分发消息。事实上，第一个简单的例子对我不起作用。我使用了camel 2.15.6（camel-core、camel-context、camel-csv、commons-csv）和java 7。

请在堆栈跟踪下方找到。

我目前Akka-Camel用于将基于 Akka 的应用程序与各种消息队列集成。
现在我想升级到最新版本的 Akka，我发现这个集成现在已经被弃用了。

我曾尝试使用alpakka-jsm集成，但无法查看在处理完消息后是否可以ack对消息队列显式执行。这个新组件中是否存在此功能？