Queue class abstract

Constructors

Queue()

Properties

channel Channel
Get the Channel where this Queue was declared
no setter
consumerCount int
no setter
hashCode int
The hash code for this object.
no setterinherited
messageCount int
no setter
name String
Get the queue name
no setter
runtimeType Type
A representation of the runtime type of the object.
no setterinherited

Methods

bind(Exchange exchange, String routingKey, {bool noWait, Map<String, Object> arguments}) Future<Queue>
Bind this queue to exchange using routingKey and return a Future<Queue> to the bound queue.
consume({String? consumerTag, bool noLocal = false, bool noAck = true, bool exclusive = false, bool noWait = false, Map<String, Object>? arguments}) Future<Consumer>
Create a consumer for processing queued messages and return a Future<Consumer> to the created consumer.
delete({bool ifUnused = false, bool ifEmpty = false, bool noWait = false}) Future<Queue>
Delete the queue and return a Future<Queue> for the deleted queue.
noSuchMethod(Invocation invocation) → dynamic
Invoked when a nonexistent method or property is accessed.
inherited
publish(Object message, {MessageProperties properties, bool mandatory = false, bool immediate = false}) → void
Publish message to the queue. message should be either a Uint8List, a String, a Map or Iterable. If message is Map or Iterable it will be encoded as JSON and the appropriate message properties (content-type and content-encoding) will be set on the outgoing message. Any other message value will trigger an ArgumentError.
purge({bool noWait = false}) Future<Queue>
Purge any queued messages that are not awaiting acknowledgment.
toString() String
A string representation of this object.
inherited
unbind(Exchange exchange, String routingKey, {bool noWait, Map<String, Object> arguments}) Future<Queue>
Unbind this queue from exchange with routingKey and return a Future<Queue> to the unbound queue.

Operators

operator ==(Object other) bool
The equality operator.
inherited