Skip to content

Commit 4ad12c4

Browse files
committed
Format test
1 parent 9bdb917 commit 4ad12c4

File tree

1 file changed

+7
-18
lines changed

1 file changed

+7
-18
lines changed

src/test/java/com/rabbitmq/integration/tests/AmqpPropertiesCustomiserIT.java

Lines changed: 7 additions & 18 deletions
Original file line numberDiff line numberDiff line change
@@ -8,23 +8,13 @@
88
import com.rabbitmq.jms.client.AmqpPropertiesCustomiser;
99
import org.junit.Test;
1010

11-
import javax.jms.BytesMessage;
12-
import javax.jms.DeliveryMode;
1311
import javax.jms.Message;
1412
import javax.jms.Queue;
15-
import javax.jms.QueueReceiver;
1613
import javax.jms.QueueSender;
1714
import javax.jms.QueueSession;
1815
import javax.jms.Session;
1916
import javax.jms.TextMessage;
20-
import java.util.Arrays;
21-
import java.util.Enumeration;
22-
import java.util.HashMap;
23-
import java.util.HashSet;
24-
import java.util.Map;
25-
import java.util.Set;
26-
27-
import static org.junit.Assert.assertArrayEquals;
17+
2818
import static org.junit.Assert.assertEquals;
2919
import static org.junit.Assert.assertNotNull;
3020

@@ -33,9 +23,9 @@
3323
*/
3424
public class AmqpPropertiesCustomiserIT extends AbstractAmqpITQueue {
3525

36-
private static final String QUEUE_NAME = "test.queue."+AmqpPropertiesCustomiserIT.class.getCanonicalName();
3726
public static final String MESSAGE = "hello";
3827
public static final String TEXT_PLAIN = "text/plain";
28+
private static final String QUEUE_NAME = "test.queue." + AmqpPropertiesCustomiserIT.class.getCanonicalName();
3929

4030
@Override
4131
protected void customise(RMQConnectionFactory connectionFactory) {
@@ -53,11 +43,11 @@ public AMQP.BasicProperties.Builder customise(AMQP.BasicProperties.Builder build
5343
public void customiserIsApplied() throws Exception {
5444

5545
channel.queueDeclare(QUEUE_NAME,
56-
false, // durable
57-
true, // exclusive
58-
true, // autoDelete
59-
null // options
60-
);
46+
false, // durable
47+
true, // exclusive
48+
true, // autoDelete
49+
null // options
50+
);
6151

6252
queueConn.start();
6353
QueueSession queueSession = queueConn.createQueueSession(false, Session.DUPS_OK_ACKNOWLEDGE);
@@ -80,5 +70,4 @@ public void customiserIsApplied() throws Exception {
8070

8171
assertEquals("body of response is not correct", TEXT_PLAIN, response.getProps().getContentType());
8272
}
83-
8473
}

0 commit comments

Comments
 (0)