replace Disposition to OutcomeState

Author: DanielePalaia

examples/getting_started/basic_example.py

@@ -6,11 +6,11 @@
     AMQPMessagingHandler,
     BindingSpecification,
     Connection,
-    Disposition,
     Environment,
     Event,
     ExchangeSpecification,
     Message,
+    OutcomeState,
     QuorumQueueSpecification,
 )
 
@@ -126,11 +126,11 @@ def main() -> None:
     for i in range(MESSAGES_TO_PUBLISH):
         print("publishing")
         status = publisher.publish(Message(body="test"))
-        if status.remote_state == Disposition.ACCEPTED:
+        if status.remote_state == OutcomeState.ACCEPTED:
             print("message accepted")
-        elif status.remote_state == Disposition.RELEASED:
+        elif status.remote_state == OutcomeState.RELEASED:
             print("message not routed")
-        elif status.remote_state == Disposition.REJECTED:
+        elif status.remote_state == OutcomeState.REJECTED:
             print("message not rejected")
 
     publisher.close()

rabbitmq_amqp_python_client/__init__.py

@@ -40,6 +40,8 @@
 
 del metadata
 
+OutcomeState = Disposition
+
 __all__ = [
     "Connection",
     "Management",
@@ -62,10 +64,9 @@
     "ArgumentOutOfRangeException",
     "SslConfigurationContext",
     "ClientCert",
-    "Delivery",
     "ConnectionClosed",
     "StreamOptions",
     "OffsetSpecification",
-    "Disposition",
+    "OutcomeState",
     "Environment",
 ]

rabbitmq_amqp_python_client/publisher.py

@@ -1,5 +1,5 @@
 import logging
-from typing import Optional
+from typing import Optional, TypeVar
 
 from .options import SenderOptionUnseattle
 from .qpid.proton._delivery import Delivery