Repository: activemq Updated Branches: refs/heads/master 40ecf22f0 -> 3e4bf2df7
Clarified and updated instructions Updated the example to match stompest API changes Project: http://git-wip-us.apache.org/repos/asf/activemq/repo Commit: http://git-wip-us.apache.org/repos/asf/activemq/commit/f89e8c5d Tree: http://git-wip-us.apache.org/repos/asf/activemq/tree/f89e8c5d Diff: http://git-wip-us.apache.org/repos/asf/activemq/diff/f89e8c5d Branch: refs/heads/master Commit: f89e8c5d25a9fb837ec6c1585a69d39eeead2b42 Parents: 40ecf22 Author: Ingo Weiss <[email protected]> Authored: Thu Feb 11 09:03:47 2016 +0000 Committer: Christopher L. Shannon (cshannon) <[email protected]> Committed: Fri Feb 12 16:43:45 2016 +0000 ---------------------------------------------------------------------- .../examples/stomp/python/stompest/async/listener.py | 3 ++- .../release/examples/stomp/python/stompest/readme.md | 14 +++++++++++++- 2 files changed, 15 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/activemq/blob/f89e8c5d/assembly/src/release/examples/stomp/python/stompest/async/listener.py ---------------------------------------------------------------------- diff --git a/assembly/src/release/examples/stomp/python/stompest/async/listener.py b/assembly/src/release/examples/stomp/python/stompest/async/listener.py index f9c7b2b..fb861e2 100644 --- a/assembly/src/release/examples/stomp/python/stompest/async/listener.py +++ b/assembly/src/release/examples/stomp/python/stompest/async/listener.py @@ -23,6 +23,7 @@ from twisted.internet import defer, reactor from stompest.config import StompConfig from stompest.async import Stomp +from stompest.async.listener import SubscriptionListener user = os.getenv('ACTIVEMQ_USER') or 'admin' password = os.getenv('ACTIVEMQ_PASSWORD') or 'password' @@ -42,7 +43,7 @@ class Listener(object): self.count = 0 self.start = time.time() - client.subscribe(destination, self.handleFrame, headers={'ack': 'auto', 'id': 'required-for-STOMP-1.1'}, ack=False) + client.subscribe(destination, listener=SubscriptionListener(self.handleFrame), headers={'ack': 'auto', 'id': 'required-for-STOMP-1.1'}) @defer.inlineCallbacks def handleFrame(self, client, frame): http://git-wip-us.apache.org/repos/asf/activemq/blob/f89e8c5d/assembly/src/release/examples/stomp/python/stompest/readme.md ---------------------------------------------------------------------- diff --git a/assembly/src/release/examples/stomp/python/stompest/readme.md b/assembly/src/release/examples/stomp/python/stompest/readme.md index a1a912b..0a1a8f2 100644 --- a/assembly/src/release/examples/stomp/python/stompest/readme.md +++ b/assembly/src/release/examples/stomp/python/stompest/readme.md @@ -8,7 +8,19 @@ easy_install users can install it by running: easy_install stompest +If you use `pip`: + + pip install stompest + The stompest client library supports a blocking API, and you can find an example of it's use in the `sync` directory. It also supports using a non-blocking API based on Twisted, and that example can be found in -the `async` directory. \ No newline at end of file +the `async` directory. + +To run the `async` examples install `stompest.async`: + + easy_install stompest.async + +If you use `pip`: + + pip install stompest.async \ No newline at end of file
