Reactivate the message notification experiment.
This commit is contained in:
		
							parent
							
								
									0f71cc7864
								
							
						
					
					
						commit
						af34b43a8d
					
				| 
						 | 
					@ -83,7 +83,7 @@ public class RedisClusterMessagesCache extends RedisClusterPubSubAdapter<String,
 | 
				
			||||||
        this.removeQueueScript        = ClusterLuaScript.fromResource(redisCluster, "lua/remove_queue.lua",          ScriptOutputType.STATUS);
 | 
					        this.removeQueueScript        = ClusterLuaScript.fromResource(redisCluster, "lua/remove_queue.lua",          ScriptOutputType.STATUS);
 | 
				
			||||||
        this.getQueuesToPersistScript = ClusterLuaScript.fromResource(redisCluster, "lua/get_queues_to_persist.lua", ScriptOutputType.MULTI);
 | 
					        this.getQueuesToPersistScript = ClusterLuaScript.fromResource(redisCluster, "lua/get_queues_to_persist.lua", ScriptOutputType.MULTI);
 | 
				
			||||||
 | 
					
 | 
				
			||||||
        /* pubSubConnection.usePubSubConnection(connection -> {
 | 
					        pubSubConnection.usePubSubConnection(connection -> {
 | 
				
			||||||
            connection.addListener(this);
 | 
					            connection.addListener(this);
 | 
				
			||||||
            connection.getResources().eventBus().get()
 | 
					            connection.getResources().eventBus().get()
 | 
				
			||||||
                    .filter(event -> event instanceof ClusterTopologyChangedEvent)
 | 
					                    .filter(event -> event instanceof ClusterTopologyChangedEvent)
 | 
				
			||||||
| 
						 | 
					@ -93,7 +93,7 @@ public class RedisClusterMessagesCache extends RedisClusterPubSubAdapter<String,
 | 
				
			||||||
                    });
 | 
					                    });
 | 
				
			||||||
        });
 | 
					        });
 | 
				
			||||||
 | 
					
 | 
				
			||||||
        subscribeForKeyspaceNotifications(); */
 | 
					        subscribeForKeyspaceNotifications();
 | 
				
			||||||
    }
 | 
					    }
 | 
				
			||||||
 | 
					
 | 
				
			||||||
    private void subscribeForKeyspaceNotifications() {
 | 
					    private void subscribeForKeyspaceNotifications() {
 | 
				
			||||||
| 
						 | 
					
 | 
				
			||||||
| 
						 | 
					@ -3,7 +3,6 @@ package org.whispersystems.textsecuregcm.storage;
 | 
				
			||||||
import io.lettuce.core.cluster.SlotHash;
 | 
					import io.lettuce.core.cluster.SlotHash;
 | 
				
			||||||
import junitparams.Parameters;
 | 
					import junitparams.Parameters;
 | 
				
			||||||
import org.junit.Before;
 | 
					import org.junit.Before;
 | 
				
			||||||
import org.junit.Ignore;
 | 
					 | 
				
			||||||
import org.junit.Test;
 | 
					import org.junit.Test;
 | 
				
			||||||
 | 
					
 | 
				
			||||||
import java.nio.charset.StandardCharsets;
 | 
					import java.nio.charset.StandardCharsets;
 | 
				
			||||||
| 
						 | 
					@ -104,7 +103,6 @@ public class RedisClusterMessagesCacheTest extends AbstractMessagesCacheTest {
 | 
				
			||||||
    }
 | 
					    }
 | 
				
			||||||
 | 
					
 | 
				
			||||||
    @Test(timeout = 5_000L)
 | 
					    @Test(timeout = 5_000L)
 | 
				
			||||||
    @Ignore
 | 
					 | 
				
			||||||
    public void testNotifyListenerNewMessage() throws InterruptedException {
 | 
					    public void testNotifyListenerNewMessage() throws InterruptedException {
 | 
				
			||||||
        final AtomicBoolean notified    = new AtomicBoolean(false);
 | 
					        final AtomicBoolean notified    = new AtomicBoolean(false);
 | 
				
			||||||
        final UUID          messageGuid = UUID.randomUUID();
 | 
					        final UUID          messageGuid = UUID.randomUUID();
 | 
				
			||||||
| 
						 | 
					@ -136,7 +134,6 @@ public class RedisClusterMessagesCacheTest extends AbstractMessagesCacheTest {
 | 
				
			||||||
    }
 | 
					    }
 | 
				
			||||||
 | 
					
 | 
				
			||||||
    @Test(timeout = 5_000L)
 | 
					    @Test(timeout = 5_000L)
 | 
				
			||||||
    @Ignore
 | 
					 | 
				
			||||||
    public void testNotifyListenerPersisted() throws InterruptedException {
 | 
					    public void testNotifyListenerPersisted() throws InterruptedException {
 | 
				
			||||||
        final AtomicBoolean notified    = new AtomicBoolean(false);
 | 
					        final AtomicBoolean notified    = new AtomicBoolean(false);
 | 
				
			||||||
 | 
					
 | 
				
			||||||
| 
						 | 
					
 | 
				
			||||||
		Loading…
	
		Reference in New Issue