Package org.opennms.core.ipc.sink.mock
Class MockMessageDispatcherFactory<U extends Message,V extends Message>
- java.lang.Object
-
- org.opennms.core.ipc.sink.common.AbstractMessageDispatcherFactory<Void>
-
- org.opennms.core.ipc.sink.mock.MockMessageDispatcherFactory<U,V>
-
- All Implemented Interfaces:
MessageDispatcherFactory
,org.springframework.beans.factory.DisposableBean
,org.springframework.beans.factory.InitializingBean
public class MockMessageDispatcherFactory<U extends Message,V extends Message> extends AbstractMessageDispatcherFactory<Void> implements org.springframework.beans.factory.InitializingBean, org.springframework.beans.factory.DisposableBean
A simpleMessageDispatcherFactory
that handles all messages with a single consumer. Used for testing.- Author:
- jwhite
-
-
Constructor Summary
Constructors Constructor Description MockMessageDispatcherFactory()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
afterPropertiesSet()
void
destroy()
<S extends Message,T extends Message>
voiddispatch(SinkModule<S,T> module, Void metadata, T message)
org.osgi.framework.BundleContext
getBundleContext()
MessageConsumer<U,V>
getConsumer()
String
getMetricDomain()
com.codahale.metrics.MetricRegistry
getMetrics()
io.opentracing.Tracer
getTracer()
void
setConsumer(MessageConsumer<U,V> consumer)
-
Methods inherited from class org.opennms.core.ipc.sink.common.AbstractMessageDispatcherFactory
createAsyncDispatcher, createSyncDispatcher, createSyncDispatcher, getModuleMetadata, onDestroy, onInit
-
-
-
-
Method Detail
-
dispatch
public <S extends Message,T extends Message> void dispatch(SinkModule<S,T> module, Void metadata, T message)
- Specified by:
dispatch
in classAbstractMessageDispatcherFactory<Void>
-
afterPropertiesSet
public void afterPropertiesSet()
- Specified by:
afterPropertiesSet
in interfaceorg.springframework.beans.factory.InitializingBean
-
destroy
public void destroy()
- Specified by:
destroy
in interfaceorg.springframework.beans.factory.DisposableBean
-
getMetricDomain
public String getMetricDomain()
- Specified by:
getMetricDomain
in classAbstractMessageDispatcherFactory<Void>
-
getBundleContext
public org.osgi.framework.BundleContext getBundleContext()
- Specified by:
getBundleContext
in classAbstractMessageDispatcherFactory<Void>
-
getTracer
public io.opentracing.Tracer getTracer()
- Specified by:
getTracer
in classAbstractMessageDispatcherFactory<Void>
-
getMetrics
public com.codahale.metrics.MetricRegistry getMetrics()
- Specified by:
getMetrics
in classAbstractMessageDispatcherFactory<Void>
-
getConsumer
public MessageConsumer<U,V> getConsumer()
-
setConsumer
public void setConsumer(MessageConsumer<U,V> consumer)
-
-