You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by gs...@apache.org on 2014/10/29 17:40:03 UTC
svn commit: r1635194 -
/qpid/proton/branches/examples/tutorial/proton_events.py
Author: gsim
Date: Wed Oct 29 16:40:02 2014
New Revision: 1635194
URL: http://svn.apache.org/r1635194
Log:
Fix encoding of transactional outcome
Modified:
qpid/proton/branches/examples/tutorial/proton_events.py
Modified: qpid/proton/branches/examples/tutorial/proton_events.py
URL: http://svn.apache.org/viewvc/qpid/proton/branches/examples/tutorial/proton_events.py?rev=1635194&r1=1635193&r2=1635194&view=diff
==============================================================================
--- qpid/proton/branches/examples/tutorial/proton_events.py (original)
+++ qpid/proton/branches/examples/tutorial/proton_events.py Wed Oct 29 16:40:02 2014
@@ -17,7 +17,7 @@
# under the License.
#
import heapq, os, Queue, re, socket, time, types
-from proton import generate_uuid, PN_ACCEPTED, SASL, symbol
+from proton import generate_uuid, PN_ACCEPTED, SASL, symbol, ulong
from proton import Collector, Connection, Delivery, Described, Endpoint, Event, Link, Terminus, Timeout
from proton import Message, Handler, ProtonException, Transport, TransportException, ConnectionException
from select import select
@@ -676,7 +676,7 @@ class TxHandler(OutgoingMessageHandler):
def settle(self, delivery, transaction, state=None):
if state:
- delivery.local.data = [transaction.id, state]
+ delivery.local.data = [transaction.id, Described(ulong(state), [])]
delivery.update(0x34)
delivery.settle()
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@qpid.apache.org
For additional commands, e-mail: commits-help@qpid.apache.org