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

DATAKV-74

Browse Source
This commit is contained in:
Costin Leau
2011-07-01 15:09:26 +03:00
parent 8c3eb982ea
commit 7c0295aacc
1 changed files with 5 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
spring-data-redis/src/test/java/org/springframework/data/keyvalue/redis/connection/AbstractConnectionIntegrationTests.java
View File

@@ -189,7 +189,7 @@ public abstract class AbstractConnectionIntegrationTests {
}
// pub sub test
@Test
public void testPubSub() throws Exception {
final BlockingDeque<Message> queue = new LinkedBlockingDeque<Message>();
@@ -243,6 +243,7 @@ public abstract class AbstractConnectionIntegrationTests {
assertEquals(3, queue.size());
}
@Test
public void testPubSubWithNamedChannels() {
final byte[] expectedChannel = "channel1".getBytes();
final byte[] expectedMessage = "msg".getBytes();
@@ -261,7 +262,7 @@ public abstract class AbstractConnectionIntegrationTests {
public void run() {
// sleep 1 second to let the registration happen
try {
Thread.currentThread().sleep(1000);
Thread.currentThread().sleep(2000);
} catch (InterruptedException ex) {
throw new RuntimeException(ex);
}
@@ -279,6 +280,7 @@ public abstract class AbstractConnectionIntegrationTests {
connection.subscribe(listener, expectedChannel);
}
@Test
public void testPubSubWithPatterns() {
final byte[] expectedPattern = "channel*".getBytes();
final byte[] expectedMessage = "msg".getBytes();
@@ -298,7 +300,7 @@ public abstract class AbstractConnectionIntegrationTests {
public void run() {
// sleep 1 second to let the registration happen
try {
Thread.currentThread().sleep(1000);
Thread.currentThread().sleep(1500);
} catch (InterruptedException ex) {
throw new RuntimeException(ex);
}