Class BARRIER

java.lang.Object
org.jgroups.jmx.Protocol
org.jgroups.jmx.protocols.BARRIER
All Implemented Interfaces:
ProtocolMBean, BARRIERMBean

public class BARRIER extends Protocol implements BARRIERMBean
JMX wrapper for BARRIER protocol.
Author:
rpike
  • Constructor Details

    • BARRIER

      public BARRIER()
    • BARRIER

      public BARRIER(Protocol p)
  • Method Details

    • attachProtocol

      public void attachProtocol(Protocol p)
      Overrides:
      attachProtocol in class Protocol
    • getInFlightThreadsCount

      public int getInFlightThreadsCount()
      Description copied from interface: BARRIERMBean
      Returns the current count of in-flight threads.

      In-flight threads are those currently processing in higher-level protocols.

      Specified by:
      getInFlightThreadsCount in interface BARRIERMBean
      Returns:
      in-flight threads count
    • getMaxCloseTime

      public long getMaxCloseTime()
      Description copied from interface: BARRIERMBean
      Gets configured max_close_time value (ms).
      Specified by:
      getMaxCloseTime in interface BARRIERMBean
    • isClosed

      public boolean isClosed()
      Description copied from interface: BARRIERMBean
      Indicates if barrier is currently closed.
      Specified by:
      isClosed in interface BARRIERMBean
    • isOpenerScheduled

      public boolean isOpenerScheduled()
      Description copied from interface: BARRIERMBean
      Returns true if barrier_opener_future is non-null.
      Specified by:
      isOpenerScheduled in interface BARRIERMBean