diff options
Diffstat (limited to 'java')
3 files changed, 8 insertions, 7 deletions
diff --git a/java/systests/src/main/java/org/apache/qpid/server/logging/DurableQueueLoggingTest.java b/java/systests/src/main/java/org/apache/qpid/server/logging/DurableQueueLoggingTest.java index b83c284ef4..ddbed2aab8 100644 --- a/java/systests/src/main/java/org/apache/qpid/server/logging/DurableQueueLoggingTest.java +++ b/java/systests/src/main/java/org/apache/qpid/server/logging/DurableQueueLoggingTest.java @@ -57,11 +57,12 @@ public class DurableQueueLoggingTest extends AbstractTestLogging public void setUp() throws Exception { super.setUp(); + //Ensure we only have logs from our test + _monitor.reset(); + _connection = getConnection(); _session = _connection.createSession(false, Session.AUTO_ACKNOWLEDGE); _durable = true; - //Ensure we only have logs from our - _monitor.reset(); } /** diff --git a/java/systests/src/main/java/org/apache/qpid/server/logging/QueueLoggingTest.java b/java/systests/src/main/java/org/apache/qpid/server/logging/QueueLoggingTest.java index 1b154f70ac..a8b532d772 100644 --- a/java/systests/src/main/java/org/apache/qpid/server/logging/QueueLoggingTest.java +++ b/java/systests/src/main/java/org/apache/qpid/server/logging/QueueLoggingTest.java @@ -53,11 +53,11 @@ public class QueueLoggingTest extends AbstractTestLogging public void setUp() throws Exception { super.setUp(); - _connection = getConnection(); - _session = _connection.createSession(false, Session.AUTO_ACKNOWLEDGE); - //Remove broker startup logging messages _monitor.reset(); + + _connection = getConnection(); + _session = _connection.createSession(false, Session.AUTO_ACKNOWLEDGE); } /** diff --git a/java/systests/src/main/java/org/apache/qpid/server/logging/SubscriptionLoggingTest.java b/java/systests/src/main/java/org/apache/qpid/server/logging/SubscriptionLoggingTest.java index 7283f7f0d0..11e345de5e 100644 --- a/java/systests/src/main/java/org/apache/qpid/server/logging/SubscriptionLoggingTest.java +++ b/java/systests/src/main/java/org/apache/qpid/server/logging/SubscriptionLoggingTest.java @@ -51,6 +51,8 @@ public class SubscriptionLoggingTest extends AbstractTestLogging public void setUp() throws Exception { super.setUp(); + //Remove broker startup logging messages + _monitor.reset(); _connection = getConnection(); @@ -58,8 +60,6 @@ public class SubscriptionLoggingTest extends AbstractTestLogging _queue = (Queue) getInitialContext().lookup(QUEUE); _topic = (Topic) getInitialContext().lookup(TOPIC); - - _monitor.reset(); } /** |