activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From cshan...@apache.org
Subject [1/2] activemq git commit: Clarified and updated instructions
Date Fri, 12 Feb 2016 16:46:34 GMT
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 <ingo@redhat.com>
Authored: Thu Feb 11 09:03:47 2016 +0000
Committer: Christopher L. Shannon (cshannon) <christopher.l.shannon@gmail.com>
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


Mime
View raw message