QPID-8341: [Broker-J] Fix failing test
diff --git a/systests/qpid-systests-jms_1.1/src/test/java/org/apache/qpid/systests/jms_1_1/extensions/queue/RejectOverflowPolicyTest.java b/systests/qpid-systests-jms_1.1/src/test/java/org/apache/qpid/systests/jms_1_1/extensions/queue/RejectOverflowPolicyTest.java
index 770f6d0..5c12387 100644
--- a/systests/qpid-systests-jms_1.1/src/test/java/org/apache/qpid/systests/jms_1_1/extensions/queue/RejectOverflowPolicyTest.java
+++ b/systests/qpid-systests-jms_1.1/src/test/java/org/apache/qpid/systests/jms_1_1/extensions/queue/RejectOverflowPolicyTest.java
@@ -61,21 +61,29 @@
try
{
final Session producerSession = producerConnection.createSession(false, Session.AUTO_ACKNOWLEDGE);
- final MessageProducer producer = producerSession.createProducer(queue);
final Message firstMessage = nextMessage(0, producerSession);
final Message secondMessage = nextMessage(1, producerSession);
-
- producer.send(firstMessage);
try
{
- producer.send(secondMessage);
- fail("Message send should fail due to reject policy");
+ final MessageProducer producer = producerSession.createProducer(queue);
+ producer.send(firstMessage);
+ try
+ {
+ producer.send(secondMessage);
+ fail("Message send should fail due to reject policy");
+ }
+ catch (JMSException e)
+ {
+ // pass
+ }
}
- catch (JMSException e)
+ finally
{
- // pass
+ producerSession.close();
}
+ final Session producerSession2 = producerConnection.createSession(false, Session.AUTO_ACKNOWLEDGE);
+ final MessageProducer producer2 = producerSession2.createProducer(queue);
final Connection consumerConnection = getConnection();
try
{
@@ -89,7 +97,7 @@
consumerSession.commit();
- producer.send(secondMessage);
+ producer2.send(secondMessage);
Message message2 = consumer.receive(getReceiveTimeout());
assertNotNull("Message is not received", message2);
