osmq.broker.handlers
Class PublisherHandler
java.lang.Object
osmq.util.Threaded
osmq.broker.handlers.ServiceHandler
osmq.broker.handlers.PublisherHandler
- All Implemented Interfaces:
- java.lang.Runnable
- public final class PublisherHandler
- extends ServiceHandler
Methods inherited from class osmq.util.Threaded |
getExceptionListener, getIterations, getPriority, getSequenceNumber, getUserDefinedName, getYieldToPeers, hasTerminated, isPaused, isRunning, isShutdownCompleted, killAll, killAllInGroup, run, setExceptionListener, setPaused, setPriority, setUserDefinedName, setYieldCount, shutdownRequested, sleepSecs, sleepTenths, start, stop, successfulInit |
Methods inherited from class java.lang.Object |
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
PublisherHandler
public PublisherHandler()
setPausePublishers
public static void setPausePublishers(boolean value)
isPausePublishers
public static boolean isPausePublishers()
getMessageCount
public static long getMessageCount()
getLocalCount
public long getLocalCount()
getPubName
public java.lang.String getPubName()
getAgentCount
public static int getAgentCount()
killAllPublishers
public static void killAllPublishers()