public static class MessageAssembler.Builder extends Object
Constructor and Description |
---|
Builder() |
Modifier and Type | Method and Description |
---|---|
MessageAssembler.Builder |
assembledMessageCallback(BiConsumer<Object,akka.actor.ActorRef> newAssembledMessageCallback)
Sets the Consumer callback for assembled messages.
|
MessageAssembler |
build()
Builds a new MessageAssembler instance.
|
MessageAssembler.Builder |
expireStateAfterInactivity(long duration,
TimeUnit unit)
Sets the duration and time unit whereby assembled message state is purged from the cache due to
inactivity from the slicing component on the other end.
|
MessageAssembler.Builder |
fileBackedStreamFactory(FileBackedOutputStreamFactory newFileBackedStreamFactory)
Sets the factory for creating FileBackedOutputStream instances used for streaming messages.
|
MessageAssembler.Builder |
logContext(String newLogContext)
Sets the context for log messages.
|
public MessageAssembler.Builder fileBackedStreamFactory(FileBackedOutputStreamFactory newFileBackedStreamFactory)
newFileBackedStreamFactory
- the factory for creating FileBackedOutputStream instancespublic MessageAssembler.Builder assembledMessageCallback(BiConsumer<Object,akka.actor.ActorRef> newAssembledMessageCallback)
newAssembledMessageCallback
- the Consumer callbackpublic MessageAssembler.Builder expireStateAfterInactivity(long duration, TimeUnit unit)
duration
- the length of time after which a state entry is purgedunit
- the unit the duration is expressed inpublic MessageAssembler.Builder logContext(String newLogContext)
newLogContext
- the log contextpublic MessageAssembler build()
Copyright © 2019 OpenDaylight. All rights reserved.