diff options
| author | Martin Ritchie <ritchiem@apache.org> | 2006-10-18 07:26:13 +0000 |
|---|---|---|
| committer | Martin Ritchie <ritchiem@apache.org> | 2006-10-18 07:26:13 +0000 |
| commit | dac3a256b4de7b2c65389dda795a1fcc8f62e5b8 (patch) | |
| tree | fc3ee9fe382dd15eecf6c9a4d31a2fa244a1c1b9 /qpid/java/client/test/src | |
| parent | 89d662f38ca2739ff61cba773dce240370d4070f (diff) | |
| download | qpid-python-dac3a256b4de7b2c65389dda795a1fcc8f62e5b8.tar.gz | |
QPID-36 Added high/low water mark to DUPS_OK_ACKNOWLEDGE.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@465166 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid/java/client/test/src')
| -rw-r--r-- | qpid/java/client/test/src/org/apache/qpid/headers/MessageFactory.java | 13 |
1 files changed, 9 insertions, 4 deletions
diff --git a/qpid/java/client/test/src/org/apache/qpid/headers/MessageFactory.java b/qpid/java/client/test/src/org/apache/qpid/headers/MessageFactory.java index fcbfe8abf2..fc976766e4 100644 --- a/qpid/java/client/test/src/org/apache/qpid/headers/MessageFactory.java +++ b/qpid/java/client/test/src/org/apache/qpid/headers/MessageFactory.java @@ -17,10 +17,15 @@ */ package org.apache.qpid.headers; -import org.apache.qpid.framing.FieldTable; import org.apache.qpid.client.AMQSession; +import org.apache.qpid.framing.FieldTable; -import javax.jms.*; +import javax.jms.BytesMessage; +import javax.jms.Destination; +import javax.jms.JMSException; +import javax.jms.Message; +import javax.jms.MessageConsumer; +import javax.jms.TextMessage; /** */ @@ -46,7 +51,7 @@ class MessageFactory } _session = session; _payload = new byte[payloadSize]; - for(int i = 0; i < _payload.length; i++) + for (int i = 0; i < _payload.length; i++) { _payload[i] = (byte) DATA[i % DATA.length]; } @@ -156,7 +161,7 @@ class MessageFactory private static Message setHeaders(Message m, String[] headers) throws JMSException { - for(int i = 0; i < headers.length; i++) + for (int i = 0; i < headers.length; i++) { // the value in GRM is 5 bytes m.setStringProperty(headers[i], "value"); |