Expose deliveryTag from AmqpMessage

achilleasa · Nov 3, 2022 · 036dc41 · 036dc41
1 parent 9a76e46
commit 036dc41
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 0 deletions.
diff --git a/lib/src/client/amqp_message.dart b/lib/src/client/amqp_message.dart
@@ -24,6 +24,9 @@ abstract class AmqpMessage {
   /// exchange (e.g. posted directly to a queue).
   String? get routingKey;
 
+  /// Get the [deliveryTag] for this message.
+  int get deliveryTag;
+
   /// Get the [properties] that were included with the message metadata
   MessageProperties? get properties;
 

diff --git a/lib/src/client/impl/amqp_message_impl.dart b/lib/src/client/impl/amqp_message_impl.dart
@@ -23,6 +23,9 @@ class _AmqpMessageImpl implements AmqpMessage {
 
   @override
   String get routingKey => (message.message as BasicDeliver).routingKey;
+
+  @override
+  int get deliveryTag => (message.message as BasicDeliver).deliveryTag;
 
   @override
   void reply(Object responseMessage,