Temporarily disarm the actual persisting part of the message persister.
This commit is contained in:
parent
42910ebe14
commit
baf563e46d
|
@ -128,7 +128,7 @@ public class RedisClusterMessagePersister implements Managed {
|
||||||
int messageCount = 0;
|
int messageCount = 0;
|
||||||
List<MessageProtos.Envelope> messages;
|
List<MessageProtos.Envelope> messages;
|
||||||
|
|
||||||
do {
|
/* do {
|
||||||
messages = messagesCache.getMessagesToPersist(accountUuid, deviceId, MESSAGE_BATCH_LIMIT);
|
messages = messagesCache.getMessagesToPersist(accountUuid, deviceId, MESSAGE_BATCH_LIMIT);
|
||||||
|
|
||||||
for (final MessageProtos.Envelope message : messages) {
|
for (final MessageProtos.Envelope message : messages) {
|
||||||
|
@ -139,7 +139,7 @@ public class RedisClusterMessagePersister implements Managed {
|
||||||
|
|
||||||
messageCount++;
|
messageCount++;
|
||||||
}
|
}
|
||||||
} while (messages.size() == MESSAGE_BATCH_LIMIT);
|
} while (messages.size() == MESSAGE_BATCH_LIMIT); */
|
||||||
|
|
||||||
queueSizeHistogram.update(messageCount);
|
queueSizeHistogram.update(messageCount);
|
||||||
} finally {
|
} finally {
|
||||||
|
|
|
@ -3,6 +3,7 @@ package org.whispersystems.textsecuregcm.storage;
|
||||||
import com.google.protobuf.ByteString;
|
import com.google.protobuf.ByteString;
|
||||||
import org.apache.commons.lang3.RandomStringUtils;
|
import org.apache.commons.lang3.RandomStringUtils;
|
||||||
import org.junit.Before;
|
import org.junit.Before;
|
||||||
|
import org.junit.Ignore;
|
||||||
import org.junit.Test;
|
import org.junit.Test;
|
||||||
import org.whispersystems.textsecuregcm.entities.MessageProtos;
|
import org.whispersystems.textsecuregcm.entities.MessageProtos;
|
||||||
import org.whispersystems.textsecuregcm.push.PushSender;
|
import org.whispersystems.textsecuregcm.push.PushSender;
|
||||||
|
@ -27,6 +28,7 @@ import static org.mockito.Mockito.times;
|
||||||
import static org.mockito.Mockito.verify;
|
import static org.mockito.Mockito.verify;
|
||||||
import static org.mockito.Mockito.when;
|
import static org.mockito.Mockito.when;
|
||||||
|
|
||||||
|
@Ignore
|
||||||
public class RedisClusterMessagePersisterTest {
|
public class RedisClusterMessagePersisterTest {
|
||||||
|
|
||||||
private RedisClusterMessagesCache messagesCache;
|
private RedisClusterMessagesCache messagesCache;
|
||||||
|
|
Loading…
Reference in New Issue