Presents an AMQP queue as either a source or destination stream of Vinyl objects.
To send a Vinyl file to a queue, use the
dest() function, with a queue name as the parameter:
var gulp = ;var es = ;var File = ;var amqp = ;gulp;
Gulp will exit after sending all of the data to the queue. The
queued event is fired when an item has been completely queued. This is usually the case, since the batch size -- which determines how many items are needed before waiting items are pushed to the queue -- is set to one by default. However, it's possible to send more than one item in a batch by setting options in the
dest() function call:
waiting event is provided to indicate that an item is waiting for the batch total to be reached. This is described in more detail in the amqp-sqs module.
To read from the queue some other process (perhaps on another machine) simply uses the
src() function, again with a queue name:
Note that in this case Gulp does not exit but continues to poll the queue. The frequency of the polling defaults to 5 minutes, which is set in the amqp-sqs module. This can be overridden by providing a configuration file, with a value such as this:
This will set the poll to be a quarter of a minute, or 15 seconds.
More control will be provided over this behaviour in the future, such as allowing the stream to close if the queue is empty, setting the poll frequency in the
src() function, and so on.
Checking the Queue Size
To get the count of the number of messages in the queue, set
true in the options parameter. Only the count will be returned, i.e., no messages will be read from the queue. For example: