From 5810d2bbc60c82feb5dec60b40e9cb14b64bca9c Mon Sep 17 00:00:00 2001 From: Martin Ritchie Date: Wed, 18 Oct 2006 07:26:13 +0000 Subject: 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 --- .../test/src/org/apache/qpid/headers/MessageFactory.java | 13 +++++++++---- 1 file changed, 9 insertions(+), 4 deletions(-) (limited to 'java/client/test/src') 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"); -- cgit v1.2.1