* fix bug: test expects JedisConnectionException
** I have mistaken while verifying seeing Exception's message * remove huge print messages
This commit is contained in:
@@ -529,8 +529,7 @@ public class PublishSubscribeCommandsTest extends JedisCommandTestBase {
|
|||||||
pubsub.unsubscribe();
|
pubsub.unsubscribe();
|
||||||
}
|
}
|
||||||
|
|
||||||
//@Test(expected = JedisConnectionException.class)
|
@Test(expected = JedisConnectionException.class)
|
||||||
@Test
|
|
||||||
public void handleClientOutputBufferLimitForSubscribeTooSlow() throws InterruptedException {
|
public void handleClientOutputBufferLimitForSubscribeTooSlow() throws InterruptedException {
|
||||||
final Thread t = new Thread(new Runnable() {
|
final Thread t = new Thread(new Runnable() {
|
||||||
public void run() {
|
public void run() {
|
||||||
@@ -561,7 +560,7 @@ public class PublishSubscribeCommandsTest extends JedisCommandTestBase {
|
|||||||
public void onMessage(String channel, String message) {
|
public void onMessage(String channel, String message) {
|
||||||
try {
|
try {
|
||||||
// wait 0.5 secs to slow down subscribe and client-output-buffer exceed
|
// wait 0.5 secs to slow down subscribe and client-output-buffer exceed
|
||||||
System.out.println("channel - " + channel + " / message - " + message);
|
//System.out.println("channel - " + channel + " / message - " + message);
|
||||||
Thread.sleep(500);
|
Thread.sleep(500);
|
||||||
} catch (Exception e) {
|
} catch (Exception e) {
|
||||||
try {
|
try {
|
||||||
|
|||||||
Reference in New Issue
Block a user