Merge pull request #80 from brizaldi/expose-delivery-tag

Expose deliveryTag from AmqpMessage
achilleasa · Nov 3, 2022 · 40f3fc1 · 40f3fc1
2 parents 9a76e46 + aa0259e
commit 40f3fc1
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
@@ -24,6 +24,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,
       {MessageProperties? properties,