RabbitMQ

pillars.rabbitmq.fs2.RabbitMQ
See theRabbitMQ companion object
final case class RabbitMQ[F[_]](config: RabbitMQConfig, client: RabbitClient[F])(implicit evidence$1: Async[F]) extends Module[F]

Attributes

Companion
object
Source
rabbitmq.scala
Graph
Supertypes
trait Serializable
trait Product
trait Equals
trait Module[F]
class Object
trait Matchable
class Any
Show all

Members list

Type members

Types

override type ModuleConfig = RabbitMQConfig

Attributes

Source
rabbitmq.scala

Value members

Concrete methods

override def probes: List[Probe[F]]

Attributes

Definition Classes
Source
rabbitmq.scala

Inherited methods

Attributes

Inherited from:
Module
Source
modules.scala

Attributes

Inherited from:
Product

Attributes

Inherited from:
Product

Exports

Defined exports

val binding: Binding[RabbitClient.this.F]
Exported from RabbitClient

Attributes

Source
RabbitClient.scala
val connection: ConnectionResource[RabbitClient.this.F]
Exported from RabbitClient

Attributes

Source
RabbitClient.scala
val consumingProgram: AckConsumingProgram[RabbitClient.this.F]
Exported from RabbitClient

Attributes

Source
RabbitClient.scala
def createBasicPublisher[A](implicit channel: AMQPChannel, encoder: MessageEncoder[RabbitClient.this.F, A]): RabbitClient.this.F[(ExchangeName, RoutingKey, A) => RabbitClient.this.F[Unit]]
Exported from RabbitClient

Attributes

Source
RabbitClient.scala
def createConnection: Resource[RabbitClient.this.F, AMQPConnection]
Exported from RabbitClient

Attributes

Source
RabbitClient.scala
def createConnectionChannel: Resource[RabbitClient.this.F, AMQPChannel]
Exported from RabbitClient

Attributes

Source
RabbitClient.scala
val declaration: Declaration[RabbitClient.this.F]
Exported from RabbitClient

Attributes

Source
RabbitClient.scala
val deletion: Deletion[RabbitClient.this.F]
Exported from RabbitClient

Attributes

Source
RabbitClient.scala
val publishingProgram: PublishingProgram[RabbitClient.this.F]
Exported from RabbitClient

Attributes

Source
RabbitClient.scala