com.devebot.opflow.OpflowRpcInvocationCounter

public class OpflowRpcInvocationCounter
extends Object

Author:: acegik

Field Summary

Fields
Modifier and Type	Field	Description
`static String`	`LABEL_RPC_ACCEPTED_INVOCATION_TOTAL`
`static String`	`LABEL_RPC_CANCELLATION_TOTAL`
`static String`	`LABEL_RPC_DIRECT_WORKER`
`static String`	`LABEL_RPC_INVOCATION_TOTAL`
`static String`	`LABEL_RPC_PAUSING_TIMEOUT_TOTAL`
`static String`	`LABEL_RPC_PUBLISHER`
`static String`	`LABEL_RPC_REJECTED_INVOCATION_DETAILS`
`static String`	`LABEL_RPC_REJECTED_INVOCATION_TOTAL`
`static String`	`LABEL_RPC_REMOTE_AMQP_WORKER`
`static String`	`LABEL_RPC_REMOTE_HTTP_WORKER`
`static String`	`LABEL_RPC_SEMAPHORE_TIMEOUT_TOTAL`
`static String`	`LABEL_RPC_SERVICE_NOT_READY_TOTAL`

Constructor Summary

Constructors

Constructor Description

OpflowRpcInvocationCounter()

Method Summary

Modifier and Type	Method	Description
`OpflowThroughput.Source`	`getNativeWorkerInfoSource()`
`OpflowThroughput.Source`	`getPublisherInfoSource()`
`OpflowThroughput.Source`	`getRemoteAMQPWorkerInfoSource()`
`OpflowThroughput.Source`	`getRemoteHTTPWorkerInfoSource()`
`void`	`incCancellationRpc()`
`void`	`incDirectRescue()`
`void`	`incDirectRetain()`
`void`	`incPausingTimeoutRpc()`
`void`	`incPublishingOk()`
`void`	`incRejectedRpc()`
`void`	`incRemoteAMQPFailure()`
`void`	`incRemoteAMQPSuccess()`
`void`	`incRemoteAMQPTimeout()`
`void`	`incRemoteHTTPFailure()`
`void`	`incRemoteHTTPSuccess()`
`void`	`incRemoteHTTPTimeout()`
`void`	`incSemaphoreTimeoutRpc()`
`void`	`incServiceNotReadyRpc()`
`void`	`reset()`
`void`	`setNativeWorkerEnabled(boolean enabled)`
`void`	`setPublisherEnabled(boolean enabled)`
`void`	`setRemoteAMQPWorkerEnabled(boolean enabled)`
`void`	`setRemoteHTTPWorkerEnabled(boolean enabled)`
`Map<String,Object>`	`toMap()`
`Map<String,Object>`	`toMap(boolean cloned)`
`Map<String,Object>`	`toMap(boolean cloned, boolean verbose)`

Methods inherited from class java.lang.Object

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

Field Details
- LABEL_RPC_INVOCATION_TOTAL
  
  public static final String LABEL_RPC_INVOCATION_TOTAL
  
  See Also:
  
  Constant Field Values
- LABEL_RPC_ACCEPTED_INVOCATION_TOTAL
  
  public static final String LABEL_RPC_ACCEPTED_INVOCATION_TOTAL
  
  See Also:
  
  Constant Field Values
- LABEL_RPC_REJECTED_INVOCATION_TOTAL
  
  public static final String LABEL_RPC_REJECTED_INVOCATION_TOTAL
  
  See Also:
  
  Constant Field Values
- LABEL_RPC_REJECTED_INVOCATION_DETAILS
  
  public static final String LABEL_RPC_REJECTED_INVOCATION_DETAILS
  
  See Also:
  
  Constant Field Values
- LABEL_RPC_CANCELLATION_TOTAL
  
  public static final String LABEL_RPC_CANCELLATION_TOTAL
  
  See Also:
  
  Constant Field Values
- LABEL_RPC_SERVICE_NOT_READY_TOTAL
  
  public static final String LABEL_RPC_SERVICE_NOT_READY_TOTAL
  
  See Also:
  
  Constant Field Values
- LABEL_RPC_PAUSING_TIMEOUT_TOTAL
  
  public static final String LABEL_RPC_PAUSING_TIMEOUT_TOTAL
  
  See Also:
  
  Constant Field Values
- LABEL_RPC_SEMAPHORE_TIMEOUT_TOTAL
  
  public static final String LABEL_RPC_SEMAPHORE_TIMEOUT_TOTAL
  
  See Also:
  
  Constant Field Values
- LABEL_RPC_PUBLISHER
  
  public static final String LABEL_RPC_PUBLISHER
  
  See Also:
  
  Constant Field Values
- LABEL_RPC_DIRECT_WORKER
  
  public static final String LABEL_RPC_DIRECT_WORKER
  
  See Also:
  
  Constant Field Values
- LABEL_RPC_REMOTE_AMQP_WORKER
  
  public static final String LABEL_RPC_REMOTE_AMQP_WORKER
  
  See Also:
  
  Constant Field Values
- LABEL_RPC_REMOTE_HTTP_WORKER
  
  public static final String LABEL_RPC_REMOTE_HTTP_WORKER
  
  See Also:
  
  Constant Field Values
Constructor Details
- OpflowRpcInvocationCounter
  
  public OpflowRpcInvocationCounter()
Method Details
- incRejectedRpc
  
  public void incRejectedRpc()
- incCancellationRpc
  
  public void incCancellationRpc()
- incServiceNotReadyRpc
  
  public void incServiceNotReadyRpc()
- incPausingTimeoutRpc
  
  public void incPausingTimeoutRpc()
- incSemaphoreTimeoutRpc
  
  public void incSemaphoreTimeoutRpc()
- incPublishingOk
  
  public void incPublishingOk()
- incDirectRescue
  
  public void incDirectRescue()
- incDirectRetain
  
  public void incDirectRetain()
- incRemoteAMQPSuccess
  
  public void incRemoteAMQPSuccess()
- incRemoteAMQPFailure
  
  public void incRemoteAMQPFailure()
- incRemoteAMQPTimeout
  
  public void incRemoteAMQPTimeout()
- incRemoteHTTPSuccess
  
  public void incRemoteHTTPSuccess()
- incRemoteHTTPFailure
  
  public void incRemoteHTTPFailure()
- incRemoteHTTPTimeout
  
  public void incRemoteHTTPTimeout()
- reset
  
  public void reset()
- toMap
  
  public Map<String,Object> toMap()
- toMap
  
  public Map<String,Object> toMap(boolean cloned)
- toMap
  
  public Map<String,Object> toMap(boolean cloned, boolean verbose)
- getPublisherInfoSource
  
  public OpflowThroughput.Source getPublisherInfoSource()
- getNativeWorkerInfoSource
  
  public OpflowThroughput.Source getNativeWorkerInfoSource()
- getRemoteAMQPWorkerInfoSource
  
  public OpflowThroughput.Source getRemoteAMQPWorkerInfoSource()
- getRemoteHTTPWorkerInfoSource
  
  public OpflowThroughput.Source getRemoteHTTPWorkerInfoSource()
- setPublisherEnabled
  
  public void setPublisherEnabled(boolean enabled)
- setNativeWorkerEnabled
  
  public void setNativeWorkerEnabled(boolean enabled)
- setRemoteAMQPWorkerEnabled
  
  public void setRemoteAMQPWorkerEnabled(boolean enabled)
- setRemoteHTTPWorkerEnabled
  
  public void setRemoteHTTPWorkerEnabled(boolean enabled)

Class OpflowRpcInvocationCounter

Field Summary

Constructor Summary

Method Summary

Methods inherited from class java.lang.Object

Field Details

Constructor Details

Method Details