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)
}
withConnection :: forall m a. (MonadIO m, MonadMask m) => Logger -> AmqpEndpoint -> (Connection -> m a) -> m a
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
}
mkConnectionOpts :: MonadIO m => AmqpEndpoint -> m ConnectionOpts
mkTLSSettings :: HostName -> RabbitMqTlsOpts -> IO TLSSettings
readCredsFromEnv :: IO (Text, Text)

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 #
Eq RabbitMqAdminOpts Source #
Instance details Defined in Network.AMQP.Extended Methods (==) :: RabbitMqAdminOpts -> RabbitMqAdminOpts -> Bool # (/=) :: RabbitMqAdminOpts -> RabbitMqAdminOpts -> Bool #

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 #
Eq AmqpEndpoint Source #
Instance details Defined in Network.AMQP.Extended Methods (==) :: AmqpEndpoint -> AmqpEndpoint -> Bool # (/=) :: AmqpEndpoint -> AmqpEndpoint -> Bool #

withConnection :: forall m a. (MonadIO m, MonadMask m) => Logger -> AmqpEndpoint -> (Connection -> m a) -> m a Source #

Connects with RabbitMQ and opens a channel.

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 #
Eq RabbitMqTlsOpts Source #
Instance details Defined in Network.AMQP.Extended Methods (==) :: RabbitMqTlsOpts -> RabbitMqTlsOpts -> Bool # (/=) :: RabbitMqTlsOpts -> RabbitMqTlsOpts -> Bool #

mkConnectionOpts :: MonadIO m => AmqpEndpoint -> m ConnectionOpts Source #

mkTLSSettings :: HostName -> RabbitMqTlsOpts -> IO TLSSettings Source #

readCredsFromEnv :: IO (Text, Text) Source #