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

public class CamelRpcServerProcessor
extends java.lang.Object
implements org.apache.camel.AsyncProcessor

Executes the RpcRequest, and asynchronously returns the RpcResponse.

Author:

jwhite

Constructor Summary

Constructors

Constructor	Description
CamelRpcServerProcessor(RpcModule<RpcRequest,RpcResponse> module, TracerRegistry tracerRegistry)

Method Summary

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()

Methods inherited from class java.lang.Object

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

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 interface org.apache.camel.Processor

process

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

Specified by:

process in interface org.apache.camel.AsyncProcessor

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object

postProcess

public void postProcess(org.apache.camel.Exchange exchange)