Package org.opennms.core.rpc.camel
Class CamelRpcServerProcessor
- java.lang.Object
-
- org.opennms.core.rpc.camel.CamelRpcServerProcessor
-
- All Implemented Interfaces:
org.apache.camel.AsyncProcessor
,org.apache.camel.Processor
- Direct Known Subclasses:
AmazonSQSServerProcessor
public class CamelRpcServerProcessor extends java.lang.Object implements org.apache.camel.AsyncProcessor
Executes theRpcRequest
, and asynchronously returns theRpcResponse
.- Author:
- jwhite
-
-
Constructor Summary
Constructors Constructor Description CamelRpcServerProcessor(RpcModule<RpcRequest,RpcResponse> module, TracerRegistry tracerRegistry)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
postProcess(org.apache.camel.Exchange exchange)
void
process(org.apache.camel.Exchange exchange)
boolean
process(org.apache.camel.Exchange exchange, org.apache.camel.AsyncCallback callback)
java.lang.String
toString()
-
-
-
Constructor Detail
-
CamelRpcServerProcessor
public CamelRpcServerProcessor(RpcModule<RpcRequest,RpcResponse> module, TracerRegistry tracerRegistry)
-
-
Method Detail
-
process
public void process(org.apache.camel.Exchange exchange)
- Specified by:
process
in interfaceorg.apache.camel.Processor
-
process
public boolean process(org.apache.camel.Exchange exchange, org.apache.camel.AsyncCallback callback)
- Specified by:
process
in interfaceorg.apache.camel.AsyncProcessor
-
toString
public java.lang.String toString()
- Overrides:
toString
in classjava.lang.Object
-
postProcess
public void postProcess(org.apache.camel.Exchange exchange)
-
-