JSDoc: Class: AmqpQueue

new AmqpQueue()

Manages an AMQP queue.

Source:

amqp-queue.js, line 48

Fires:

Methods

ack(msg, callback)

Use this if the message is processed successfully.

Parameters:

Name Type Description

msg AmqpMessage

callback

function

Properties

Name	Type	Attributes	Description
`err`	Error	<nullable>

Source:

amqp-queue.js, line 284

close(callbackopt)

To close the queue. You can use a callback function to get the result or listen events.

Parameters:

Name Type Attributes Description

callback

function

Properties

Name	Type	Attributes	Description
`err`	Error	<nullable>

Source:

amqp-queue.js, line 188

connect()

To connect to the message queue. The `AmqpQueue` will report status with Status.

Source:

amqp-queue.js, line 167

Throws:

Wrong usage.
Type Error

isRecv() → {boolean}

Is the queue a receiver.

Source:

amqp-queue.js, line 135

Returns:

Type: boolean

nack(msg, callback)

To requeue the message and the broker will send the message in the future.

Parameters:

Name Type Description

msg AmqpMessage

callback

function

Properties

Name	Type	Attributes	Description
`err`	Error	<nullable>

Source:

amqp-queue.js, line 307

name() → {string}

To get the queue name.

Source:

amqp-queue.js, line 126

Returns:

Type: string

sendMsg(payload, callback)

To send a message (for senders only).

Parameters:

Name Type Description

payload Buffer The raw data to be sent.

callback

function

Properties

Name	Type	Attributes	Description
`err`	Error	<nullable>

Source:

amqp-queue.js, line 236

Throws:

Wrong arguments.
Type Error

setMsgHandler(handlernullable)

Set the message handler.

Parameters:

Name	Type	Attributes	Description
`handler`	AmqpQueueMsgHandler	<nullable>

Source:

amqp-queue.js, line 154

Throws:

Wrong arguments.
Type Error

status() → {Status}

To get the queue status.

Source:

amqp-queue.js, line 144

Returns:

Type: Status

Events

error

Queue error event.

Type:

Error

Source:

amqp-queue.js, line 17

status

Queue status event.

Type:

Status

Source:

amqp-queue.js, line 24

new AmqpQueue(opts, conn)

Parameters:

Name Type Description

opts

Object

The queue options.

Properties

Name	Type	Attributes	Default	Description
`name`	string			The queue name that is used to map a AMQP queue (unicast) or an exchange (broadcast). The pattern is `^[a-z0-9_-]+([\.]{1}[a-z0-9_-]+)*$`.
`isRecv`	boolean			`true` for the receiver and `false` for the sender.
`reliable`	boolean			Reliable by selecting the confirm channel (for publish).
`broadcast`	boolean			`true` for broadcast and `false` for unicast.
`reconnectMillis`	number	<optional>	1000	Time in milliseconds from disconnection to reconnection.
`prefetch`	number	<optional>		REQUIRED when `isRecv=true`. The QoS of the receiver queue. This value MUST be a positive value between 1 to 65535.
`persistent`	boolean	<optional>	false	Use persistent delivery mode.

conn AmqpConnection The AMQP connection.

Source:

amqp-queue.js, line 72

Throws:

Wrong arguments.
Type Error

Methods

ack(msg, callback)

Use this if the message is processed successfully.

Parameters:

Name Type Description

msg AmqpMessage

callback

function

Properties

Name	Type	Attributes	Description
`err`	Error	<nullable>

Source:

amqp-queue.js, line 284

close(callbackopt)

To close the queue. You can use a callback function to get the result or listen events.

Parameters:

Name Type Attributes Description

callback

function

Properties

Name	Type	Attributes	Description
`err`	Error	<nullable>

Source:

amqp-queue.js, line 188

connect()

To connect to the message queue. The `AmqpQueue` will report status with Status.

Source:

amqp-queue.js, line 167

Throws:

Wrong usage.
Type Error

isRecv() → {boolean}

Is the queue a receiver.

Source:

amqp-queue.js, line 135

Returns:

Type: boolean

nack(msg, callback)

To requeue the message and the broker will send the message in the future.

Parameters:

Name Type Description

msg AmqpMessage

callback

function

Properties

Name	Type	Attributes	Description
`err`	Error	<nullable>

Source:

amqp-queue.js, line 307

name() → {string}

To get the queue name.

Source:

amqp-queue.js, line 126

Returns:

Type: string

sendMsg(payload, callback)

To send a message (for senders only).

Parameters:

Name Type Description

payload Buffer The raw data to be sent.

callback

function

Properties

Name	Type	Attributes	Description
`err`	Error	<nullable>

Source:

amqp-queue.js, line 236

Throws:

Wrong arguments.
Type Error

setMsgHandler(handlernullable)

Set the message handler.

Parameters:

Name	Type	Attributes	Description
`handler`	AmqpQueueMsgHandler	<nullable>

Source:

amqp-queue.js, line 154

Throws:

Wrong arguments.
Type Error

status() → {Status}

To get the queue status.

Source:

amqp-queue.js, line 144

Returns:

Type: Status

Events

error

Queue error event.

Type:

Error

Source:

amqp-queue.js, line 17

status

Queue status event.

Type:

Status

Source:

amqp-queue.js, line 24