diff --git a/spring-integration-jdbc/src/test/java/org/springframework/integration/jdbc/JdbcMessageStoreChannelIntegrationTests-context.xml b/spring-integration-jdbc/src/test/java/org/springframework/integration/jdbc/JdbcMessageStoreChannelIntegrationTests-context.xml index 916ce47d06..289a5b802e 100644 --- a/spring-integration-jdbc/src/test/java/org/springframework/integration/jdbc/JdbcMessageStoreChannelIntegrationTests-context.xml +++ b/spring-integration-jdbc/src/test/java/org/springframework/integration/jdbc/JdbcMessageStoreChannelIntegrationTests-context.xml @@ -27,7 +27,7 @@ - + diff --git a/spring-integration-jdbc/src/test/java/org/springframework/integration/jdbc/JdbcMessageStoreChannelTests-context.xml b/spring-integration-jdbc/src/test/java/org/springframework/integration/jdbc/JdbcMessageStoreChannelTests-context.xml index 997a101146..ba41b34921 100644 --- a/spring-integration-jdbc/src/test/java/org/springframework/integration/jdbc/JdbcMessageStoreChannelTests-context.xml +++ b/spring-integration-jdbc/src/test/java/org/springframework/integration/jdbc/JdbcMessageStoreChannelTests-context.xml @@ -27,7 +27,7 @@ - + diff --git a/spring-integration-jdbc/src/test/java/org/springframework/integration/jdbc/JdbcMessageStoreChannelTests.java b/spring-integration-jdbc/src/test/java/org/springframework/integration/jdbc/JdbcMessageStoreChannelTests.java index 73dbf4bc90..225bf8601d 100644 --- a/spring-integration-jdbc/src/test/java/org/springframework/integration/jdbc/JdbcMessageStoreChannelTests.java +++ b/spring-integration-jdbc/src/test/java/org/springframework/integration/jdbc/JdbcMessageStoreChannelTests.java @@ -58,7 +58,7 @@ public class JdbcMessageStoreChannelTests { input.send(new GenericMessage("foo")); Service.await(10000); assertEquals(1, Service.messages.size()); - assertEquals(0, messageStore.getMessageGroup("input-queue").size()); + assertEquals(0, messageStore.getMessageGroup("JdbcMessageStoreChannelTests").size()); } @Test @@ -69,7 +69,7 @@ public class JdbcMessageStoreChannelTests { Service.await(10000); assertEquals(1, Service.messages.size()); // After a rollback in the poller the message is still waiting to be delivered - assertEquals(1, messageStore.getMessageGroup("input-queue").size()); + assertEquals(1, messageStore.getMessageGroup("JdbcMessageStoreChannelTests").size()); } @Test @@ -87,7 +87,7 @@ public class JdbcMessageStoreChannelTests { // So no activation assertEquals(0, Service.messages.size()); // But inside the transaction the message is still there - assertEquals(1, messageStore.getMessageGroup("input-queue").size()); + assertEquals(1, messageStore.getMessageGroup("JdbcMessageStoreChannelTests").size()); } public static class Service {