Package org.opennms.core.ipc.twin.common

Class LocalTwinSubscriberImpl

java.lang.Object

org.opennms.core.ipc.twin.common.AbstractTwinSubscriber

org.opennms.core.ipc.twin.common.LocalTwinSubscriberImpl

All Implemented Interfaces:

Closeable, AutoCloseable, TwinSubscriber, LocalTwinSubscriber

public class LocalTwinSubscriberImpl
extends AbstractTwinSubscriber
implements LocalTwinSubscriber

Field Summary

Fields inherited from class org.opennms.core.ipc.twin.common.AbstractTwinSubscriber

TAG_TWIN_RPC_REQUEST

Constructor Summary

Constructors

Constructor	Description
LocalTwinSubscriberImpl(Identity identity, TracerRegistry tracerRegistry, com.codahale.metrics.MetricRegistry metricRegistry)

Method Summary

Modifier and Type	Method	Description
void	accept(TwinUpdate twinUpdate)
com.codahale.metrics.MetricRegistry	getMetricRegistry()
TracerRegistry	getTracerRegistry()
protected void	sendRpcRequest(TwinRequest twinRequest)

Methods inherited from class org.opennms.core.ipc.twin.common.AbstractTwinSubscriber

close, getIdentity, getMetrics, getTracer, mapTwinRequestToProto, mapTwinResponseToProto, subscribe

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.io.Closeable

close

Methods inherited from interface org.opennms.core.ipc.twin.api.TwinSubscriber

subscribe

Constructor Detail

LocalTwinSubscriberImpl

public LocalTwinSubscriberImpl(Identity identity,
                               TracerRegistry tracerRegistry,
                               com.codahale.metrics.MetricRegistry metricRegistry)

Method Detail

sendRpcRequest

protected void sendRpcRequest(TwinRequest twinRequest)

Specified by:

sendRpcRequest in class AbstractTwinSubscriber

accept

public void accept(TwinUpdate twinUpdate)

Specified by:

accept in interface LocalTwinSubscriber

Overrides:

accept in class AbstractTwinSubscriber

getTracerRegistry

public TracerRegistry getTracerRegistry()

Specified by:

getTracerRegistry in interface LocalTwinSubscriber

Overrides:

getTracerRegistry in class AbstractTwinSubscriber

getMetricRegistry

public com.codahale.metrics.MetricRegistry getMetricRegistry()

Specified by:

getMetricRegistry in interface LocalTwinSubscriber