public class DispatcherState<W,S extends Message,T extends Message> extends Object implements AutoCloseable
Constructor and Description |
---|
DispatcherState(AbstractMessageDispatcherFactory<W> dispatcherFactory,
SinkModule<S,T> module) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
com.codahale.metrics.Timer |
getDispatchTimer() |
W |
getMetaData() |
protected com.codahale.metrics.MetricRegistry |
getMetrics() |
SinkModule<S,T> |
getModule() |
public DispatcherState(AbstractMessageDispatcherFactory<W> dispatcherFactory, SinkModule<S,T> module)
public SinkModule<S,T> getModule()
public W getMetaData()
protected com.codahale.metrics.MetricRegistry getMetrics()
public com.codahale.metrics.Timer getDispatchTimer()
public void close() throws Exception
close
in interface AutoCloseable
Exception
Copyright © 2017. All rights reserved.