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 | 5810d2bbc60c82feb5dec60b40e9cb14b64bca9c (patch) | |
| tree | ace36b79c20b6080d42f9c8999386ff65581674b /java/client/test/src | |
| parent | 9da1df0a07bb9543078fd5384e47dc651e4ceaf0 (diff) | |
| download | qpid-python-5810d2bbc60c82feb5dec60b40e9cb14b64bca9c.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/qpid@465166 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'java/client/test/src')
| -rw-r--r-- | java/client/test/src/org/apache/qpid/headers/MessageFactory.java | 13 |
1 files changed, 9 insertions, 4 deletions
diff --git a/java/client/test/src/org/apache/qpid/headers/MessageFactory.java b/java/client/test/src/org/apache/qpid/headers/MessageFactory.java index fcbfe8abf2..fc976766e4 100644 --- a/java/client/test/src/org/apache/qpid/headers/MessageFactory.java +++ b/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"); |