org.openeai.jms.consumer
Class PubSubMessageStore

java.lang.Object

  |

  +--org.openeai.OpenEaiObject

        |

        +--org.openeai.jms.consumer.PubSubMessageStore

public class PubSubMessageStore

extends OpenEaiObject

A Class class.

Version:

3.0 beta2 - 28 January 2003

Author:

Tod Jackson (tod@openeai.org), Steve Wheat (steve@openeai.org)

Field Summary

Fields inherited from class org.openeai.OpenEaiObject

logger

Constructor Summary

PubSubMessageStore(java.util.Properties props)
Constructor

Method Summary

void	addStoredMessage(StoredMessage sMessage)
boolean	getGuaranteedOrderOfProcessing()
StoredMessage	getStoredMessage()
java.util.Vector	getStoredMessageIds()
java.util.Vector	getStoredMessages()
javax.jms.TopicSession	getTopicSession()
void	persistStore()
boolean	predecessorExists(java.lang.String msgSeries)
void	removeStoredMessage(StoredMessage sMsg)
void	setGuaranteedOrderOfProcessing(boolean gop)
void	setStoredMessageIds(java.util.Vector messages)
void	setStoredMessages(java.util.Vector messages)
void	setTopicSession(javax.jms.TopicSession session)

Methods inherited from class org.openeai.OpenEaiObject

addLog4jProperty, getAppName, getDebug, getFromAddr, getLog4jProperties, getMailHost, getMailService, getProperties, getToAddr, initializeLog4j, initializeLog4j, initializeLog4j, setAppName, setDebug, setFromAddr, setMailHost, setMailService, setProperties, setToAddr

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

PubSubMessageStore

public PubSubMessageStore(java.util.Properties props)
                   throws java.io.IOException

Constructor

Method Detail

getTopicSession

public javax.jms.TopicSession getTopicSession()

setTopicSession

public void setTopicSession(javax.jms.TopicSession session)

setGuaranteedOrderOfProcessing

public void setGuaranteedOrderOfProcessing(boolean gop)

getGuaranteedOrderOfProcessing

public boolean getGuaranteedOrderOfProcessing()

getStoredMessages

public java.util.Vector getStoredMessages()

setStoredMessages

public void setStoredMessages(java.util.Vector messages)

getStoredMessageIds

public java.util.Vector getStoredMessageIds()

setStoredMessageIds

public void setStoredMessageIds(java.util.Vector messages)

addStoredMessage

public void addStoredMessage(StoredMessage sMessage)

getStoredMessage

public StoredMessage getStoredMessage()
                               throws java.sql.SQLException

java.sql.SQLException

removeStoredMessage

public void removeStoredMessage(StoredMessage sMsg)

persistStore

public void persistStore()
                  throws javax.jms.JMSException,
                         java.sql.SQLException

javax.jms.JMSException

java.sql.SQLException

predecessorExists

public boolean predecessorExists(java.lang.String msgSeries)
                          throws java.sql.SQLException

java.sql.SQLException