diff options
| author | Charles E. Rolke <chug@apache.org> | 2012-02-27 17:40:42 +0000 |
|---|---|---|
| committer | Charles E. Rolke <chug@apache.org> | 2012-02-27 17:40:42 +0000 |
| commit | c3a0c2ec78970005da38d524f38939cc7f2fb3a7 (patch) | |
| tree | e0efc6e350bc0867c5f114ca10fc7b48a3cfa033 /doc | |
| parent | 879da6a01706268adbb75c42182027bde4a1d430 (diff) | |
| download | qpid-python-c3a0c2ec78970005da38d524f38939cc7f2fb3a7.tar.gz | |
Merge from trunk into branch
git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/QPID-3799-acl@1294242 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'doc')
| -rw-r--r-- | doc/book/src/LVQ.xml | 11 |
1 files changed, 5 insertions, 6 deletions
diff --git a/doc/book/src/LVQ.xml b/doc/book/src/LVQ.xml index 4e818881ad..b57c6268be 100644 --- a/doc/book/src/LVQ.xml +++ b/doc/book/src/LVQ.xml @@ -117,7 +117,7 @@ qpid-config utility: </para> <programlisting> - $ qpid-config add queue prices --argument qpid.last_value_queue_key=ticker + $ qpid-config add queue prices --lvq-key ticker </programlisting> </section> </section> @@ -131,13 +131,13 @@ from qpid.messaging import Connection, Message def send(sender, key, message): - message.properties["key"] = key + message.properties["ticker"] = key sender.send(message) conn = Connection("localhost") conn.open() sess = conn.session() - tx = sess.sender("topic;{create:always, node:{type:queue,x-declare:{arguments:{'qpid.last_value_queue_key':key}}}}") + tx = sess.sender("prices;{create:always, node:{type:queue,x-declare:{arguments:{'qpid.last_value_queue_key':ticker}}}}") msg = Message("Content") send(tx, "key1", msg); @@ -155,12 +155,11 @@ <title>LVQ Browsing Receiver</title> <programlisting> from qpid.messaging import Connection, Message - from time import sleep conn = Connection("localhost") conn.open() sess = conn.session() - rx = sess.receiver("topic;{mode:browse}") + rx = sess.receiver("prices;{mode:browse}") while True: msg = rx.fetch() @@ -176,7 +175,7 @@ There are two legacy modes (still implemented as of Qpid 0.14) controlled by the qpid.last_value_queue and qpid.last_value_queue_no_browse argument values. These modes are - intended to be deprecated and should not be used. + deprecated and should not be used. </para> </section> </section> |