OpflowTaskSubmitter (opflow-core 0.3.0 API)

All Known Implementing Classes:: OpflowTaskSubmitterMaster

public interface OpflowTaskSubmitter

Author:: drupalex

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 connectorName, boolean state, Map<String,Object> opts)`
`Map<String,Object>`	`activatePublisher(String connectorName, boolean state, Map<String,Object> opts)`
`Map<String,Object>`	`activateRemoteAMQPWorker(String connectorName, boolean state, Map<String,Object> opts)`
`Map<String,Object>`	`activateRemoteHTTPWorker(String connectorName, boolean state, Map<String,Object> opts)`
`Map<String,Object>`	`pause(long duration)`
`Map<String,Object>`	`reset()`
`Map<String,Object>`	`resetDiscoveryClient()`
`Map<String,Object>`	`resetRpcInvocationCounter()`
`Map<String,Object>`	`unpause()`

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