Apache
/
activemq-artemis
mirror of https://github.com/apache/activemq-artemis.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

NO-JIRA - fixing up some broken tests 

updated tests that rely on logging id's
This commit is contained in:
andytaylor 2018-10-11 10:25:14 +01:00
parent d4ac3c2f87
commit d8c34dd3d7
1 changed files with 8 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/cli/QueueCommandTest.java
View File

@ -59,7 +59,7 @@ public class QueueCommandTest extends JMSTestBase {
command.setMulticast(true); command.setMulticast(true);
command.setAnycast(false); command.setAnycast(false);
command.execute(new ActionContext(System.in, new PrintStream(output), new PrintStream(error))); command.execute(new ActionContext(System.in, new PrintStream(output), new PrintStream(error)));
checkExecutionFailure(command, "AMQ119203"); checkExecutionFailure(command, "AMQ229203");
assertFalse(server.queueQuery(new SimpleString(queueName)).isExists()); assertFalse(server.queueQuery(new SimpleString(queueName)).isExists());
} }
@ -137,7 +137,7 @@ public class QueueCommandTest extends JMSTestBase {
command.setAnycast(false); command.setAnycast(false);
command.execute(new ActionContext()); command.execute(new ActionContext());
command.execute(new ActionContext(System.in, new PrintStream(output), new PrintStream(error))); command.execute(new ActionContext(System.in, new PrintStream(output), new PrintStream(error)));
checkExecutionFailure(command, "AMQ119019"); checkExecutionFailure(command, "AMQ229019");
} }
@Test @Test
@ -167,7 +167,7 @@ public class QueueCommandTest extends JMSTestBase {
DeleteQueue delete = new DeleteQueue(); DeleteQueue delete = new DeleteQueue();
delete.setName(queueName.toString()); delete.setName(queueName.toString());
delete.execute(new ActionContext(System.in, new PrintStream(output), new PrintStream(error))); delete.execute(new ActionContext(System.in, new PrintStream(output), new PrintStream(error)));
checkExecutionFailure(delete, "AMQ119017"); checkExecutionFailure(delete, "AMQ229017");
assertFalse(server.queueQuery(queueName).isExists()); assertFalse(server.queueQuery(queueName).isExists());
} }
@ -189,7 +189,7 @@ public class QueueCommandTest extends JMSTestBase {
DeleteQueue delete = new DeleteQueue(); DeleteQueue delete = new DeleteQueue();
delete.setName(queueName.toString()); delete.setName(queueName.toString());
delete.execute(new ActionContext(System.in, new PrintStream(output), new PrintStream(error))); delete.execute(new ActionContext(System.in, new PrintStream(output), new PrintStream(error)));
checkExecutionFailure(delete, "AMQ119025"); checkExecutionFailure(delete, "AMQ229025");
} }
@Test @Test
@ -292,7 +292,7 @@ public class QueueCommandTest extends JMSTestBase {
updateQueue.setMaxConsumers(-1); updateQueue.setMaxConsumers(-1);
updateQueue.execute(new ActionContext(System.in, new PrintStream(output), new PrintStream(error))); updateQueue.execute(new ActionContext(System.in, new PrintStream(output), new PrintStream(error)));
checkExecutionFailure(updateQueue, "AMQ119211"); checkExecutionFailure(updateQueue, "AMQ229211");
final QueueQueryResult queueQueryResult = server.queueQuery(queueNameString); final QueueQueryResult queueQueryResult = server.queueQuery(queueNameString);
assertEquals("maxConsumers", oldMaxConsumers, queueQueryResult.getMaxConsumers()); assertEquals("maxConsumers", oldMaxConsumers, queueQueryResult.getMaxConsumers());
@ -322,7 +322,7 @@ public class QueueCommandTest extends JMSTestBase {
updateQueue.setMaxConsumers(newMaxConsumers); updateQueue.setMaxConsumers(newMaxConsumers);
updateQueue.execute(new ActionContext(System.in, new PrintStream(output), new PrintStream(error))); updateQueue.execute(new ActionContext(System.in, new PrintStream(output), new PrintStream(error)));
checkExecutionFailure(updateQueue, "AMQ119210"); checkExecutionFailure(updateQueue, "AMQ229210");
final QueueQueryResult queueQueryResult = server.queueQuery(queueNameString); final QueueQueryResult queueQueryResult = server.queueQuery(queueNameString);
assertEquals("maxConsumers", oldMaxConsumers, queueQueryResult.getMaxConsumers()); assertEquals("maxConsumers", oldMaxConsumers, queueQueryResult.getMaxConsumers());
@ -335,7 +335,7 @@ public class QueueCommandTest extends JMSTestBase {
UpdateQueue updateQueue = new UpdateQueue(); UpdateQueue updateQueue = new UpdateQueue();
updateQueue.setName(queueName.toString()); updateQueue.setName(queueName.toString());
updateQueue.execute(new ActionContext(System.in, new PrintStream(output), new PrintStream(error))); updateQueue.execute(new ActionContext(System.in, new PrintStream(output), new PrintStream(error)));
checkExecutionFailure(updateQueue, "AMQ119017: Queue " + queueName + " does not exist"); checkExecutionFailure(updateQueue, "AMQ229017: Queue " + queueName + " does not exist");
assertFalse(server.queueQuery(queueName).isExists()); assertFalse(server.queueQuery(queueName).isExists());
} }
@ -363,7 +363,7 @@ public class QueueCommandTest extends JMSTestBase {
PurgeQueue purge = new PurgeQueue(); PurgeQueue purge = new PurgeQueue();
purge.setName(queueName.toString()); purge.setName(queueName.toString());
purge.execute(new ActionContext(System.in, new PrintStream(output), new PrintStream(error))); purge.execute(new ActionContext(System.in, new PrintStream(output), new PrintStream(error)));
checkExecutionFailure(purge, "AMQ119067: Cannot find resource with name queue." + queueName); checkExecutionFailure(purge, "AMQ229067: Cannot find resource with name queue." + queueName);
assertFalse(server.queueQuery(queueName).isExists()); assertFalse(server.queueQuery(queueName).isExists());
} }