Описание тега akka-camel
Модуль akka-camel позволяет нетипизированным субъектам получать и отправлять сообщения по большому количеству протоколов и API. В дополнение к нативному API-интерфейсу Scala и Java актеры теперь могут обмениваться сообщениями с другими системами по большому количеству протоколов и API-интерфейсов, таких как HTTP, SOAP, TCP, FTP, SMTP или JMS. На данный момент поддерживается около 80 протоколов и API.
1
ответ
Как использовать значение заголовка внутри атрибута XML с помощью Apache Camel?
У меня есть следующее на верблюжьем маршруте, но, похоже, значение заголовка не получается. Это правильный способ сделать это? <to uri="ahc:http://${header.freeNasServerIp}:80/api/v1.0/storage/volume/"/>
18 авг '15 в 07:53
1
ответ
Akka Camel RabbitMQ Создание новых подключений каждый раз
Я использую akka-верблюда, чтобы подписаться на обмен rabbitmq. Будет создано несколько таких актеров... по одному на каждый routingKey, Обмен и очередь не меняются. Каждый раз новый routingKey запрашивается создание нового действующего лица, и вмес…
15 май '15 в 03:24
1
ответ
Получив доступ к Twitter с помощью Akka Camel, вы получите JSON
Я использовал метод HTTP POST, используя URL-адрес " https://stream.twitter.com/1.1/statuses/filter.json", и в теле я публиковал ключ / значение, от которого я хотел получить твиты - например " трек = лондон". Это работало нормально. Сейчас я пытаюс…
17 фев '17 в 19:09
1
ответ
Как компонент Camel Jetty работает в Akka?
В следующем примере (взятом из документа Akka Camel) HTTP-компонент Jetty используется для получения HTTP-сообщений. Означает ли это, что актер запускает новый сервер Jetty? import akka.camel.{ CamelMessage, Consumer } class MyEndpoint extends Consu…
29 авг '16 в 20:44
1
ответ
Akka Camel и ActiveMQ: как установить режим доставки
Насколько я знаю, ActiveMQ устанавливает режим доставки на PERSISTENT по умолчанию... так как мне установить режим доставки на NON_PERSISTENT для конкретной темы при использовании Akka-Camel? Здесь ниже мой пример кода: import akka.actor._ import ak…
26 сен '15 в 12:11
1
ответ
Проверьте состояние подключения очереди сообщений в Apache Camel
Я использую Apache Camel в Akka и пытаюсь через определенные промежутки времени проверять состояние очереди сообщений.Я вижу, что очередь периодически регистрирует свое состояние, но я бы хотел, чтобы программно можно было выполнить эту проверку.
12 янв '17 в 04:19
0
ответов
Актер не существует
Я хочу создать актера верблюжьего акка, который будет использовать сервер MQTT. Но когда я получаю сообщение от сервера MQTT, он выдает ошибку и сообщает, что актер не существует. Мой актер public class GetListener extends UntypedConsumerActor{ priv…
15 мар '17 в 16:59
1
ответ
Apache Camel: подключение к серверу ZeroMQ
Я пытаюсь подключиться к ZeroMQ сервер, использующий apache camel, Я использую camel-zeromq компонент, предоставленный camel-extra проект, но кажется, что для этого требуется предыдущая установка родного ZeroMQ библиотека в системе. Кто-нибудь знает…
02 мар '16 в 17:05
1
ответ
Верблюд-акка и ответ от актера
Уважаемые Акка /Camel Masters! У меня есть следующий маршрут: (netty4: tcp) -> (акка: актер) Я использую модуль Акка-верблюд, где: akka: actor имеет тип UntypedConsumerActor netty4:tcp является конечной точкой, определенной в методе getEndopointUri …
07 ноя '16 в 10:59
0
ответов
Apache Camel неверный ответ JSON - UTF8
У меня есть эта конфигурация для службы Apache Camel Rest: <route id="RouteWebAutorizacion"> <from uri="jetty:http://{{web.host}}:{{web.port}}/autorizacion"/> <convertBodyTo type="java.lang.String" charset="UTF-8"/> <removeHeade…
06 апр '18 в 20:18
0
ответов
Как потреблять агрегированный обмен в apache camel с streamz dsl
Я пытаюсь использовать верблюд, чтобы найти последний файл, доступный в конечной точке в файловой системе только для чтения, и использовать его. Так как у меня есть приложение, основанное на akka streams, и поэтому я решил использовать библиотеку st…
07 сен '18 в 11:20
1
ответ
Явное подтверждение JMS с использованием Alpakka
Я сейчас пользуюсь Akka-Camel для интеграции моего приложения на основе Akka с различными очередями сообщений.Теперь, когда я хочу перейти на последнюю версию Akka, я вижу, что эта интеграция устарела. Я пытался использовать alpakka-jsm интеграция, …
31 июл '17 в 09:50
0
ответов
Двусторонняя связь (спросить или рассказать)?
Документация Акка для Java говорит http://doc.akka.io/docs/akka/2.4/java/camel.html Двусторонняя связь между конечной точкой Camel и субъектом инициируется отправкой сообщения запроса субъекту с шаблоном запроса, и субъект отвечает на конечную точку…
26 ноя '16 в 22:47
2
ответа
Тайм-аут встроенного Jetty под нагрузкой
У меня есть приложение akka (Java) с потребителем Camel-Jetty. При некоторой минимальной нагрузке (около 10 TPS) наш клиент начинает видеть ошибку HTTP 503. Я попытался воспроизвести проблему в нашей лаборатории, и похоже, что Jetty не может справит…
23 июл '15 в 18:31
2
ответа
Akka Camel: сообщения перенаправлены на неверный маршрут SEDA
Мой упрощенный Akka Camel Приложение настроено следующим образом: AppleProducer -> seda:appleRoute -> AppleConsumer OrangeProducer -> seda:orangeRoute -> OrangeConsumer Я вижу только то, что Apple события периодически потребляются Orange…
03 июн '16 в 19:50
1
ответ
Акка Верблюд несколько потребителей
Я использую akka + camel для получения сообщения от activemq, и я пытаюсь выяснить, как развернуть этот потребитель на нескольких машинах без дублирования сообщения. В этом случае я использую сообщение из темы, и activemq должен знать, что у меня од…
01 июл '15 в 20:23
1
ответ
Camel, Akka, JMS и отложенное подтверждение сообщения: могу ли я подтвердить ранее обработанное сообщение брокеру?
Я использую Akka (последняя стабильная версия), akka-camel и JMS (для целей этого разговора, скажем, это ActiveMQ, но в идеале решение должно быть общим). Вариант использования У меня есть следующий вариант использования. В очереди Q Я получаю сообщ…
24 мар '16 в 09:53
1
ответ
Не удалось найти конечную точку для: test, пожалуйста, проверьте, что ваш classpath содержит необходимый jar компонента Camel
Я пытаюсь отправлять и получать сообщения, используя akka-camel и создал пример для производителя и потребителя, как показано ниже: Режиссер: import akka.actor.{Actor, ActorSystem, Props} import akka.camel.Producer class CamelJmsProducer extends Act…
07 дек '17 в 08:41
0
ответов
Apache Camel doTry doCatch не ловит исключение акка верблюда
Мы используем XML DSL с Akka Camel (2.5.13) и обнаружили, что когда верблюд указывает на боб, который отвечает с исключением, он не пойман верблюдом. Наш код Scala: private def replyError(exception: ChannelException) { log.error(exception.error) sen…
13 авг '18 в 14:31
0
ответов
Отключение JMX с помощью application.conf выдает ошибку
У нас проблема с отключением JMX. Я использую Akka-Camel и Spring XML. В нашем application.conf у нас есть следующее: akka.camel { jmx = off context-provider = "com.mycompany.myapp.CamelContextProvider" } Затем мы получаем сообщение о том, что jmx н…
27 сен '18 в 16:11