|
OSMQ v2.0.1 |
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectosmq.clients.PublisherBase
osmq.clients.PublisherBean
osmq.clients.BatchPublisher
Constructor Summary | |
BatchPublisher()
|
|
BatchPublisher(java.lang.String identifier)
|
Method Summary | |
void |
addMessageBuilder(MessageBuilder builder)
Adds a message builder that will create messages that will be written by the message publisher. |
MessageBuilder |
getControlMessageBuilder()
Returns a reference to the MessageBuilder that will create preliminary and final control messages. |
int |
getFocusBuilder()
|
java.lang.String |
getFocusBuilderName()
|
int |
getMaxRate()
Returns the maximum rate (in messages-per-second) at which message will be published. |
int |
getTotalBuilders()
|
void |
halt()
Terminate published messages. |
boolean |
isPublishing()
Returns true if this is a threaded publisher and messages are currently being published. |
boolean |
isThreaded()
Returns true if batch publishing will be performed by a seperate thread, and false if by the thread that calls PublishMessages() |
void |
publishMessages()
Called to initiate message publishing. |
void |
removeMessageBuilder(MessageBuilder builder)
Removes a MessageBuilder from the set that will publish messages. |
void |
run()
Called by the internal methods. |
void |
setControlMessageBuilder(MessageBuilder mb)
Sets the control MessageBuilder that will create preliminary and a final control message. |
void |
setMaxRate(int rate)
Sets the maximum rate of message publishing (in messages per second). |
void |
setThreaded(boolean threaded)
Determines whether batch publishing will be performed by a seperate thread, or by the thread that calls PublishMessages(). |
Methods inherited from class osmq.clients.PublisherBean |
close, commit, getBrokerName, getClientID, getCommitTransactionCount, getConnectionPublishedCount, getExceptionListener, getHostName, getPortID, getPublishedCount, isAutoCommit, isOpen, onException, open, publish, rollback, setAutoCommit, setBrokerName, setClientID, setExceptionListener, setHostName, setPortID |
Methods inherited from class java.lang.Object |
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Methods inherited from interface osmq.clients.Publisher |
commit, getConnectionPublishedCount, getPublishedCount, isOpen, publish, rollback |
Constructor Detail |
public BatchPublisher()
public BatchPublisher(java.lang.String identifier)
Method Detail |
public void setThreaded(boolean threaded)
setThreaded
in interface Publisher
setThreaded
in class PublisherBean
public boolean isThreaded()
isThreaded
in interface Publisher
isThreaded
in class PublisherBean
public void addMessageBuilder(MessageBuilder builder)
public void removeMessageBuilder(MessageBuilder builder)
public boolean isPublishing()
public int getFocusBuilder()
public java.lang.String getFocusBuilderName()
public int getTotalBuilders()
public void run()
run
in interface java.lang.Runnable
public void publishMessages() throws java.lang.Exception
java.lang.Exception
public void setMaxRate(int rate)
public int getMaxRate()
public void halt()
setThreaded(boolean)
public void setControlMessageBuilder(MessageBuilder mb)
public MessageBuilder getControlMessageBuilder()
|
(c) 2000 - 2003 MQue Systems All Rights Reserved |
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |