Я использовал alpakka (Scala) и коннектор JMS для отправки/получения сообщений между клиентом и сервером. Все работает отлично, но я не знаю - как я могу установить в jms.Message в ответ корреляцию Id. Любая идея, пожалуйста. Спасибо.

Я пытаюсь реализовать очень простой сервис, подключенный к брокеру AMQP с помощью Alpakka. Я просто хочу, чтобы он потреблял сообщения из своей очереди в виде потока в тот момент, когда они отправляются на заданный обмен/тему. В моих тестах все...

Я новичок в scala, использую клиент alpakka-elasticsearch для выполнения запроса с эластичным поиском. Одиночный поисковый запрос отлично работает с двумя способами, которые внутренне вызывают _search url эластичного поиска: val...

У меня есть источник AMQP и приемник AMQP с объявлениями: List<Declaration> declarations = new ArrayList<Declaration>() {{ add(QueueDeclaration.create(sourceExchangeName)); add(BindingDeclaration.create(sourceExchangeName,...

Я пытаюсь передать результаты запроса с помощью Slick в приложении Java, используя Akka Streams и Postgres: Source mySource = Slick.source( slickSession, "SELECT * from message where started_instant is null",...

Я делаю то, что считаю очень простой вещью, чтобы проверить, работает ли alpakka: val awsCreds = AwsBasicCredentials.create("xxx", "xxx") val credentialsProvider = StaticCredentialsProvider.create(awsCreds) implicit val...