Akka Streams: Добавить поток, который выполняет и HTTP-запрос

Question

У меня есть источник потока Akka из очереди сообщений, например RabbitMq.Для каждого сообщения, которое я хочу выполнить, запрос http, сопоставьте запрос http с объектом и продолжайте работу вниз.

Возможно ли это с помощью потока из akka http (Http (). OutgoingConnection) или если запросбыть выполненным внутри операции карты?

Answer 1

Это именно то, для чего используется Http().outgoingConnection (как упоминалось в вопросе):

type MQMessage = ???

val messageToRequest : (MQMessage) => HttpRequest = ???

type ObjectType = ???

val responseToObjectType = (HttpResponse) => ObjectType = ???

val httpHost : String = ???

val messageFlow : Flow[MQMessage, ObjectType, _] = 
  Flow.map(messageToRequest)
      .via(Http().outgoingConnection(httpHost))
      .map(responseToObjectType)