filedBackedStreamFactory should be fileBackedStreamFactory.
Change-Id: Ib0b65d68d37c5b0ded4f1739d4ddc578973fe6ec
Signed-off-by: Tom Pantelis <tompantelis@gmail.com>
.getSyncIndexThreshold());
appendEntriesMessageAssembler = MessageAssembler.builder().logContext(logName())
- .filedBackedStreamFactory(context.getFileBackedOutputStreamFactory())
+ .fileBackedStreamFactory(context.getFileBackedOutputStreamFactory())
.assembledMessageCallback((message, sender) -> handleMessage(sender, message)).build();
if (context.getPeerIds().isEmpty() && getLeaderId() == null) {
private static final Logger LOG = LoggerFactory.getLogger(MessageAssembler.class);
private final Cache<Identifier, AssembledMessageState> stateCache;
- private final FileBackedOutputStreamFactory filedBackedStreamFactory;
+ private final FileBackedOutputStreamFactory fileBackedStreamFactory;
private final BiConsumer<Object, ActorRef> assembledMessageCallback;
private final String logContext;
private MessageAssembler(Builder builder) {
- this.filedBackedStreamFactory = Preconditions.checkNotNull(builder.filedBackedStreamFactory,
+ this.fileBackedStreamFactory = Preconditions.checkNotNull(builder.fileBackedStreamFactory,
"FiledBackedStreamFactory cannot be null");
this.assembledMessageCallback = Preconditions.checkNotNull(builder.assembledMessageCallback,
"assembledMessageCallback cannot be null");
if (messageSlice.getSliceIndex() == SlicedMessageState.FIRST_SLICE_INDEX) {
LOG.debug("{}: Received first slice for {} - creating AssembledMessageState", logContext, identifier);
return new AssembledMessageState(identifier, messageSlice.getTotalSlices(),
- filedBackedStreamFactory, logContext);
+ fileBackedStreamFactory, logContext);
}
LOG.debug("{}: AssembledMessageState not found for {} - returning failed reply", logContext, identifier);
}
public static class Builder {
- private FileBackedOutputStreamFactory filedBackedStreamFactory;
+ private FileBackedOutputStreamFactory fileBackedStreamFactory;
private BiConsumer<Object, ActorRef> assembledMessageCallback;
private long expireStateAfterInactivityDuration = 1;
private TimeUnit expireStateAfterInactivityUnit = TimeUnit.MINUTES;
/**
* Sets the factory for creating FileBackedOutputStream instances used for streaming messages.
*
- * @param newFiledBackedStreamFactory the factory for creating FileBackedOutputStream instances
+ * @param newFileBackedStreamFactory the factory for creating FileBackedOutputStream instances
* @return this Builder
*/
- public Builder filedBackedStreamFactory(final FileBackedOutputStreamFactory newFiledBackedStreamFactory) {
- this.filedBackedStreamFactory = Preconditions.checkNotNull(newFiledBackedStreamFactory);
+ public Builder fileBackedStreamFactory(final FileBackedOutputStreamFactory newFileBackedStreamFactory) {
+ this.fileBackedStreamFactory = Preconditions.checkNotNull(newFileBackedStreamFactory);
return this;
}
public static final int DEFAULT_MAX_SLICING_TRIES = 3;
private final Cache<Identifier, SlicedMessageState<ActorRef>> stateCache;
- private final FileBackedOutputStreamFactory filedBackedStreamFactory;
+ private final FileBackedOutputStreamFactory fileBackedStreamFactory;
private final int messageSliceSize;
private final int maxSlicingTries;
private final String logContext;
private final long id;
private MessageSlicer(Builder builder) {
- this.filedBackedStreamFactory = builder.filedBackedStreamFactory;
+ this.fileBackedStreamFactory = builder.fileBackedStreamFactory;
this.messageSliceSize = builder.messageSliceSize;
this.maxSlicingTries = builder.maxSlicingTries;
if (message != null) {
LOG.debug("{}: slice: identifier: {}, message: {}", logContext, identifier, message);
- Preconditions.checkNotNull(filedBackedStreamFactory,
+ Preconditions.checkNotNull(fileBackedStreamFactory,
"The FiledBackedStreamFactory must be set in order to call this slice method");
// Serialize the message to a FileBackedOutputStream.
- fileBackedStream = filedBackedStreamFactory.newInstance();
+ fileBackedStream = fileBackedStreamFactory.newInstance();
try (ObjectOutputStream out = new ObjectOutputStream(fileBackedStream)) {
out.writeObject(message);
} catch (IOException e) {
}
public static class Builder {
- private FileBackedOutputStreamFactory filedBackedStreamFactory;
+ private FileBackedOutputStreamFactory fileBackedStreamFactory;
private int messageSliceSize = -1;
private long expireStateAfterInactivityDuration = -1;
private TimeUnit expireStateAfterInactivityUnit = TimeUnit.MINUTES;
* is used by the {@link MessageSlicer#slice(SliceOptions)} method if a Serializable message is passed.
* If Serializable messages aren't passed then the factory need not be set.
*
- * @param newFiledBackedStreamFactory the factory for creating FileBackedOutputStream instances
+ * @param newFileBackedStreamFactory the factory for creating FileBackedOutputStream instances
* @return this Builder
*/
- public Builder filedBackedStreamFactory(final FileBackedOutputStreamFactory newFiledBackedStreamFactory) {
- this.filedBackedStreamFactory = Preconditions.checkNotNull(newFiledBackedStreamFactory);
+ public Builder fileBackedStreamFactory(final FileBackedOutputStreamFactory newFileBackedStreamFactory) {
+ this.fileBackedStreamFactory = Preconditions.checkNotNull(newFileBackedStreamFactory);
return this;
}
}
private Builder newMessageAssemblerBuilder(String logContext) {
- return MessageAssembler.builder().filedBackedStreamFactory(mockFiledBackedStreamFactory)
+ return MessageAssembler.builder().fileBackedStreamFactory(mockFiledBackedStreamFactory)
.assembledMessageCallback(mockAssembledMessageCallback).logContext(logContext);
}
}
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);
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,
private final MessageAssembler assembler = MessageAssembler.builder()
.assembledMessageCallback(mockAssembledMessageCallback).logContext("test")
- .filedBackedStreamFactory(FILE_BACKED_STREAM_FACTORY).build();
+ .fileBackedStreamFactory(FILE_BACKED_STREAM_FACTORY).build();
@Before
public void setup() {
private MessageSlicer newMessageSlicer(String logContext, final int messageSliceSize) {
return MessageSlicer.builder().messageSliceSize(messageSliceSize).logContext(logContext)
- .filedBackedStreamFactory(FILE_BACKED_STREAM_FACTORY).build();
+ .fileBackedStreamFactory(FILE_BACKED_STREAM_FACTORY).build();
}
}