Safe Haskell	Safe-Inferred
Language	GHC2021

Network.AMQP.Extended

Synopsis

data RabbitMqHooks m = RabbitMqHooks {
- onNewChannel :: Channel -> m ()
- onConnectionClose :: m ()
- onChannelException :: SomeException -> m ()
}
data RabbitMqAdminOpts = RabbitMqAdminOpts {
- host :: !String
- port :: !Int
- vHost :: !Text
- tls :: Maybe RabbitMqTlsOpts
- adminPort :: !Int
}
data AmqpEndpoint = AmqpEndpoint {
- host :: !String
- port :: !Int
- vHost :: !Text
- tls :: !(Maybe RabbitMqTlsOpts)
}
openConnectionWithRetries :: forall m. (MonadIO m, MonadMask m, MonadBaseControl IO m) => Logger -> AmqpEndpoint -> RabbitMqHooks m -> m ()
mkRabbitMqAdminClientEnv :: RabbitMqAdminOpts -> IO (AdminAPI (AsClientT IO))
mkRabbitMqChannelMVar :: Logger -> AmqpEndpoint -> IO (MVar Channel)
demoteOpts :: RabbitMqAdminOpts -> AmqpEndpoint
data RabbitMqTlsOpts = RabbitMqTlsOpts {
- caCert :: !(Maybe FilePath)
- insecureSkipVerifyTls :: Bool
}

Documentation

data RabbitMqHooks m Source #

Constructors

RabbitMqHooks

Fields

onNewChannel :: Channel -> m ()
Called whenever there is a new channel. At any time there should be at max 1 open channel. Perhaps this would need to change in future.
onConnectionClose :: m ()
Called when connection is closed. Any exceptions thrown by this would be logged and ignored.
onChannelException :: SomeException -> m ()
Called when the channel is closed. Any exceptions thrown by this would be logged and ignored.

data RabbitMqAdminOpts Source #

Constructors

RabbitMqAdminOpts
Fields host :: !String port :: !Int vHost :: !Text tls :: Maybe RabbitMqTlsOpts adminPort :: !Int

Instances

Instances details

FromJSON RabbitMqAdminOpts Source #
Instance details Defined in Network.AMQP.Extended Methods parseJSON :: Value -> Parser RabbitMqAdminOpts Source # parseJSONList :: Value -> Parser [RabbitMqAdminOpts] Source #
Show RabbitMqAdminOpts Source #
Instance details Defined in Network.AMQP.Extended Methods showsPrec :: Int -> RabbitMqAdminOpts -> ShowS # show :: RabbitMqAdminOpts -> String # showList :: [RabbitMqAdminOpts] -> ShowS #

data AmqpEndpoint Source #

When admin opts are needed use `AmqpEndpoint Identity`, otherwise use `AmqpEndpoint NoAdmin`.

Constructors

AmqpEndpoint
Fields host :: !String port :: !Int vHost :: !Text tls :: !(Maybe RabbitMqTlsOpts)

Instances

Instances details

FromJSON AmqpEndpoint Source #
Instance details Defined in Network.AMQP.Extended Methods parseJSON :: Value -> Parser AmqpEndpoint Source # parseJSONList :: Value -> Parser [AmqpEndpoint] Source #
Show AmqpEndpoint Source #
Instance details Defined in Network.AMQP.Extended Methods showsPrec :: Int -> AmqpEndpoint -> ShowS # show :: AmqpEndpoint -> String # showList :: [AmqpEndpoint] -> ShowS #

openConnectionWithRetries :: forall m. (MonadIO m, MonadMask m, MonadBaseControl IO m) => Logger -> AmqpEndpoint -> RabbitMqHooks m -> m () Source #

Connects with RabbitMQ and opens a channel. If the channel is closed for some reasons, reopens the channel. If the connection is closed for some reasons, keeps retrying to connect until it works.

mkRabbitMqAdminClientEnv :: RabbitMqAdminOpts -> IO (AdminAPI (AsClientT IO)) Source #

mkRabbitMqChannelMVar :: Logger -> AmqpEndpoint -> IO (MVar Channel) Source #

Useful if the application only pushes into some queues.

demoteOpts :: RabbitMqAdminOpts -> AmqpEndpoint Source #

data RabbitMqTlsOpts Source #

Constructors

RabbitMqTlsOpts
Fields caCert :: !(Maybe FilePath) insecureSkipVerifyTls :: Bool

Instances

Instances details

Show RabbitMqTlsOpts Source #
Instance details Defined in Network.AMQP.Extended Methods showsPrec :: Int -> RabbitMqTlsOpts -> ShowS # show :: RabbitMqTlsOpts -> String # showList :: [RabbitMqTlsOpts] -> ShowS #