OSMQ
v2.0.1

osmq.broker
Class ChangeRequestor

java.lang.Object
  extended byosmq.broker.ChangeRequestor

public class ChangeRequestor
extends java.lang.Object

A client component that submits one or more change requests to the router/server.


Field Summary
static java.lang.String FLUSH_QUEUE
           
static java.lang.String FLUSH_TOPICS
           
static java.lang.String KILL_BROKER
           
static java.lang.String KILL_SUBSCRIBER
           
static java.lang.String PAUSE_BROKER
           
static java.lang.String UNPAUSE_BROKER
           
 
Constructor Summary
ChangeRequestor()
           
 
Method Summary
 void flushNamedQueue(java.lang.String name)
           
 void flushTopicFor(java.lang.String name)
           
 boolean isConnected()
           
 void killBrokerEngine()
           
 void killSubscriberConnection(java.lang.String name)
           
 void sendPaused(boolean paused)
           
 
Methods inherited from class java.lang.Object
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

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
Constructor Detail

ChangeRequestor

public ChangeRequestor()
Method Detail

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

(c) 2000 - 2003 MQue Systems
All Rights Reserved