Class JmsTwinPublisher
- java.lang.Object
-
- org.opennms.core.ipc.twin.common.AbstractTwinPublisher
-
- org.opennms.core.ipc.twin.jms.publisher.JmsTwinPublisher
-
- All Implemented Interfaces:
Closeable
,AutoCloseable
,org.apache.camel.AsyncProcessor
,org.apache.camel.Processor
,TwinPublisher
public class JmsTwinPublisher extends AbstractTwinPublisher implements org.apache.camel.AsyncProcessor
-
-
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 Modifier and Type Field Description static String
JMS_QUEUE_NAME_HEADER
-
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 JmsTwinPublisher(org.apache.camel.CamelContext camelContext, LocalTwinSubscriber twinSubscriber, TracerRegistry tracerRegistry, com.codahale.metrics.MetricRegistry metricRegistry)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
close()
protected void
handleSinkUpdate(TwinUpdate sinkUpdate)
void
init()
void
process(org.apache.camel.Exchange exchange)
boolean
process(org.apache.camel.Exchange exchange, org.apache.camel.AsyncCallback callback)
-
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
-
-
-
-
Field Detail
-
JMS_QUEUE_NAME_HEADER
public static String JMS_QUEUE_NAME_HEADER
-
-
Constructor Detail
-
JmsTwinPublisher
public JmsTwinPublisher(org.apache.camel.CamelContext camelContext, LocalTwinSubscriber twinSubscriber, TracerRegistry tracerRegistry, com.codahale.metrics.MetricRegistry metricRegistry)
-
-
Method Detail
-
handleSinkUpdate
protected void handleSinkUpdate(TwinUpdate sinkUpdate)
- Specified by:
handleSinkUpdate
in classAbstractTwinPublisher
- Parameters:
sinkUpdate
- Handle sink Update from @AbstractTwinPublisher
.
-
close
public void close() throws IOException
- Specified by:
close
in interfaceAutoCloseable
- Specified by:
close
in interfaceCloseable
- Throws:
IOException
-
process
public boolean process(org.apache.camel.Exchange exchange, org.apache.camel.AsyncCallback callback)
- Specified by:
process
in interfaceorg.apache.camel.AsyncProcessor
-
-