summaryrefslogtreecommitdiff
path: root/qpid/java/client/example/src
diff options
context:
space:
mode:
authorRafael H. Schloming <rhs@apache.org>2008-07-09 13:26:54 +0000
committerRafael H. Schloming <rhs@apache.org>2008-07-09 13:26:54 +0000
commit21c61b77e0216a6a5d4f97cd5ab4793433b47066 (patch)
tree1c124a592450525e273149a2b2c7a5d325da034e /qpid/java/client/example/src
parentb4e3a8fef0a146d2eac02ac1250365c01989a973 (diff)
downloadqpid-python-21c61b77e0216a6a5d4f97cd5ab4793433b47066.tar.gz
Primarily profiling driven changes:
- added batched writes of commands/controls issued on a session - copy fragmented frames and segments rather than trying to decode them piecemeal, removed FragmentDecoder - added caching for str8 encode/decode - compute sizes as we encode by going back and filling in the amount of bytes written rather than computing it up front - added SYNC option to commands - renamed NO_OPTION argument to NONE - added a timeout to Client.java - removed use of UUID.fromString in BasicMessageProducer_0_10.java git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@675165 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid/java/client/example/src')
-rwxr-xr-xqpid/java/client/example/src/main/java/org/apache/qpid/example/amqpexample/pubsub/TopicListener.java2
1 files changed, 1 insertions, 1 deletions
diff --git a/qpid/java/client/example/src/main/java/org/apache/qpid/example/amqpexample/pubsub/TopicListener.java b/qpid/java/client/example/src/main/java/org/apache/qpid/example/amqpexample/pubsub/TopicListener.java
index f26e5418b4..100dcf52bf 100755
--- a/qpid/java/client/example/src/main/java/org/apache/qpid/example/amqpexample/pubsub/TopicListener.java
+++ b/qpid/java/client/example/src/main/java/org/apache/qpid/example/amqpexample/pubsub/TopicListener.java
@@ -55,7 +55,7 @@ public class TopicListener implements MessageListener
Session.TRANSFER_CONFIRM_MODE_NOT_REQUIRED,
Session.TRANSFER_ACQUIRE_MODE_PRE_ACQUIRE,
new MessagePartListenerAdapter(this),
- null, Option.NO_OPTION);
+ null, Option.NONE);
// issue credits
// XXX: need to be able to set to null
session.messageFlow(queueName, MessageCreditUnit.BYTE, Session.MESSAGE_FLOW_MAX_BYTES);