diff options
| author | Alan Conway <aconway@apache.org> | 2010-07-05 20:12:08 +0000 |
|---|---|---|
| committer | Alan Conway <aconway@apache.org> | 2010-07-05 20:12:08 +0000 |
| commit | 1c0490365610ba8db496847589049c83ddbc36e1 (patch) | |
| tree | e41c5b53b7060014fbc7dd472cf9b75385264d43 /qpid/tools/src/py | |
| parent | 8db7ae7ca30bdf2f71598d5a52b5711705a1a011 (diff) | |
| download | qpid-python-1c0490365610ba8db496847589049c83ddbc36e1.tar.gz | |
Defer delivery of messages in cluster-unsafe context.
Messages enqueued in a cluster-safe context are synchronized across
the cluster. However some messages are delivered in a cluster-unsafe
context, for example raising a link established event occurs the
connection thread of the establishing connection.
This fix deferrs such messages by multicasting them so they can be
re-delived in a cluster safe context.
See https://bugzilla.redhat.com/show_bug.cgi?id=611543
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@960681 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid/tools/src/py')
| -rwxr-xr-x | qpid/tools/src/py/qpid-printevents | 4 |
1 files changed, 3 insertions, 1 deletions
diff --git a/qpid/tools/src/py/qpid-printevents b/qpid/tools/src/py/qpid-printevents index 0c1b618a1f..ed2155ad22 100755 --- a/qpid/tools/src/py/qpid-printevents +++ b/qpid/tools/src/py/qpid-printevents @@ -29,13 +29,15 @@ from qmf.console import Console, Session class EventConsole(Console): def event(self, broker, event): print event + sys.stdout.flush() def brokerConnected(self, broker): print strftime("%c", gmtime(time())), "NOTIC qpid-printevents:brokerConnected broker=%s" % broker.getUrl() + sys.stdout.flush() def brokerDisconnected(self, broker): print strftime("%c", gmtime(time())), "NOTIC qpid-printevents:brokerDisconnected broker=%s" % broker.getUrl() - + sys.stdout.flush() ## ## Main Program |