Class GrpcTwinSubscriber
- java.lang.Object
-
- org.opennms.core.ipc.twin.common.AbstractTwinSubscriber
-
- org.opennms.core.ipc.twin.grpc.subscriber.GrpcTwinSubscriber
-
- All Implemented Interfaces:
Closeable
,AutoCloseable
,TwinSubscriber
public class GrpcTwinSubscriber extends AbstractTwinSubscriber
-
-
Field Summary
-
Fields inherited from class org.opennms.core.ipc.twin.common.AbstractTwinSubscriber
TAG_TWIN_RPC_REQUEST
-
-
Constructor Summary
Constructors Constructor Description GrpcTwinSubscriber(MinionIdentity minionIdentity, org.osgi.service.cm.ConfigurationAdmin configAdmin, TracerRegistry tracerRegistry, com.codahale.metrics.MetricRegistry metricRegistry, int port)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
close()
protected void
sendRpcRequest(TwinRequest twinRequest)
void
start()
-
Methods inherited from class org.opennms.core.ipc.twin.common.AbstractTwinSubscriber
accept, getIdentity, getMetrics, getTracer, getTracerRegistry, mapTwinRequestToProto, mapTwinResponseToProto, subscribe
-
-
-
-
Constructor Detail
-
GrpcTwinSubscriber
public GrpcTwinSubscriber(MinionIdentity minionIdentity, org.osgi.service.cm.ConfigurationAdmin configAdmin, TracerRegistry tracerRegistry, com.codahale.metrics.MetricRegistry metricRegistry, int port)
-
-
Method Detail
-
start
public void start() throws IOException
- Throws:
IOException
-
close
public void close() throws IOException
- Specified by:
close
in interfaceAutoCloseable
- Specified by:
close
in interfaceCloseable
- Overrides:
close
in classAbstractTwinSubscriber
- Throws:
IOException
-
sendRpcRequest
protected void sendRpcRequest(TwinRequest twinRequest)
- Specified by:
sendRpcRequest
in classAbstractTwinSubscriber
-
-