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

Class JmsTwinSubscriber

java.lang.Object

org.opennms.core.ipc.twin.common.AbstractTwinSubscriber

org.opennms.core.ipc.twin.jms.subscriber.JmsTwinSubscriber

All Implemented Interfaces:

Closeable, AutoCloseable, org.apache.camel.Processor, TwinSubscriber

public class JmsTwinSubscriber
extends AbstractTwinSubscriber
implements org.apache.camel.Processor

Field Summary

Fields inherited from class org.opennms.core.ipc.twin.common.AbstractTwinSubscriber

TAG_TWIN_RPC_REQUEST

Constructor Summary

Constructors

Constructor	Description
JmsTwinSubscriber(MinionIdentity minionIdentity, org.apache.camel.Component queuingservice, TracerRegistry tracerRegistry, com.codahale.metrics.MetricRegistry metricRegistry, String debugMaxChar)

Method Summary

Modifier and Type	Method	Description
void	close()
void	init()
void	process(org.apache.camel.Exchange exchange)
protected void	sendRpcRequest(TwinRequest twinRequest)

Methods inherited from class org.opennms.core.ipc.twin.common.AbstractTwinSubscriber

accept, getIdentity, getMetrics, getTracer, getTracerRegistry, mapTwinRequestToProto, mapTwinResponseToProto, subscribe

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

JmsTwinSubscriber

public JmsTwinSubscriber(MinionIdentity minionIdentity,
                         org.apache.camel.Component queuingservice,
                         TracerRegistry tracerRegistry,
                         com.codahale.metrics.MetricRegistry metricRegistry,
                         String debugMaxChar)

Method Detail

sendRpcRequest

protected void sendRpcRequest(TwinRequest twinRequest)

Specified by:

sendRpcRequest in class AbstractTwinSubscriber

init

public void init()
          throws Exception

Throws:

Exception

close

public void close()
           throws IOException

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Overrides:

close in class AbstractTwinSubscriber

Throws:

IOException

process

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

Specified by:

process in interface org.apache.camel.Processor

Throws:

Exception