- this.identifier = Preconditions.checkNotNull(identifier);
- this.scheduler = Preconditions.checkNotNull(scheduler);
- this.executionContext = Preconditions.checkNotNull(executionContext);
- this.config = Preconditions.checkNotNull(config);
+ this.identifier = requireNonNull(identifier);
+ this.scheduler = requireNonNull(system).scheduler();
+ this.executionContext = system.dispatcher();
+ this.dispatchers = new Dispatchers(system.dispatchers());
+ this.config = requireNonNull(config);
+
+ messageSlicer = MessageSlicer.builder().messageSliceSize(config.getMaximumMessageSliceSize())
+ .logContext(persistenceId).expireStateAfterInactivity(config.getRequestTimeout(), TimeUnit.NANOSECONDS)
+ .fileBackedStreamFactory(new FileBackedOutputStreamFactory(config.getFileBackedStreamingThreshold(),
+ config.getTempFileDirectory())).build();