Package com.devebot.opflow

Class OpflowRpcInvocationHandler

java.lang.Object

com.devebot.opflow.OpflowRpcInvocationHandler

All Implemented Interfaces:

InvocationHandler

public class OpflowRpcInvocationHandler
extends Object
implements InvocationHandler

Author:

cuoi

Constructor Summary

Constructors

Constructor	Description
OpflowRpcInvocationHandler(OpflowLogTracer logTracer, OpflowPromMeasurer measurer, OpflowRestrictorMaster restrictor, OpflowReqExtractor reqExtractor, OpflowRpcObserver rpcObserver, OpflowRpcAmqpMaster amqpMaster, OpflowRpcHttpMaster httpMaster, OpflowPubsubHandler publisher, Class clazz, Object nativeWorker, boolean nativeWorkerEnabled)

Method Summary

Modifier and Type	Method	Description
Set<Map<String,Object>>	getMethodInfos()
Set<String>	getMethodNames()
String	getNativeWorkerClassName()
Integer	getNativeWorkerHashCode()
Object	invoke(Object proxy, Method method, Object[] args)
boolean	isNativeWorkerActive()
boolean	isNativeWorkerAvailable()
boolean	isPublisherActive()
boolean	isPublisherAvailable()
boolean	isRemoteAMQPWorkerActive()
boolean	isRemoteAMQPWorkerAvailable()
boolean	isRemoteHTTPWorkerActive()
boolean	isRemoteHTTPWorkerAvailable()
void	setNativeWorkerActive(boolean active)
void	setPublisherActive(boolean active)
void	setRemoteAMQPWorkerActive(boolean active)
void	setRemoteHTTPWorkerActive(boolean active)

Methods inherited from class java.lang.Object

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

Constructor Details

OpflowRpcInvocationHandler

public OpflowRpcInvocationHandler(OpflowLogTracer logTracer, OpflowPromMeasurer measurer, OpflowRestrictorMaster restrictor, OpflowReqExtractor reqExtractor, OpflowRpcObserver rpcObserver, OpflowRpcAmqpMaster amqpMaster, OpflowRpcHttpMaster httpMaster, OpflowPubsubHandler publisher, Class clazz, Object nativeWorker, boolean nativeWorkerEnabled)

Method Details

getMethodNames

public Set<String> getMethodNames()

getMethodInfos

public Set<Map<String,Object>> getMethodInfos()

isPublisherActive

public boolean isPublisherActive()

setPublisherActive

public void setPublisherActive(boolean active)

isPublisherAvailable

public boolean isPublisherAvailable()

isNativeWorkerActive

public boolean isNativeWorkerActive()

setNativeWorkerActive

public void setNativeWorkerActive(boolean active)

isNativeWorkerAvailable

public boolean isNativeWorkerAvailable()

getNativeWorkerClassName

public String getNativeWorkerClassName()

getNativeWorkerHashCode

public Integer getNativeWorkerHashCode()

isRemoteAMQPWorkerActive

public boolean isRemoteAMQPWorkerActive()

setRemoteAMQPWorkerActive

public void setRemoteAMQPWorkerActive(boolean active)

isRemoteAMQPWorkerAvailable

public boolean isRemoteAMQPWorkerAvailable()

isRemoteHTTPWorkerActive

public boolean isRemoteHTTPWorkerActive()

setRemoteHTTPWorkerActive

public void setRemoteHTTPWorkerActive(boolean active)

isRemoteHTTPWorkerAvailable

public boolean isRemoteHTTPWorkerAvailable()

invoke

public Object invoke(Object proxy, Method method, Object[] args) throws Throwable

Specified by:

invoke in interface InvocationHandler

Throws:

Throwable