akka-camel

2зной

1ответ

Akka Streams, исходные элементы как еще один источник?

Я использую Alpakka-FTP, но, возможно, я ищу общий шаблон акка-потока. Соединитель FTP можно просмотреть список файлов или получить их: def ls(host: String): Source[FtpFile, NotUsed] def fromPath(hos

1зной

1ответ

Как работает компонент Camel Jetty в Акке?

В следующем примере (взятом из Akka Camel doc) HTTP-компонент Jetty используется для приема сообщений HTTP. Означает ли это, что актер запускает новый сервер Jetty? import akka.camel.{ CamelMessage, C

0зной

1ответ

Akka Camel и ActiveMQ: Как установить режим доставки

Как мне известно, ActiveMQ устанавливает режим доставки по умолчанию PERSISTENT ... так как установить режим доставки на NON_PERSISTENT по конкретной теме при использовании Akka-Camel? Здесь ниже мой

0зной

2ответ

Akka Camel: Сообщения, направляемые к неправильному маршруту SEDA

Мой упрощенный Akka Camel приложение устанавливается следующим образом: AppleProducer -> seda:appleRoute -> AppleConsumer OrangeProducer -> seda:orangeRoute -> OrangeConsumer Что я вижу, хотя в то

0зной

1ответ

Доступ к Twitter с Akka Camel для возврата JSON

Я использовал HTTP POST-метод, используя URL-адрес «https://stream.twitter.com/1.1/statuses/filter.json», и в теле я отправлял ключ/значение, на которое я хотел получить твиты, например, «track = lond

1зной

1ответ

Проверить статус подключения очереди сообщений в Apache Camel

Я использую Apache Camel в Акке, и я пытаюсь проверить с заданными интервалами, каков статус очереди сообщений. Я вижу, что очередь периодически регистрирует свой статус, но я хотел бы программно выпо