You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@usergrid.apache.org by sn...@apache.org on 2014/11/04 17:11:47 UTC
[3/5] git commit: Added an extra test to check that multiple
listeners function correctly.
Added an extra test to check that multiple listeners function correctly.
Project: http://git-wip-us.apache.org/repos/asf/incubator-usergrid/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-usergrid/commit/e9f876c5
Tree: http://git-wip-us.apache.org/repos/asf/incubator-usergrid/tree/e9f876c5
Diff: http://git-wip-us.apache.org/repos/asf/incubator-usergrid/diff/e9f876c5
Branch: refs/heads/two-dot-o-events
Commit: e9f876c5c1b336cdffff85c06457bc926dfe479d
Parents: 54a64e6
Author: grey <gr...@apigee.com>
Authored: Mon Nov 3 15:44:56 2014 -0800
Committer: grey <gr...@apigee.com>
Committed: Mon Nov 3 15:44:56 2014 -0800
----------------------------------------------------------------------
.../impl/EntityVersionCreatedTaskTest.java | 72 ++++++++++++++++++++
1 file changed, 72 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-usergrid/blob/e9f876c5/stack/corepersistence/collection/src/test/java/org/apache/usergrid/persistence/collection/impl/EntityVersionCreatedTaskTest.java
----------------------------------------------------------------------
diff --git a/stack/corepersistence/collection/src/test/java/org/apache/usergrid/persistence/collection/impl/EntityVersionCreatedTaskTest.java b/stack/corepersistence/collection/src/test/java/org/apache/usergrid/persistence/collection/impl/EntityVersionCreatedTaskTest.java
index b25b5b4..9d72665 100644
--- a/stack/corepersistence/collection/src/test/java/org/apache/usergrid/persistence/collection/impl/EntityVersionCreatedTaskTest.java
+++ b/stack/corepersistence/collection/src/test/java/org/apache/usergrid/persistence/collection/impl/EntityVersionCreatedTaskTest.java
@@ -17,22 +17,45 @@
*/
package org.apache.usergrid.persistence.collection.impl;
+import com.google.common.base.Optional;
import com.google.common.util.concurrent.ListenableFuture;
+import com.netflix.astyanax.Keyspace;
+import com.netflix.astyanax.MutationBatch;
import com.netflix.astyanax.connectionpool.exceptions.ConnectionException;
+
+import java.util.ArrayList;
+import java.util.HashSet;
import java.util.Iterator;
+import java.util.List;
+import java.util.NoSuchElementException;
import java.util.Set;
+import java.util.UUID;
import java.util.concurrent.CountDownLatch;
import java.util.concurrent.ExecutionException;
import org.apache.usergrid.persistence.collection.CollectionScope;
+import org.apache.usergrid.persistence.collection.MvccEntity;
import org.apache.usergrid.persistence.collection.event.EntityVersionCreated;
+import org.apache.usergrid.persistence.collection.event.EntityVersionDeleted;
+import org.apache.usergrid.persistence.collection.mvcc.MvccEntitySerializationStrategy;
+import org.apache.usergrid.persistence.collection.mvcc.MvccLogEntrySerializationStrategy;
+import org.apache.usergrid.persistence.collection.mvcc.entity.impl.MvccEntityImpl;
+import org.apache.usergrid.persistence.collection.serialization.SerializationFig;
+import org.apache.usergrid.persistence.collection.serialization.UniqueValueSerializationStrategy;
+import org.apache.usergrid.persistence.collection.util.LogEntryMock;
import org.apache.usergrid.persistence.core.task.NamedTaskExecutorImpl;
import org.apache.usergrid.persistence.core.task.TaskExecutor;
import org.apache.usergrid.persistence.model.entity.Entity;
import org.apache.usergrid.persistence.model.entity.Id;
import org.apache.usergrid.persistence.model.entity.SimpleId;
+import org.apache.usergrid.persistence.model.util.UUIDGenerator;
+
import org.junit.AfterClass;
import org.junit.Test;
+
+import static org.mockito.Matchers.any;
+import static org.mockito.Matchers.same;
import static org.mockito.Mockito.mock;
+import static org.mockito.Mockito.times;
import static org.mockito.Mockito.verify;
import static org.mockito.Mockito.when;
@@ -128,6 +151,55 @@ public class EntityVersionCreatedTaskTest {
}
+ @Test(timeout=10000)
+ public void multipleListener()
+ throws ExecutionException, InterruptedException, ConnectionException {
+
+ final int sizeToReturn = 3;
+
+ final Set<EntityVersionCreated> listeners = mock( Set.class );
+ final Iterator<EntityVersionCreated> helper = mock(Iterator.class);
+
+ when ( listeners.size()).thenReturn( 3 );
+ when ( listeners.iterator()).thenReturn( helper );
+
+ final Id applicationId = new SimpleId( "application" );
+
+ final CollectionScope appScope = new CollectionScopeImpl(
+ applicationId, applicationId, "users" );
+
+ final Id entityId = new SimpleId( "user" );
+ final Entity entity = new Entity( entityId );
+
+ // start the task
+
+ EntityVersionCreatedTask entityVersionCreatedTask =
+ new EntityVersionCreatedTask( appScope, listeners, entity);
+
+ final CountDownLatch latch = new CountDownLatch( sizeToReturn );
+
+ final EntityVersionCreatedTest listener1 = new EntityVersionCreatedTest(latch);
+ final EntityVersionCreatedTest listener2 = new EntityVersionCreatedTest(latch);
+ final EntityVersionCreatedTest listener3 = new EntityVersionCreatedTest(latch);
+
+ when ( helper.next() ).thenReturn( listener1,listener2,listener3);
+
+ ListenableFuture<Void> future = taskExecutor.submit( entityVersionCreatedTask );
+
+ //wait for the task
+ //intentionally fails due to difficulty mocking observable
+ try {
+ future.get();
+ }catch(Exception e){
+ ;
+ }
+
+ //mocked listener makes sure that the task is called
+ verify( listeners ).size();
+ //verifies that the observable made listener iterate.
+ verify( listeners ).iterator();
+ }
+
private static class EntityVersionCreatedTest implements EntityVersionCreated {
final CountDownLatch invocationLatch;