Author: kwall
Date: Fri Jan 20 10:09:07 2017
New Revision: 1779597
URL: http://svn.apache.org/viewvc?rev=1779597&view=rev
Log:
QPID-7546: [System Tests] Enable AlertingTest for AMQP 1.0 for persistent
profiles
Modified:
qpid/java/trunk/systests/src/test/java/org/apache/qpid/server/logging/AlertingTest.java
Modified:
qpid/java/trunk/systests/src/test/java/org/apache/qpid/server/logging/AlertingTest.java
URL:
http://svn.apache.org/viewvc/qpid/java/trunk/systests/src/test/java/org/apache/qpid/server/logging/AlertingTest.java?rev=1779597&r1=1779596&r2=1779597&view=diff
==============================================================================
---
qpid/java/trunk/systests/src/test/java/org/apache/qpid/server/logging/AlertingTest.java
(original)
+++
qpid/java/trunk/systests/src/test/java/org/apache/qpid/server/logging/AlertingTest.java
Fri Jan 20 10:09:07 2017
@@ -40,6 +40,7 @@ public class AlertingTest extends Abstra
private static final int ALERT_LOG_WAIT_PERIOD = 5000;
private static final String MESSAGE_COUNT_ALERT = "MESSAGE_COUNT_ALERT";
+ @Override
public void setUp() throws Exception
{
_numMessages = 50;
@@ -71,11 +72,10 @@ public class AlertingTest extends Abstra
throws Exception
{
_connection = getConnection();
+ _connection.start();
_session = _connection.createSession(true, Session.SESSION_TRANSACTED);
_destination = createTestQueue(_session);
- // Consumer is only used to actually create the destination
- _session.createConsumer(_destination).close();
}
/**
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
