Node.AMQP.FFI

type EffAMQP e a = Eff (amqp :: AMQP | e) a

type AffAMQP e a = Aff (amqp :: AMQP | e) a

type ECb e a = Error -> EffAMQP e a

type SCb r e a = r -> EffAMQP e a

_connect :: forall a e. Fn3 String (ECb e a) (SCb Connection e a) (EffAMQP e a)

_close :: forall a e. Fn3 Connection (ECb e a) (SCb Unit e a) (EffAMQP e a)

_createChannel :: forall a e. Fn3 Connection (ECb e a) (SCb Channel e a) (EffAMQP e a)

_closeChannel :: forall a e. Fn3 Channel (ECb e a) (SCb Unit e a) (EffAMQP e a)

_assertQueue :: forall a e. Fn5 Channel QueueName Foreign (ECb e a) (SCb AssertQueueOK e a) (EffAMQP e a)

_checkQueue :: forall a e. Fn4 Channel QueueName (ECb e a) (SCb AssertQueueOK e a) (EffAMQP e a)

_deleteQueue :: forall a e. Fn5 Channel QueueName Foreign (ECb e a) (SCb DeleteQueueOK e a) (EffAMQP e a)

_purgeQueue :: forall a e. Fn4 Channel QueueName (ECb e a) (SCb PurgeQueueOK e a) (EffAMQP e a)

_bindQueue :: forall a e. Fn7 Channel QueueName ExchangeName RoutingKey Foreign (ECb e a) (SCb Unit e a) (EffAMQP e a)

_unbindQueue :: forall a e. Fn7 Channel QueueName ExchangeName RoutingKey Foreign (ECb e a) (SCb Unit e a) (EffAMQP e a)

_assertExchange :: forall a e. Fn6 Channel ExchangeName String Foreign (ECb e a) (SCb Unit e a) (EffAMQP e a)

_checkExchange :: forall a e. Fn4 Channel ExchangeName (ECb e a) (SCb Unit e a) (EffAMQP e a)

_deleteExchange :: forall a e. Fn5 Channel ExchangeName Foreign (ECb e a) (SCb Unit e a) (EffAMQP e a)

_bindExchange :: forall a e. Fn7 Channel QueueName QueueName RoutingKey Foreign (ECb e a) (SCb Unit e a) (EffAMQP e a)

_unbindExchange :: forall a e. Fn7 Channel QueueName QueueName RoutingKey Foreign (ECb e a) (SCb Unit e a) (EffAMQP e a)

_publish :: forall a e. Fn6 Channel ExchangeName RoutingKey Buffer Foreign (SCb Unit e a) (EffAMQP e a)

_sendToQueue :: forall a e. Fn5 Channel QueueName Buffer Foreign (SCb Unit e a) (EffAMQP e a)

_consume :: forall a e. Fn6 Channel QueueName (SCb (Nullable Message') e Unit) Foreign (ECb e a) (SCb ConsumeOK e a) (EffAMQP e a)

_cancel :: forall a e. Fn4 Channel String (ECb e a) (SCb Unit e a) (EffAMQP e a)

_get :: forall a e. Fn5 Channel QueueName Foreign (ECb e a) (SCb (Nullable Message') e a) (EffAMQP e a)

_ack :: forall a e. Fn3 Channel String Boolean (EffAMQP e a)

_nack :: forall a e. Fn4 Channel String Boolean Boolean (EffAMQP e a)

_ackAll :: forall a e. Fn1 Channel (EffAMQP e a)

_nackAll :: forall a e. Fn2 Channel Boolean (EffAMQP e a)

_prefetch :: forall a e. Fn2 Channel Int (EffAMQP e a)

_recover :: forall a e. Fn3 Channel (ECb e a) (SCb Unit e a) (EffAMQP e a)

_onConnectionClose :: forall a e. Fn2 Connection (SCb (Nullable Error) e Unit) (EffAMQP e a)

_onConnectionError :: forall a e. Fn2 Connection (SCb Error e Unit) (EffAMQP e a)

_onConnectionBlocked :: forall a e. Fn2 Connection (SCb String e Unit) (EffAMQP e a)

_onConnectionUnblocked :: forall a e. Fn2 Connection (EffAMQP e Unit) (EffAMQP e a)

_onChannelClose :: forall a e. Fn2 Channel (EffAMQP e Unit) (EffAMQP e a)

_onChannelError :: forall a e. Fn2 Channel (SCb Error e Unit) (EffAMQP e a)

_onChannelReturn :: forall a e. Fn2 Channel (SCb Message' e Unit) (EffAMQP e a)

_onChannelDrain :: forall a e. Fn2 Channel (EffAMQP e Unit) (EffAMQP e a)