Add a test to make sure that we don't double-insert messages with the same GUID.
This commit is contained in:
parent
3016269268
commit
1ccfe928f7
|
@ -72,6 +72,17 @@ public class MessagesCacheTest extends AbstractRedisClusterTest {
|
||||||
assertTrue(messagesCache.insert(messageGuid, DESTINATION_UUID, DESTINATION_DEVICE_ID, generateRandomMessage(messageGuid, sealedSender)) > 0);
|
assertTrue(messagesCache.insert(messageGuid, DESTINATION_UUID, DESTINATION_DEVICE_ID, generateRandomMessage(messageGuid, sealedSender)) > 0);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@Test
|
||||||
|
public void testDoubleInsertGuid() {
|
||||||
|
final UUID duplicateGuid = UUID.randomUUID();
|
||||||
|
final MessageProtos.Envelope duplicateMessage = generateRandomMessage(duplicateGuid, false);
|
||||||
|
|
||||||
|
final long firstId = messagesCache.insert(duplicateGuid, DESTINATION_UUID, DESTINATION_DEVICE_ID, duplicateMessage);
|
||||||
|
final long secondId = messagesCache.insert(duplicateGuid, DESTINATION_UUID, DESTINATION_DEVICE_ID, duplicateMessage);
|
||||||
|
|
||||||
|
assertEquals(firstId, secondId);
|
||||||
|
}
|
||||||
|
|
||||||
@Test
|
@Test
|
||||||
public void testRepairMetadata() {
|
public void testRepairMetadata() {
|
||||||
final int distinctUuidCount = 17;
|
final int distinctUuidCount = 17;
|
||||||
|
|
Loading…
Reference in New Issue