Safe Haskell	Safe-Inferred
Language	Haskell2010

Network.AMQP.Worker.Worker

Synopsis

worker :: (FromJSON a, MonadIO m, MonadCatch m) => Connection -> WorkerOptions -> Queue a -> (WorkerException SomeException -> m ()) -> (Message a -> m ()) -> m ()
data WorkerOptions = WorkerOptions {
- pollDelay :: Microseconds
- loopDelay :: Microseconds
}
data WorkerException e
- = MessageParseError ByteString String
- | OtherException ByteString e

Documentation

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

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 Source #

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

Instances details

Show WorkerOptions Source #
Instance details Defined in Network.AMQP.Worker.Worker Methods showsPrec :: Int -> WorkerOptions -> ShowS # show :: WorkerOptions -> String # showList :: [WorkerOptions] -> ShowS #
Default WorkerOptions Source #
Instance details Defined in Network.AMQP.Worker.Worker Methods def :: WorkerOptions #
Eq WorkerOptions Source #
Instance details Defined in Network.AMQP.Worker.Worker Methods (==) :: WorkerOptions -> WorkerOptions -> Bool # (/=) :: WorkerOptions -> WorkerOptions -> Bool #

data WorkerException e Source #

Exceptions created while processing

Constructors

MessageParseError ByteString String
OtherException ByteString e

Instances

Instances details

Exception e => Exception (WorkerException e) Source #
Instance details Defined in Network.AMQP.Worker.Worker Methods toException :: WorkerException e -> SomeException # fromException :: SomeException -> Maybe (WorkerException e) # displayException :: WorkerException e -> String #
Show e => Show (WorkerException e) Source #
Instance details Defined in Network.AMQP.Worker.Worker Methods showsPrec :: Int -> WorkerException e -> ShowS # show :: WorkerException e -> String # showList :: [WorkerException e] -> ShowS #
Eq e => Eq (WorkerException e) Source #
Instance details Defined in Network.AMQP.Worker.Worker Methods (==) :: WorkerException e -> WorkerException e -> Bool # (/=) :: WorkerException e -> WorkerException e -> Bool #