Force message durable to True

rabbitmq_amqp_python_client/qpid/proton/_message.py

@@ -110,7 +110,7 @@ class Message(object):
     """ Default AMQP message priority"""
 
     def __init__(
-        self, body: Union[bytes, None] = None, inferred=True, durable=True, **kwargs
+        self, body: Union[bytes, None] = None, inferred=True, **kwargs
     ) -> None:
         # validate the types
 
@@ -120,7 +120,7 @@ def __init__(
         self.application_properties = None
         self.body = body
         self.inferred = inferred
-        self.durable = durable
+        self.durable = True
 
         for k, v in kwargs.items():
             getattr(self, k)  # Raise exception if it's not a valid attribute.

tests/test_publisher.py

@@ -465,22 +465,11 @@ def test_durable_message(connection: Connection) -> None:
     assert status.remote_state == OutcomeState.ACCEPTED
     # message should be not durable by setting the durable to False by the user
 
-    m = Message(
-        body=Converter.string_to_bytes("not durable"),
-        durable=False,
-    )
-    status = publisher.publish(m)
-
     assert status.remote_state == OutcomeState.ACCEPTED
 
     consumer = connection.consumer(destination)
     should_be_durable = consumer.consume()
     assert should_be_durable.durable is True
     consumer.close()
-    # it does not work due of https://github.com/rabbitmq/rabbitmq-amqp-python-client/issues/83
-    # should_be_not_durable = consumer.consume()
-    # assert should_be_not_durable.durable is False
-    # message_count = management.purge_queue(queue_name)
     management.purge_queue(queue_name)
-    # assert message_count == 0
     management.delete_queue(queue_name)