X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?p=controller.git;a=blobdiff_plain;f=opendaylight%2Fmd-sal%2Fsal-clustering-commons%2Fsrc%2Ftest%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fcluster%2Fmessaging%2FMessageSlicerTest.java;fp=opendaylight%2Fmd-sal%2Fsal-clustering-commons%2Fsrc%2Ftest%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fcluster%2Fmessaging%2FMessageSlicerTest.java;h=ac6ab2e447b52e61b49e00c348f4af245886795e;hp=df12ad2c1158c5e5b63b95c758261dbe8321b954;hb=da0c512a2fc26de5a161b13eb91650af23450829;hpb=a7e7fbdd3cc51a384778b557854849c9e0470eaf diff --git a/opendaylight/md-sal/sal-clustering-commons/src/test/java/org/opendaylight/controller/cluster/messaging/MessageSlicerTest.java b/opendaylight/md-sal/sal-clustering-commons/src/test/java/org/opendaylight/controller/cluster/messaging/MessageSlicerTest.java index df12ad2c11..ac6ab2e447 100644 --- a/opendaylight/md-sal/sal-clustering-commons/src/test/java/org/opendaylight/controller/cluster/messaging/MessageSlicerTest.java +++ b/opendaylight/md-sal/sal-clustering-commons/src/test/java/org/opendaylight/controller/cluster/messaging/MessageSlicerTest.java @@ -138,7 +138,7 @@ public class MessageSlicerTest extends AbstractMessagingTest { final int expiryDuration = 200; try (MessageSlicer slicer = MessageSlicer.builder().messageSliceSize(1) .logContext("testCheckExpiredSlicedMessageState") - .filedBackedStreamFactory(mockFiledBackedStreamFactory) + .fileBackedStreamFactory(mockFiledBackedStreamFactory) .expireStateAfterInactivity(expiryDuration, TimeUnit.MILLISECONDS).build()) { slice(slicer, IDENTIFIER, new BytesMessage(new byte[]{1, 2}), testProbe.ref(), testProbe.ref(), mockOnFailureCallback); @@ -159,7 +159,7 @@ public class MessageSlicerTest extends AbstractMessagingTest { private MessageSlicer newMessageSlicer(String logContext, final int messageSliceSize) { return MessageSlicer.builder().messageSliceSize(messageSliceSize).logContext(logContext) - .filedBackedStreamFactory(mockFiledBackedStreamFactory).build(); + .fileBackedStreamFactory(mockFiledBackedStreamFactory).build(); } static void slice(MessageSlicer slicer, Identifier identifier, Serializable message, ActorRef sendTo,