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

Class JmsTwinPublisher

java.lang.Object

org.opennms.core.ipc.twin.common.AbstractTwinPublisher

org.opennms.core.ipc.twin.jms.publisher.JmsTwinPublisher

All Implemented Interfaces:

java.io.Closeable, java.lang.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 java.lang.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

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 java.lang.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 class AbstractTwinPublisher

Parameters:

sinkUpdate - Handle sink Update from @AbstractTwinPublisher.

init

public void init()
          throws java.lang.Exception

Throws:

java.lang.Exception

close

public void close()
           throws java.io.IOException

Specified by:

close in interface java.lang.AutoCloseable

Specified by:

close in interface java.io.Closeable

Throws:

java.io.IOException

process

public boolean process(org.apache.camel.Exchange exchange,
                       org.apache.camel.AsyncCallback callback)

Specified by:

process in interface org.apache.camel.AsyncProcessor

process

public void process(org.apache.camel.Exchange exchange)
             throws java.lang.Exception

Specified by:

process in interface org.apache.camel.Processor

Throws:

java.lang.Exception