Package org.opennms.core.ipc.sink.common
Class DispatcherState<W,S extends Message,T extends Message>
- java.lang.Object
-
- org.opennms.core.ipc.sink.common.DispatcherState<W,S,T>
-
-
Constructor Summary
Constructors Constructor Description DispatcherState(AbstractMessageDispatcherFactory<W> dispatcherFactory, SinkModule<S,T> module)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
close()
com.codahale.metrics.Timer
getDispatchTimer()
W
getMetaData()
protected com.codahale.metrics.MetricRegistry
getMetrics()
SinkModule<S,T>
getModule()
-
-
-
Constructor Detail
-
DispatcherState
public DispatcherState(AbstractMessageDispatcherFactory<W> dispatcherFactory, SinkModule<S,T> module)
-
-
Method Detail
-
getModule
public SinkModule<S,T> getModule()
-
getMetaData
public W getMetaData()
-
getMetrics
protected com.codahale.metrics.MetricRegistry getMetrics()
-
getDispatchTimer
public com.codahale.metrics.Timer getDispatchTimer()
-
close
public void close() throws java.lang.Exception
- Specified by:
close
in interfacejava.lang.AutoCloseable
- Throws:
java.lang.Exception
-
-