Class GrpcTwinPublisher
- java.lang.Object
-
- org.opennms.core.ipc.twin.common.AbstractTwinPublisher
-
- org.opennms.core.ipc.twin.grpc.publisher.GrpcTwinPublisher
-
- All Implemented Interfaces:
Closeable
,AutoCloseable
,TwinPublisher
public class GrpcTwinPublisher extends AbstractTwinPublisher
-
-
Nested Class Summary
-
Nested classes/interfaces inherited from class org.opennms.core.ipc.twin.common.AbstractTwinPublisher
AbstractTwinPublisher.SessionKey
-
Nested classes/interfaces inherited from interface org.opennms.core.ipc.twin.api.TwinPublisher
TwinPublisher.Session<T>
-
-
Field Summary
-
Fields inherited from class org.opennms.core.ipc.twin.common.AbstractTwinPublisher
objectMapper, TAG_PATCH, TAG_SESSION_ID, TAG_TWIN_RPC, TAG_TWIN_SINK, TAG_VERSION
-
-
Constructor Summary
Constructors Constructor Description GrpcTwinPublisher(LocalTwinSubscriber twinSubscriber, GrpcIpcServer grpcIpcServer)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
close()
protected void
handleSinkUpdate(TwinUpdate sinkUpdate)
void
start()
-
Methods inherited from class org.opennms.core.ipc.twin.common.AbstractTwinPublisher
addTracingInfo, forEachSession, generateTracingOperationKey, getTracer, getTwin, mapTwinRequestProto, mapTwinResponse, register
-
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.TwinPublisher
register
-
-
-
-
Constructor Detail
-
GrpcTwinPublisher
public GrpcTwinPublisher(LocalTwinSubscriber twinSubscriber, GrpcIpcServer grpcIpcServer)
-
-
Method Detail
-
handleSinkUpdate
protected void handleSinkUpdate(TwinUpdate sinkUpdate)
- Specified by:
handleSinkUpdate
in classAbstractTwinPublisher
- Parameters:
sinkUpdate
- Handle sink Update from @AbstractTwinPublisher
.
-
start
public void start() throws IOException
- Throws:
IOException
-
close
public void close() throws IOException
- Throws:
IOException
-
-