Network.AMQP.Worker.Worker

Documentation

worker :: (FromJSON a, MonadIO m, MonadCatch m) => Connection -> WorkerOptions -> Queue a -> (WorkerException SomeException -> m ()) -> (Message a -> m ()) -> m ()

Create a worker which loops, checks for messages, and handles errors

startWorker conn queue = do
  Worker.worker conn def queue onError onMessage

  where
    onMessage :: Message User
    onMessage m = do
      putStrLn "handle user message"
      print (value m)

    onError :: WorkerException SomeException -> IO ()
    onError e = do
      putStrLn "Do something with errors"

data WorkerOptions

Options for worker

Constructors

WorkerOptions

Fields

• pollDelay :: Microseconds

  Delay between checks to consume. Defaults to 10ms

• loopDelay :: Microseconds

  Delay between calls to job. Defaults to 0

Instances

Eq WorkerOptions

Defined in Network.AMQP.Worker.Worker

Methods

(==) :: WorkerOptions -> WorkerOptions -> Bool

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

Show WorkerOptions

Defined in Network.AMQP.Worker.Worker

Methods

showsPrec :: Int -> WorkerOptions -> ShowS

show :: WorkerOptions -> String

showList :: [WorkerOptions] -> ShowS

Default WorkerOptions

Defined in Network.AMQP.Worker.Worker

Methods

def :: WorkerOptions

data WorkerException e

Exceptions created while processing

Constructors

MessageParseError ByteString String

OtherException ByteString e

Instances

Eq e => Eq (WorkerException e)

Defined in Network.AMQP.Worker.Worker

Methods

(==) :: WorkerException e -> WorkerException e -> Bool

(/=) :: WorkerException e -> WorkerException e -> Bool

Show e => Show (WorkerException e)

Defined in Network.AMQP.Worker.Worker

Methods

showsPrec :: Int -> WorkerException e -> ShowS

show :: WorkerException e -> String

showList :: [WorkerException e] -> ShowS

Exception e => Exception (WorkerException e)

Defined in Network.AMQP.Worker.Worker

Methods

toException :: WorkerException e -> SomeException

fromException :: SomeException -> Maybe (WorkerException e)

displayException :: WorkerException e -> String