DVAmqpChannel class abstract
What this adapter needs from an AMQP connection.
An interface rather than a socket, for the same reason the Postgres and MySQL adapters abstract theirs: the protocol is then testable without a broker, and connection management, heartbeats and reconnection stay with whatever owns the connection.
Constructors
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) → Future< void> - Acknowledge, removing it from the broker.
-
declareQueue(
String name, {required bool durable}) → Future< void> - Declare a durable queue, creating it if absent.
-
get(
String queue) → Future< DVAmqpMessage?> - Take one message without acknowledging it, or null when none is waiting.
-
nack(
int deliveryTag, {required bool requeue}) → Future< void> - Reject, and requeue it or send it to the dead-letter exchange.
-
noSuchMethod(
Invocation invocation) → dynamic -
Invoked when a nonexistent method or property is accessed.
inherited
-
publish(
String queue, List< int> body, {required bool persistent, int priority}) → Future<void> - Publish to the default exchange, routed by queue name.
-
purge(
String queue) → Future< int> - Remove every message, returning how many went.
-
toString(
) → String -
A string representation of this object.
inherited
Operators
-
operator ==(
Object other) → bool -
The equality operator.
inherited