Package org.opennms.core.rpc.camel
Class CamelRpcServerRouteManager
- java.lang.Object
-
- org.opennms.core.rpc.camel.CamelRpcServerRouteManager
-
- Direct Known Subclasses:
AmazonSQSServerRouteManager
,JmsRpcServerRouteManager
public abstract class CamelRpcServerRouteManager extends java.lang.Object
Dynamically creates and deletes Camel routes to process RPC requests for all registeredRpcModule
services.- Author:
- jwhite
-
-
Constructor Summary
Constructors Constructor Description CamelRpcServerRouteManager(org.apache.camel.CamelContext context, MinionIdentity identity)
-
Method Summary
All Methods Static Methods Instance Methods Abstract Methods Concrete Methods Modifier and Type Method Description void
bind(RpcModule module)
abstract org.apache.camel.builder.RouteBuilder
getRouteBuilder(org.apache.camel.CamelContext context, MinionIdentity identity, RpcModule<RpcRequest,RpcResponse> module)
static java.lang.String
getRouteId(RpcModule<?,?> module)
void
unbind(RpcModule module)
-
-
-
Constructor Detail
-
CamelRpcServerRouteManager
public CamelRpcServerRouteManager(org.apache.camel.CamelContext context, MinionIdentity identity)
-
-
Method Detail
-
getRouteId
public static java.lang.String getRouteId(RpcModule<?,?> module)
-
getRouteBuilder
public abstract org.apache.camel.builder.RouteBuilder getRouteBuilder(org.apache.camel.CamelContext context, MinionIdentity identity, RpcModule<RpcRequest,RpcResponse> module)
-
bind
public void bind(RpcModule module) throws java.lang.Exception
- Throws:
java.lang.Exception
-
unbind
public void unbind(RpcModule module) throws java.lang.Exception
- Throws:
java.lang.Exception
-
-