Package org.opennms.core.ipc.osgi
Class OsgiIpcManager
- java.lang.Object
-
- org.opennms.core.ipc.sink.common.AbstractMessageConsumerManager
-
- org.opennms.core.ipc.osgi.OsgiIpcManager
-
- All Implemented Interfaces:
MessageConsumerManager
,RpcClientFactory
,org.springframework.beans.factory.DisposableBean
public class OsgiIpcManager extends AbstractMessageConsumerManager implements RpcClientFactory, org.springframework.beans.factory.DisposableBean
-
-
Field Summary
-
Fields inherited from class org.opennms.core.ipc.sink.common.AbstractMessageConsumerManager
SINK_INITIAL_SLEEP_TIME, startupExecutor, waitForStartup
-
Fields inherited from interface org.opennms.core.ipc.sink.api.MessageConsumerManager
LOG_PREFIX, METRIC_DISPATCH_TIME, METRIC_MESSAGE_SIZE, METRIC_MESSAGES_RECEIVED
-
Fields inherited from interface org.opennms.core.rpc.api.RpcClientFactory
JMX_DOMAIN_RPC, LOG_PREFIX, RPC_DURATION, RPC_FAILED, RPC_REQUEST_SENT, RPC_REQUEST_SIZE, RPC_REQUESTS_RECEIVED, RPC_RESPONSE_SIZE
-
-
Constructor Summary
Constructors Constructor Description OsgiIpcManager()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
destroy()
<S extends Message,T extends Message>
voiddispatch(SinkModule<S,T> module, T message)
<R extends RpcRequest,S extends RpcResponse>
RpcClient<R,S>getClient(RpcModule<R,S> module)
<S extends Message,T extends Message>
voidregisterConsumer(MessageConsumer<S,T> consumer)
protected void
startConsumingForModule(SinkModule<?,Message> module)
protected void
stopConsumingForModule(SinkModule<?,Message> module)
<S extends Message,T extends Message>
voidunregisterConsumer(MessageConsumer<S,T> consumer)
-
Methods inherited from class org.opennms.core.ipc.sink.common.AbstractMessageConsumerManager
getNumConsumerThreads, getStartupExecutor, unregisterAllConsumers
-
-
-
-
Method Detail
-
getClient
public <R extends RpcRequest,S extends RpcResponse> RpcClient<R,S> getClient(RpcModule<R,S> module)
- Specified by:
getClient
in interfaceRpcClientFactory
-
dispatch
public <S extends Message,T extends Message> void dispatch(SinkModule<S,T> module, T message)
- Specified by:
dispatch
in interfaceMessageConsumerManager
- Overrides:
dispatch
in classAbstractMessageConsumerManager
-
startConsumingForModule
protected void startConsumingForModule(SinkModule<?,Message> module) throws java.lang.Exception
- Specified by:
startConsumingForModule
in classAbstractMessageConsumerManager
- Throws:
java.lang.Exception
-
stopConsumingForModule
protected void stopConsumingForModule(SinkModule<?,Message> module) throws java.lang.Exception
- Specified by:
stopConsumingForModule
in classAbstractMessageConsumerManager
- Throws:
java.lang.Exception
-
registerConsumer
public <S extends Message,T extends Message> void registerConsumer(MessageConsumer<S,T> consumer) throws java.lang.Exception
- Specified by:
registerConsumer
in interfaceMessageConsumerManager
- Overrides:
registerConsumer
in classAbstractMessageConsumerManager
- Throws:
java.lang.Exception
-
unregisterConsumer
public <S extends Message,T extends Message> void unregisterConsumer(MessageConsumer<S,T> consumer) throws java.lang.Exception
- Specified by:
unregisterConsumer
in interfaceMessageConsumerManager
- Overrides:
unregisterConsumer
in classAbstractMessageConsumerManager
- Throws:
java.lang.Exception
-
destroy
public void destroy() throws java.lang.Exception
- Specified by:
destroy
in interfaceorg.springframework.beans.factory.DisposableBean
- Throws:
java.lang.Exception
-
-