You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@sling.apache.org by to...@apache.org on 2014/01/22 11:49:30 UTC

svn commit: r1560310 - /sling/trunk/contrib/extensions/replication/src/test/java/org/apache/sling/replication/serialization/impl/DefaultReplicationPackageImporterTest.java

Author: tommaso
Date: Wed Jan 22 10:49:30 2014
New Revision: 1560310

URL: http://svn.apache.org/r1560310
Log:
SLING-3330 - added asynchronous package import, fixed test

Modified:
    sling/trunk/contrib/extensions/replication/src/test/java/org/apache/sling/replication/serialization/impl/DefaultReplicationPackageImporterTest.java

Modified: sling/trunk/contrib/extensions/replication/src/test/java/org/apache/sling/replication/serialization/impl/DefaultReplicationPackageImporterTest.java
URL: http://svn.apache.org/viewvc/sling/trunk/contrib/extensions/replication/src/test/java/org/apache/sling/replication/serialization/impl/DefaultReplicationPackageImporterTest.java?rev=1560310&r1=1560309&r2=1560310&view=diff
==============================================================================
--- sling/trunk/contrib/extensions/replication/src/test/java/org/apache/sling/replication/serialization/impl/DefaultReplicationPackageImporterTest.java (original)
+++ sling/trunk/contrib/extensions/replication/src/test/java/org/apache/sling/replication/serialization/impl/DefaultReplicationPackageImporterTest.java Wed Jan 22 10:49:30 2014
@@ -21,8 +21,6 @@ package org.apache.sling.replication.ser
 import java.io.ByteArrayInputStream;
 import java.io.InputStream;
 import java.lang.reflect.Field;
-import java.util.Collection;
-import java.util.LinkedList;
 import java.util.Map;
 import org.apache.sling.event.jobs.Job;
 import org.apache.sling.event.jobs.JobBuilder;
@@ -113,13 +111,10 @@ public class DefaultReplicationPackageIm
         ReplicationPackageBuilder packageBuilder = mock(ReplicationPackageBuilder.class);
         ReplicationPackage replicationPackage = new VoidReplicationPackage(new ReplicationRequest(System.currentTimeMillis(), ReplicationActionType.DELETE, "/content"), "void");
         when(packageBuilder.readPackage(any(InputStream.class), eq(true))).thenReturn(replicationPackage);
-        Collection<ReplicationPackageBuilder> packageBuilders = new LinkedList<ReplicationPackageBuilder>();
-        packageBuilders.add(packageBuilder);
-        when(replicationPackageBuilderProvider.getAvailableReplicationPackageBuilders()).thenReturn(packageBuilders);
         replicationPackageBuilderProviderField.set(importer, replicationPackageBuilderProvider);
 
         InputStream stream = mock(InputStream.class);
-        assertTrue(importer.importStream(stream, null));
+        assertFalse(importer.importStream(stream, null));
     }
 
     @Test