Network.AMQP.Worker.Queue

Documentation

type QueueName = Text

newtype QueuePrefix

Constructors

QueuePrefix Text

Instances

IsString QueuePrefix

Defined in Network.AMQP.Worker.Queue

Methods

fromString :: String -> QueuePrefix

Show QueuePrefix

Defined in Network.AMQP.Worker.Queue

Methods

showsPrec :: Int -> QueuePrefix -> ShowS

show :: QueuePrefix -> String

showList :: [QueuePrefix] -> ShowS

Default QueuePrefix

Defined in Network.AMQP.Worker.Queue

Methods

def :: QueuePrefix

Eq QueuePrefix

Defined in Network.AMQP.Worker.Queue

Methods

(==) :: QueuePrefix -> QueuePrefix -> Bool

(/=) :: QueuePrefix -> QueuePrefix -> Bool

data Queue msg

A queue is an inbox for messages to be delivered

Constructors

Queue (Key Binding msg) QueueName

Instances

Show (Queue msg)

Defined in Network.AMQP.Worker.Queue

Methods

showsPrec :: Int -> Queue msg -> ShowS

show :: Queue msg -> String

showList :: [Queue msg] -> ShowS

Eq (Queue msg)

Defined in Network.AMQP.Worker.Queue

Methods

(==) :: Queue msg -> Queue msg -> Bool

(/=) :: Queue msg -> Queue msg -> Bool

queue :: MonadIO m => Connection -> QueuePrefix -> Key a msg -> m (Queue msg)

Create a queue to receive messages matching the Key with a name prefixed via queueName.

q <- Worker.queue conn "main" $ key "messages" & any1
Worker.worker conn def q onError onMessage

queueNamed :: MonadIO m => Connection -> QueueName -> Key a msg -> m (Queue msg)

Create a queue to receive messages matching the binding key. Each queue with a unique name will be delivered a separate copy of the messsage. Workers operating on the same queue, or on queues with the same name will load balance

queueName :: QueuePrefix -> Key a msg -> QueueName

Name a queue with a prefix and the binding key name. Useful for seeing at a glance which queues are receiving which messages

-- "main messages.new"
queueName "main" (key "messages" & word "new")

bindQueue :: MonadIO m => Connection -> Queue msg -> m ()

Queues must be bound before you publish messages to them, or the messages will not be saved. Use queue or queueNamed instead