public class StreamDropwizardBuilder extends LocalStreamBuilder implements StreamBuilder
BROADCAST_INTERVAL_KEY, BROADCAST_KEY, DEFAULT_STARTED_AT_KEY, DEFAULT_STREAM_IDENTIFIER, STREAM_IDENTIFIER_KEY, TIMEOUT_KEY
Constructor and Description |
---|
StreamDropwizardBuilder() |
StreamDropwizardBuilder(int maxQueueCapacity) |
StreamDropwizardBuilder(int maxQueueCapacity,
Map<String,Object> streamConfig) |
StreamDropwizardBuilder(Map<String,Object> streamConfig) |
StreamDropwizardBuilder(StreamsConfiguration streamConfig) |
Modifier and Type | Method and Description |
---|---|
StreamBuilder |
newPerpetualStream(String streamId,
StreamsProvider provider) |
addStreamsPersistWriter, addStreamsProcessor, forceShutdown, getStreamsConfiguration, getTimeout, newReadCurrentStream, newReadNewStream, newReadRangeStream, prepare, setStreamsConfiguration, setupComponentTasks, setupProviderTasks, setUseDeprecatedMonitors, shutdown, start, stop, stopInternal
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
addStreamsPersistWriter, addStreamsProcessor, getStreamsConfiguration, newReadCurrentStream, newReadNewStream, newReadRangeStream, setStreamsConfiguration, start, stop
public StreamDropwizardBuilder()
public StreamDropwizardBuilder(StreamsConfiguration streamConfig)
public StreamDropwizardBuilder(int maxQueueCapacity)
public StreamBuilder newPerpetualStream(String streamId, StreamsProvider provider)
newPerpetualStream
in interface StreamBuilder
newPerpetualStream
in class LocalStreamBuilder
Copyright © 2012–2016 The Apache Software Foundation. All rights reserved.