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, required 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.
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.
qos(int prefetchSize, int prefetchCount) → Future<Channel>
Setup the prefetchSize and prefetchCount QoS parameters. Returns a Future<Channel> with the affected channel once the server confirms the updated QoS settings.
queue(String name, {bool passive = false, bool durable = false, bool exclusive = false, bool autoDelete = false, bool noWait = false, 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