Repository: usergrid Updated Branches: refs/heads/usergrid-1318-queue 71fe06fec -> 9f2863fd6
http://git-wip-us.apache.org/repos/asf/usergrid/blob/7be8c274/stack/corepersistence/queue/src/test/java/org/apache/usergrid/persistence/qakka/serialization/queuemessages/DatabaseQueueMessageSerializationTest.java ---------------------------------------------------------------------- diff --git a/stack/corepersistence/queue/src/test/java/org/apache/usergrid/persistence/qakka/serialization/queuemessages/DatabaseQueueMessageSerializationTest.java b/stack/corepersistence/queue/src/test/java/org/apache/usergrid/persistence/qakka/serialization/queuemessages/DatabaseQueueMessageSerializationTest.java index 4ea6de3..88d89de 100644 --- a/stack/corepersistence/queue/src/test/java/org/apache/usergrid/persistence/qakka/serialization/queuemessages/DatabaseQueueMessageSerializationTest.java +++ b/stack/corepersistence/queue/src/test/java/org/apache/usergrid/persistence/qakka/serialization/queuemessages/DatabaseQueueMessageSerializationTest.java @@ -21,11 +21,13 @@ package org.apache.usergrid.persistence.qakka.serialization.queuemessages; import com.datastax.driver.core.DataType; import com.datastax.driver.core.ProtocolVersion; +import com.google.inject.Injector; import org.apache.commons.lang.RandomStringUtils; import org.apache.usergrid.persistence.qakka.AbstractTest; import org.apache.usergrid.persistence.qakka.exceptions.QakkaRuntimeException; import org.apache.usergrid.persistence.qakka.serialization.sharding.Shard; import org.apache.usergrid.persistence.qakka.core.QakkaUtils; +import org.apache.usergrid.persistence.qakka.serialization.sharding.ShardSerialization; import org.junit.Test; import java.io.*; @@ -64,19 +66,27 @@ public class DatabaseQueueMessageSerializationTest extends AbstractTest { @Test public void deleteMessage(){ + Injector injector = getInjector(); + QueueMessageSerialization queueMessageSerialization = - getInjector().getInstance( QueueMessageSerialization.class ); + injector.getInstance( QueueMessageSerialization.class ); - Shard shard1 = new Shard("test", "region1", Shard.Type.DEFAULT, 100L, null); + ShardSerialization shardSerialization = + injector.getInstance( ShardSerialization.class ); - UUID messageId = QakkaUtils.getTimeUuid(); String queueName = "dqmst_queue_" + RandomStringUtils.randomAlphanumeric( 20 ); + String region = "dummy_region"; + + Shard shard1 = new Shard(queueName, region, Shard.Type.DEFAULT, 1L, null); + shardSerialization.createShard( shard1 ); + + UUID messageId = QakkaUtils.getTimeUuid(); DatabaseQueueMessage message = new DatabaseQueueMessage( messageId, DatabaseQueueMessage.Type.DEFAULT, queueName, - "dummy_region", + region, shard1.getShardId(), System.currentTimeMillis(), null, null ); @@ -85,14 +95,14 @@ public class DatabaseQueueMessageSerializationTest extends AbstractTest { queueMessageSerialization.deleteMessage( queueName, - "dummy_region", + region, shard1.getShardId(), DatabaseQueueMessage.Type.DEFAULT, queueMessageId ); assertNull( queueMessageSerialization.loadMessage( queueName, - "dummy_region", + region, shard1.getShardId(), DatabaseQueueMessage.Type.DEFAULT, queueMessageId http://git-wip-us.apache.org/repos/asf/usergrid/blob/7be8c274/stack/corepersistence/queue/src/test/resources/log4j.properties ---------------------------------------------------------------------- diff --git a/stack/corepersistence/queue/src/test/resources/log4j.properties b/stack/corepersistence/queue/src/test/resources/log4j.properties index 2653fd6..c7d53a3 100644 --- a/stack/corepersistence/queue/src/test/resources/log4j.properties +++ b/stack/corepersistence/queue/src/test/resources/log4j.properties @@ -25,6 +25,6 @@ log4j.logger.org.apache.cassandra=WARN log4j.logger.org.glassfish=WARN log4j.logger.org.apache.usergrid=INFO -log4j.logger.org.apache.usergrid.persistence.qakka=INFO -log4j.logger.org.apache.usergrid.persistence.queue=INFO +#log4j.logger.org.apache.usergrid.persistence.qakka=DEBUG +#log4j.logger.org.apache.usergrid.persistence.queue=DEBUG log4j.logger.org.apache.usergrid.corepersistence.asyncevents=INFO
