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

Modifier and Type	Method	Description
void	destroy()
<S extends Message,T extends Message> void	dispatch(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> void	registerConsumer(MessageConsumer<S,T> consumer)
protected void	startConsumingForModule(SinkModule<?,Message> module)
protected void	stopConsumingForModule(SinkModule<?,Message> module)
<S extends Message,T extends Message> void	unregisterConsumer(MessageConsumer<S,T> consumer)

Methods inherited from class org.opennms.core.ipc.sink.common.AbstractMessageConsumerManager

getNumConsumerThreads, getStartupExecutor, unregisterAllConsumers

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

OsgiIpcManager

public OsgiIpcManager()

Method Detail

getClient

public <R extends RpcRequest,S extends RpcResponse> RpcClient<R,S> getClient(RpcModule<R,S> module)

Specified by:

getClient in interface RpcClientFactory

dispatch

public <S extends Message,T extends Message> void dispatch(SinkModule<S,T> module,
                                                                 T message)

Specified by:

dispatch in interface MessageConsumerManager

Overrides:

dispatch in class AbstractMessageConsumerManager

startConsumingForModule

protected void startConsumingForModule(SinkModule<?,Message> module)
                                throws java.lang.Exception

Specified by:

startConsumingForModule in class AbstractMessageConsumerManager

Throws:

java.lang.Exception

stopConsumingForModule

protected void stopConsumingForModule(SinkModule<?,Message> module)
                               throws java.lang.Exception

Specified by:

stopConsumingForModule in class AbstractMessageConsumerManager

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 interface MessageConsumerManager

Overrides:

registerConsumer in class AbstractMessageConsumerManager

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 interface MessageConsumerManager

Overrides:

unregisterConsumer in class AbstractMessageConsumerManager

Throws:

java.lang.Exception

destroy

public void destroy()
             throws java.lang.Exception

Specified by:

destroy in interface org.springframework.beans.factory.DisposableBean

Throws:

java.lang.Exception