问题标签 [alpakka]

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

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

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

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

编辑：

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

我在使用 Alpakka AMQP 连接器和 Akka Streams 时遇到了一个非常奇怪的问题。

当我的 RabbitMQ 消息代理重新启动时，源似乎重新启动正常。但是，一旦重新启动，流永远不会完成，并且消息会丢失在流中更远的分区中。当我启动 AMQP 服务器时，我的 Akka 应用程序运行良好，但反过来一切都搞砸了。

这是我初始化我的方式AMQPSource：

我试图删除发生问题的分区，将流直接发送到与我的示例相关的流，这甚至更奇怪：在这种情况下，AMQP 客户端甚至不再从 RabbitMQ 读取消息。

我显然在这里遗漏了一些东西，但我尝试了很多不同的东西，但根本没有解决我的问题。

使用 Alpakka，我们可以使用以下代码为任何主题创建非持久订阅者：

有谁知道如何使这个主题订阅者持久？

我想在现有交换中创建一个队列以供阅读。

另一个应用程序正在向此交换发布消息并将它们散播到所有成员队列。我希望我的新应用程序成为这些消息的额外订阅者。

下面创建一个队列：

这为交换创建了一个接收器

但我不确定如何将它们一起使用，如果这是正确的方法。

我使用 alpakka(Scala) 和 JMS 连接器在客户端和服务器之间发送/接收消息。一切工作完美，但我不知道 - 我如何在 jms.Message 中设置相关性 ID 作为响应。请有任何想法。谢谢你。

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

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

我正在使用 Java 实现 Akka Alpakka，以便从 ActiveMQ 队列中消费和生产。我可以成功地从队列中消费，但我还不能实现应用程序级的消息确认。

我的目标是使用队列中的消息并将它们发送给另一个参与者进行处理。当该参与者完成处理后，我希望它能够控制 ActiveMQ 中消息的确认。据推测，这可以通过向另一个可以进行确认的参与者发送消息、在消息本身上调用确认函数或其他方式来完成。

在我的测试中，有 2 条消息被放入 AlpakkaTest 队列，然后这段代码尝试消费并确认它们。但是，我看不到将 ActiveMQ 会话设置为 CLIENT_ACKNOWLEDGE 的方法，并且无论是否调用m.acknowledge();. 因此，我认为消息仍在被自动确认。

有谁知道为 CLIENT_ACKNOWLEDGE 配置 ActiveMQ 会话并使用 Alpakka 在 Java Akka 系统中手动确认 ActiveMQ 消息的公认方法？

相关的测试函数为：

此代码打印：

嗨，我使用 datastax 驱动程序创建了自己的 Cassandra 连接器。但是我面临一些内存泄漏问题，所以我开始考虑另一种解决方案，例如具有 Cassandra 连接器的 Alpakka de lightbend。

但是在检查了糟糕的文档之后，我改变了主意，因为它只是将连接器与 CQLSH 查询一起使用，在我的情况下，我管理 DTO 对象。

任何人都知道任何文档，我可以在其中查看 Alpakka cassandra 是否以一致性级别管理 DTO 的保存？

此代码来自我当前的连接器。我想实现类似的东西。

我使用 Play Framework 2.6 (Scala) 和 Alpakka AWS S3 连接器将文件异步上传到 S3 存储桶。我的代码如下所示：

它可以工作，但它会在上传到 S3 之前返回文件名。但我想在它上传到 S3 后返回值。有什么解决办法吗？

此外，是否可以将文件上传直接流式传输到 S3，以正确显示进度并且不使用临时磁盘文件？

我使用 Alpakka Cassandra 库编写了这个简单的应用程序

此应用程序完全按预期运行，它在屏幕上打印 10 行。

但是发布它挂起。调用执行时System.exit(0)会抛出异常

但应用程序仍然没有停止运行。它只是挂起。

我不明白为什么这个应用程序不能正常终止（实际上它甚至不需要 system.exit(0) 调用。

退出此应用程序的唯一方法是通过控件 C。