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
All Methods Instance Methods Concrete Methods 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
-
-
-
-
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 classAbstractTwinSubscriber
-
close
public void close() throws IOException
- Specified by:
close
in interfaceAutoCloseable
- Specified by:
close
in interfaceCloseable
- Overrides:
close
in classAbstractTwinSubscriber
- Throws:
IOException
-
-