osmq.broker
Class ChangeRequestor
java.lang.Object
osmq.broker.ChangeRequestor
- public class ChangeRequestor
- extends java.lang.Object
A client component that submits one or more
change requests to the router/server.
Methods inherited from class java.lang.Object |
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
KILL_SUBSCRIBER
public static final java.lang.String KILL_SUBSCRIBER
- See Also:
- Constant Field Values
KILL_BROKER
public static final java.lang.String KILL_BROKER
- See Also:
- Constant Field Values
PAUSE_BROKER
public static final java.lang.String PAUSE_BROKER
- See Also:
- Constant Field Values
UNPAUSE_BROKER
public static final java.lang.String UNPAUSE_BROKER
- See Also:
- Constant Field Values
FLUSH_QUEUE
public static final java.lang.String FLUSH_QUEUE
- See Also:
- Constant Field Values
FLUSH_TOPICS
public static final java.lang.String FLUSH_TOPICS
- See Also:
- Constant Field Values
ChangeRequestor
public ChangeRequestor()
isConnected
public boolean isConnected()
killSubscriberConnection
public void killSubscriberConnection(java.lang.String name)
throws java.io.IOException
- Throws:
java.io.IOException
flushNamedQueue
public void flushNamedQueue(java.lang.String name)
throws java.io.IOException
- Throws:
java.io.IOException
flushTopicFor
public void flushTopicFor(java.lang.String name)
throws java.io.IOException
- Throws:
java.io.IOException
sendPaused
public void sendPaused(boolean paused)
throws java.io.IOException
- Throws:
java.io.IOException
killBrokerEngine
public void killBrokerEngine()
throws java.io.IOException
- Throws:
java.io.IOException