Проверьте, успешно ли маршрутизировано сообщение rabbitMQ. - PullRequest
Новая
       8

Проверьте, успешно ли маршрутизировано сообщение rabbitMQ.

0 голосов
/ 07 декабря 2018

Я использую akka-stream-alpakka-amqp для публикации сообщений на rabbitmq exchange, я хочу знать, есть ли способ определить, правильно ли message направлен в очередь с akka-streams, в данный момент в ответ я получаю статус http200 независимо от того, маршрутизируется сообщение или нет

пример создания сообщения 

val headers = new java.util.HashMap[String, AnyRef]()
headers.put("hash-on", hashOn)
headers.put("message-type", messageType)
val basicProps = new BasicProperties().builder().headers(headers).build()

OutgoingMessage(
  bytes = ByteString(body),
  immediate = false,
  mandatory = false)
  .withProperties(basicProps)


Source.single(outgoingMessage).runWith(sink)
...