Automorph
API
Generated with
Automorph/automorph/automorph.transport/automorph.transport.amqp/automorph.transport.amqp.client

automorph.transport.amqp.client

package automorph.transport.amqp.client

Members list

Type members

Classlikes

final case class RabbitMqClient[Effect[_]](effectSystem: AsyncEffectSystem[Effect], url: URI, routingKey: String, exchange: String, addresses: Seq[Address], connectionFactory: ConnectionFactory) extends ClientTransport[Effect, Context]

RabbitMQ client message transport plugin.

RabbitMQ client message transport plugin.

Uses the supplied RPC request as AMQP request message body and returns AMQP response message body as a result.

  • AMQP request messages are published to the specified exchange using direct reply-tomechanism.
  • AMQP response messages are consumed using direct reply-tomechanism and automatically acknowledged.

Type parameters

Effect

effect type

Value parameters

addresses

broker hostnames and ports for reconnection attempts

connectionFactory

AMQP broker connection factory

effectSystem

effect system plugin

exchange

direct non-durable AMQP message exchange name

routingKey

AMQP routing key (typically a queue name)

url

AMQP broker URL (amqp[s]://[username:password@]host[:port][/virtual_host])

Attributes

Constructor

Creates a RabbitMQ client message transport plugin.

See also
Companion
object
Supertypes
trait Serializable
trait Product
trait Equals
trait ClientTransport[Effect, Context]
class Object
trait Matchable
class Any
Show all
object RabbitMqClient

Attributes

Companion
class
Supertypes
trait Product
trait Mirror
class Object
trait Matchable
class Any
Self type
Generated with