|
OSMQ v2.0.1 |
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectosmq.broker.SlaveRouterProcessor
A class that attaches to a Message Router as a subscriber, subscribing to all topics, and saves subscribed messages to a Queue. The Queue can be later copied to another Queue, or saved to an external file.
Constructor Summary | |
SlaveRouterProcessor()
|
Method Summary | |
void |
close()
Disconnect the connection to the Message Broker and closes the Queue. |
void |
closeConnection()
Closes the connection to the Message Broker. |
java.lang.String |
getServiceName()
|
long |
getSlaveQueueCount()
|
boolean |
isFlushOnClose()
Returns true if calling close will result in messages being lost. |
void |
run()
|
void |
saveSlaveQueue()
Saves the data on the slave Queue to a permenant file. |
void |
setFlushOnClose(boolean b)
Defines whether the messages will be discarded when the broker is closed. |
void |
setServiceName(java.lang.String servicename)
|
MQue |
writeSlaveToQueue(PersistableMQue target)
Takes the data that has been written and transfers it to the target Queue. |
Methods inherited from class java.lang.Object |
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
public SlaveRouterProcessor()
Method Detail |
public void setServiceName(java.lang.String servicename)
public java.lang.String getServiceName()
public long getSlaveQueueCount()
public boolean isFlushOnClose()
public void setFlushOnClose(boolean b)
public MQue writeSlaveToQueue(PersistableMQue target) throws java.io.IOException
java.io.IOException
public void closeConnection()
public void saveSlaveQueue()
public void close()
isFlushOnClose()
public void run() throws java.io.IOException
java.io.IOException
|
(c) 2000 - 2003 MQue Systems All Rights Reserved |
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |