Channel class abstract

Constructors

Channel()

Properties

hashCode → int
The hash code for this object.
no setterinherited
runtimeType → Type
A representation of the runtime type of the object.
no setterinherited

Methods

ack(int deliveryTag, {bool multiple = false}) → void
Acknowledge a deliveryTag. The multiple flag can be set to true to notify the server that the client ack-ed all pending messages up to deliveryTag.
basicReturnListener(void onData(BasicReturnMessage message), {Function onError, void onDone(), bool cancelOnError}) → StreamSubscription<BasicReturnMessage>
Register a listener for basicReturn Messages
close() → Future<Channel>
Close the channel, abort any pending operations and return a Future<Channel> to be completed when the channel is closed.
commit() → Future<Channel>
Commit an open transaction on the current channel. Returns a Future<Channel> with the affected channel.
confirmPublishedMessages() → Future
Request that from this point onwards, the broker must confirm whether it has processed or dropped each message published to this channel. A listener for these notifications can be registered via publishNotifier.
exchange(String name, ExchangeType type, {bool passive = false, bool durable = false, bool noWait = false, Map<String, Object> arguments}) → Future<Exchange>
Define an exchange named name of type type and return a Future<Exchange> when the exchange is allocated.
flow(bool active) → Future<Channel>
Enable or disable the flow of messages to the client depending on active flag. This call should be used to notify the server that the client cannot handle the volume of incoming messages on the channel.
noSuchMethod(Invocation invocation) → dynamic
Invoked when a nonexistent method or property is accessed.
inherited
privateQueue({bool noWait = false, Map<String, Object> arguments}) → Future<Queue>
A convenience method for allocating private queues. The client will allocate an exclusive queue with a random, server-assigned name and return a Future<Queue> to be completed when the server responds.
publishNotifier(void onData(PublishNotification notification), {Function onError, void onDone(), bool cancelOnError}) → StreamSubscription<PublishNotification>
Register a listener to be notified when the broker ACKs or NACKs published messages.
qos(int? prefetchSize, int? prefetchCount, {bool global = true}) → Future<Channel>
Setup the prefetchSize and prefetchCount QoS parameters. The value of the global flag is interpreted differently between the AMQP 0-9-1 spec and RabbitMQ.
queue(String name, {bool passive = false, bool durable = false, bool exclusive = false, bool autoDelete = false, bool noWait = false, bool declare = true, Map<String, Object> arguments}) → Future<Queue>
Define a queue named name. Returns a Future<Queue> to be completed when the queue is allocated.
recover(bool requeue) → Future<Channel>
Ask the server to re-deliver unacknowledged messages. If this requeue flag is false, the server will redeliver messages to the original recipient. If requeue is set to true, the server will attempt to requeue the message, potentially then delivering it to an alternative client.
rollback() → Future<Channel>
Rollback an open transaction on the current channel. Returns a Future<Channel> with the affected channel.
select() → Future<Channel>
Begin a transaction on the current channel. Returns a Future<Channel> with the affected channel.
toString() → String
A string representation of this object.
inherited

Operators

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