Service bus delivery count (#26)

Author: maiqbal11

azure/functions/_servicebus.py

@@ -23,6 +23,12 @@ def correlation_id(self) -> typing.Optional[str]:
         """Message correlation identifier."""
         pass
 
+    @property
+    @abc.abstractmethod
+    def delivery_count(self) -> typing.Optional[int]:
+        """Number of times delivery has been attempted."""
+        pass
+
     @property
     @abc.abstractmethod
     def expiration_time(self) -> typing.Optional[datetime.datetime]:

azure/functions/servicebus.py

@@ -14,6 +14,7 @@ def __init__(
             body: bytes,
             content_type: typing.Optional[str]=None,
             correlation_id: typing.Optional[str]=None,
+            delivery_count: typing.Optional[int]=0,
             expiration_time: typing.Optional[datetime.datetime]=None,
             label: typing.Optional[str]=None,
             message_id: str,
@@ -29,6 +30,7 @@ def __init__(
         self.__body = body
         self.__content_type = content_type
         self.__correlation_id = correlation_id
+        self.__delivery_count = delivery_count
         self.__expiration_time = expiration_time
         self.__label = label
         self.__message_id = message_id
@@ -52,6 +54,10 @@ def content_type(self) -> typing.Optional[str]:
     def correlation_id(self) -> typing.Optional[str]:
         return self.__correlation_id
 
+    @property
+    def delivery_count(self) -> typing.Optional[int]:
+        return self.__delivery_count
+
     @property
     def expiration_time(self) -> typing.Optional[datetime.datetime]:
         return self.__expiration_time
@@ -143,6 +149,8 @@ def decode(cls, data: meta.Datum, *,
                 trigger_metadata, 'ContentType', python_type=str),
             correlation_id=cls._decode_trigger_metadata_field(
                 trigger_metadata, 'CorrelationId', python_type=str),
+            delivery_count=cls._decode_trigger_metadata_field(
+                trigger_metadata, 'DeliveryCount', python_type=int),
             expiration_time=cls._parse_datetime_metadata(
                 trigger_metadata, 'ExpirationTime'),
             label=cls._decode_trigger_metadata_field(

setup.py

@@ -3,7 +3,7 @@
 
 setup(
     name='azure-functions',
-    version='1.0.3',
+    version='1.0.4',
     description='Azure Functions for Python',
     author='Microsoft Corporation',
     author_email='[email protected]',