Skip to content

Commit d323082

Browse files
committed
PROTON-2873: [Python] Fix transaction code for new disposition API
1 parent 0464a4f commit d323082

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

python/proton/_reactor.py

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -34,7 +34,7 @@
3434
from cproton import PN_ACCEPTED, PN_EVENT_NONE
3535

3636
from ._data import Described, symbol, ulong
37-
from ._delivery import Delivery, TransactionalDisposition
37+
from ._delivery import Delivery, Disposition, TransactionalDisposition
3838
from ._endpoints import Connection, Endpoint, Link, Session, Terminus
3939
from ._events import Collector, EventType, EventBase, Event
4040
from ._exceptions import SSLUnavailable
@@ -615,8 +615,8 @@ def _clear_pending(self):
615615

616616
def handle_outcome(self, event):
617617
if event.delivery == self._declare:
618-
if event.delivery.remote.data:
619-
self.id = event.delivery.remote.data[0]
618+
if event.delivery.remote_state == Disposition.TRANSACTIONAL_STATE:
619+
self.id = event.delivery.remote.id
620620
self.handler.on_transaction_declared(event)
621621
elif event.delivery.remote_state == Delivery.REJECTED:
622622
self.handler.on_transaction_declare_failed(event)

0 commit comments

Comments
 (0)