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:
java.io.Closeable
,java.lang.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
All Methods Instance Methods Concrete Methods 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 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 classAbstractTwinSubscriber
-
accept
public void accept(TwinUpdate twinUpdate)
- Specified by:
accept
in interfaceLocalTwinSubscriber
- Overrides:
accept
in classAbstractTwinSubscriber
-
getTracerRegistry
public TracerRegistry getTracerRegistry()
- Specified by:
getTracerRegistry
in interfaceLocalTwinSubscriber
- Overrides:
getTracerRegistry
in classAbstractTwinSubscriber
-
getMetricRegistry
public com.codahale.metrics.MetricRegistry getMetricRegistry()
- Specified by:
getMetricRegistry
in interfaceLocalTwinSubscriber
-
-