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 Scala Camel. Обработка исключений

У меня есть akka camel-ftp потребитель. Я хотел бы обрабатывать все исключения в коде (например, Authentification Exception или файл на ftp не может быть прочитан). Я вижу только стек из таблицы и не

0зной

2ответ

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

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

4зной

1ответ

Apache camel: подключение к серверу ZeroMQ

Я пытаюсь подключиться к серверу ZeroMQ с использованием apache camel. Я использую компонент camel-zeromq, предоставляемый проектом camel-extra, но, похоже, для этого требуется предыдущая установка вс

0зной

1ответ

Как использовать значение заголовка внутри атрибута XML с помощью Apache Camel?

У меня есть следующий маршрут верблюда, но, похоже, он не получил значение заголовка. Правильно ли это? <to uri="ahc:http://${header.freeNasServerIp}:80/api/v1.0/storage/volume/"/>

0зной

1ответ

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

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

0зной

2ответ

Потребительские товары/Производитель AWS SQS akka scala с потребителем синхронных товаров

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

1зной

1ответ

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

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