Constructors
constructor
-
Parameters
-
queue: Queue<Data>
-
message: AMQPMessage
Properties
message
message: AMQPMessage
Methods
ack
- ack(allUpTo?: boolean): Promise<void>
-
Parameters
-
Optional allUpTo: boolean
Returns Promise<void>
nack
- nack(allUpTo?: boolean, requeue?: boolean): Promise<void>
-
Parameters
-
Optional allUpTo: boolean
-
Optional requeue: boolean
Returns Promise<void>
publish
- publish(data: any, options?: AMQPOptions.Publish): Promise<boolean>
-
Parameters
-
data: any
-
Optional options: AMQPOptions.Publish
Returns Promise<boolean>