Spring/spring-integration
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Merge pull request #438 from ghillert/INT-2556

Browse Source
This commit is contained in:
Gary Russell
2012-05-14 18:26:09 -04:00
parent f564204466 1b03c40abc
commit 2486f0cad4
2 changed files with 10 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files

16
spring-integration-jpa/src/test/java/org/springframework/integration/jpa/inbound/JpaPollingChannelAdapterTests.java
View File

@@ -114,7 +114,7 @@ public class JpaPollingChannelAdapterTests {
assertNotNull(message);
assertNotNull(message.getPayload());
assertNotNull(message.getPayload() instanceof Collection<?>);
assertTrue(message.getPayload() instanceof Collection<?>);
Collection<?> primeNumbers = message.getPayload();
@@ -157,7 +157,7 @@ public class JpaPollingChannelAdapterTests {
assertNotNull(message);
assertNotNull(message.getPayload());
assertNotNull(message.getPayload() instanceof Collection<?>);
assertTrue(message.getPayload() instanceof Collection<?>);
Collection<?> primeNumbers = message.getPayload();
@@ -201,7 +201,7 @@ public class JpaPollingChannelAdapterTests {
assertNotNull(message);
assertNotNull(message.getPayload());
assertNotNull(message.getPayload() instanceof Collection<?>);
assertTrue(message.getPayload() instanceof Collection<?>);
Collection<?> primeNumbers = message.getPayload();
@@ -244,7 +244,7 @@ public class JpaPollingChannelAdapterTests {
assertNotNull(message);
assertNotNull(message.getPayload());
assertNotNull(message.getPayload() instanceof Collection<?>);
assertTrue(message.getPayload() instanceof Collection<?>);
Collection<?> students = message.getPayload();
@@ -293,7 +293,7 @@ public class JpaPollingChannelAdapterTests {
assertNotNull("Message is null.", message);
assertNotNull(message.getPayload());
assertNotNull(message.getPayload() instanceof Collection<?>);
assertTrue(message.getPayload() instanceof Collection<?>);
Collection<?> students = message.getPayload();
@@ -376,7 +376,7 @@ public class JpaPollingChannelAdapterTests {
assertNotNull("Message is null.", message);
assertNotNull(message.getPayload());
assertNotNull(message.getPayload() instanceof Collection<?>);
assertTrue(message.getPayload() instanceof Collection<?>);
Collection<?> students = message.getPayload();
@@ -423,7 +423,7 @@ public class JpaPollingChannelAdapterTests {
assertNotNull(message);
assertNotNull(message.getPayload());
assertNotNull(message.getPayload() instanceof Collection<?>);
assertTrue(message.getPayload() instanceof Collection<?>);
Collection<?> students = message.getPayload();
@@ -466,7 +466,7 @@ public class JpaPollingChannelAdapterTests {
assertNotNull(message);
assertNotNull(message.getPayload());
assertNotNull(message.getPayload() instanceof Collection<?>);
assertTrue(message.getPayload() instanceof Collection<?>);
Collection<?> students = message.getPayload();

4
spring-integration-jpa/src/test/java/org/springframework/integration/jpa/test/Consumer.java
View File

@@ -33,12 +33,12 @@ public final class Consumer {
private static final BlockingQueue<Message<Collection<?>>> MESSAGES = new LinkedBlockingQueue<Message<Collection<?>>>();
public void receive(Message<Collection<?>>message) {
public synchronized void receive(Message<Collection<?>>message) {
logger.info("Service Activator received Message: " + message);
MESSAGES.add(message);
}
public Message<Collection<?>> poll(long timeoutInMillis) throws InterruptedException {
public synchronized Message<Collection<?>> poll(long timeoutInMillis) throws InterruptedException {
return MESSAGES.poll(timeoutInMillis, TimeUnit.MILLISECONDS);
}