Package com.devebot.opflow.services

Class OpflowTaskSubmitterMaster

java.lang.Object

com.devebot.opflow.services.OpflowTaskSubmitterMaster

All Implemented Interfaces:

OpflowTaskSubmitter

public class OpflowTaskSubmitterMaster
extends Object
implements OpflowTaskSubmitter

Author:

cuoi

Constructor Summary

Constructors

Constructor	Description
OpflowTaskSubmitterMaster(String componentId, OpflowPromMeasurer measurer, OpflowRestrictorMaster restrictor, Map<String,OpflowConnector> connectors, OpflowThroughput.Meter speedMeter, OpflowDiscoveryMaster discoveryMaster)

Method Summary

Modifier and Type	Method	Description
Map<String,Object>	activateAllNativeWorkers(boolean state, Map<String,Object> opts)
Map<String,Object>	activateAllPublishers(boolean state, Map<String,Object> opts)
Map<String,Object>	activateAllRemoteAMQPWorkers(boolean state, Map<String,Object> opts)
Map<String,Object>	activateAllRemoteHTTPWorkers(boolean state, Map<String,Object> opts)
Map<String,Object>	activateNativeWorker(String name, boolean state, Map<String,Object> opts)
Map<String,Object>	activatePublisher(String name, boolean state, Map<String,Object> opts)
Map<String,Object>	activateRemoteAMQPWorker(String name, boolean state, Map<String,Object> opts)
Map<String,Object>	activateRemoteHTTPWorker(String name, boolean state, Map<String,Object> opts)
Map<String,Object>	pause(long duration)
Map<String,Object>	reset()
Map<String,Object>	reset(String connectorName)
Map<String,Object>	resetDiscoveryClient()
Map<String,Object>	resetRpcInvocationCounter()
Map<String,Object>	resetRpcInvocationCounter(String connectorName)
Map<String,Object>	unpause()

Methods inherited from class java.lang.Object

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

Constructor Details

OpflowTaskSubmitterMaster

public OpflowTaskSubmitterMaster(String componentId, OpflowPromMeasurer measurer, OpflowRestrictorMaster restrictor, Map<String,OpflowConnector> connectors, OpflowThroughput.Meter speedMeter, OpflowDiscoveryMaster discoveryMaster)

Method Details

pause

public Map<String,Object> pause(long duration)

Specified by:

pause in interface OpflowTaskSubmitter

unpause

public Map<String,Object> unpause()

Specified by:

unpause in interface OpflowTaskSubmitter

reset

public Map<String,Object> reset()

Specified by:

reset in interface OpflowTaskSubmitter

reset

public Map<String,Object> reset(String connectorName)

resetRpcInvocationCounter

public Map<String,Object> resetRpcInvocationCounter()

Specified by:

resetRpcInvocationCounter in interface OpflowTaskSubmitter

resetRpcInvocationCounter

public Map<String,Object> resetRpcInvocationCounter(String connectorName)

resetDiscoveryClient

public Map<String,Object> resetDiscoveryClient()

Specified by:

resetDiscoveryClient in interface OpflowTaskSubmitter

activateAllPublishers

public Map<String,Object> activateAllPublishers(boolean state, Map<String,Object> opts)

Specified by:

activateAllPublishers in interface OpflowTaskSubmitter

activatePublisher

public Map<String,Object> activatePublisher(String name, boolean state, Map<String,Object> opts)

Specified by:

activatePublisher in interface OpflowTaskSubmitter

activateAllRemoteAMQPWorkers

public Map<String,Object> activateAllRemoteAMQPWorkers(boolean state, Map<String,Object> opts)

Specified by:

activateAllRemoteAMQPWorkers in interface OpflowTaskSubmitter

activateRemoteAMQPWorker

public Map<String,Object> activateRemoteAMQPWorker(String name, boolean state, Map<String,Object> opts)

Specified by:

activateRemoteAMQPWorker in interface OpflowTaskSubmitter

activateAllRemoteHTTPWorkers

public Map<String,Object> activateAllRemoteHTTPWorkers(boolean state, Map<String,Object> opts)

Specified by:

activateAllRemoteHTTPWorkers in interface OpflowTaskSubmitter

activateRemoteHTTPWorker

public Map<String,Object> activateRemoteHTTPWorker(String name, boolean state, Map<String,Object> opts)

Specified by:

activateRemoteHTTPWorker in interface OpflowTaskSubmitter

activateAllNativeWorkers

public Map<String,Object> activateAllNativeWorkers(boolean state, Map<String,Object> opts)

Specified by:

activateAllNativeWorkers in interface OpflowTaskSubmitter

activateNativeWorker

public Map<String,Object> activateNativeWorker(String name, boolean state, Map<String,Object> opts)

Specified by:

activateNativeWorker in interface OpflowTaskSubmitter