Package org.opennms.core.ipc.twin.grpc.publisher

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

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 class AbstractTwinPublisher

Parameters:

sinkUpdate - Handle sink Update from @AbstractTwinPublisher.

start

public void start()
           throws IOException

Throws:

IOException

close

public void close()
           throws IOException

Throws:

IOException