Node.AMQP.Types.Internal

connectUrl :: String -> ConnectOptions -> String

encodeQueueOptions :: QueueOptions -> Foreign

encodeDeleteQueueOptions :: DeleteQueueOptions -> Foreign

encodeExchangeOptions :: ExchangeOptions -> Foreign

encodeDeleteExchangeOptions :: DeleteExchangeOptions -> Foreign

encodePublishOptions :: PublishOptions -> Foreign

encodeConsumeOptions :: ConsumeOptions -> Foreign

encodeGetOptions :: GetOptions -> Foreign

newtype QueueOptions'

Constructors

• QueueOptions' { arguments :: StrMap Foreign, autoDelete :: NullOrUndefined Boolean, deadLetterExchange :: NullOrUndefined String, deadLetterRoutingKey :: NullOrUndefined String, durable :: NullOrUndefined Boolean, exclusive :: NullOrUndefined Boolean, expires :: NullOrUndefined Number, maxLength :: NullOrUndefined Int, maxPriority :: NullOrUndefined Int, messageTtl :: NullOrUndefined Number }

Instances

• Generic QueueOptions' _
• Encode QueueOptions'

fromQueueOptions :: QueueOptions -> QueueOptions'

newtype DeleteQueueOptions'

Constructors

• DeleteQueueOptions' { ifEmpty :: NullOrUndefined Boolean, ifUnused :: NullOrUndefined Boolean }

Instances

• Generic DeleteQueueOptions' _
• Encode DeleteQueueOptions'

fromDeleteQueueOptions :: DeleteQueueOptions -> DeleteQueueOptions'

newtype ExchangeOptions'

Constructors

• ExchangeOptions' { alternateExchange :: NullOrUndefined String, arguments :: StrMap Foreign, autoDelete :: NullOrUndefined Boolean, durable :: NullOrUndefined Boolean, internal :: NullOrUndefined Boolean }

Instances

• Generic ExchangeOptions' _
• Encode ExchangeOptions'

fromExchangeOptions :: ExchangeOptions -> ExchangeOptions'

newtype DeleteExchangeOptions'

Constructors

• DeleteExchangeOptions' { ifUnused :: NullOrUndefined Boolean }

Instances

• Generic DeleteExchangeOptions' _
• Encode DeleteExchangeOptions'

fromDeleteExchangeOptions :: DeleteExchangeOptions -> DeleteExchangeOptions'

newtype PublishOptions'

Constructors

• PublishOptions' { "BCC" :: Array RoutingKey, "CC" :: Array RoutingKey, appId :: NullOrUndefined String, contentEncoding :: NullOrUndefined String, contentType :: NullOrUndefined String, correlationId :: NullOrUndefined String, expiration :: NullOrUndefined String, headers :: StrMap Foreign, mandatory :: NullOrUndefined Boolean, messageId :: NullOrUndefined String, persistent :: NullOrUndefined Boolean, priority :: NullOrUndefined Int, replyTo :: NullOrUndefined QueueName, timestamp :: NullOrUndefined Number, type :: NullOrUndefined String, userId :: NullOrUndefined String }

Instances

• Generic PublishOptions' _
• Encode PublishOptions'

fromPublishOptions :: PublishOptions -> PublishOptions'

newtype MessageProperties'

Constructors

• MessageProperties' { appId :: Nullable String, contentEncoding :: Nullable String, contentType :: Nullable String, correlationId :: Nullable String, deliveryMode :: Nullable Int, expiration :: Nullable Number, headers :: StrMap Foreign, messageId :: Nullable String, priority :: Nullable Int, replyTo :: Nullable QueueName, timestamp :: Nullable Number, type :: Nullable String, userId :: Nullable String }

newtype Message'

Constructors

• Message' { content :: Buffer, fields :: MessageFields, properties :: MessageProperties' }

toMessage :: Message' -> Message

newtype ConsumeOptions'

Constructors

• ConsumeOptions' { arguments :: StrMap Foreign, consumerTag :: NullOrUndefined String, exclusive :: NullOrUndefined Boolean, noAck :: NullOrUndefined Boolean, noLocal :: NullOrUndefined Boolean, priority :: NullOrUndefined Int }

Instances

• Generic ConsumeOptions' _
• Encode ConsumeOptions'

fromConsumeOptions :: ConsumeOptions -> ConsumeOptions'

newtype GetOptions'

Constructors

• GetOptions' { noAck :: NullOrUndefined Boolean }

Instances

• Generic GetOptions' _
• Encode GetOptions'

fromGetOptions :: GetOptions -> GetOptions'