|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.activemq.store.jdbc.JDBCMessageStore
Field Summary | |
protected JDBCAdapter |
adapter
|
protected java.lang.String |
destinationName
|
protected JDBCPersistenceAdapter |
persistenceAdapter
|
protected LongSequenceGenerator |
sequenceGenerator
|
protected WireFormat |
wireFormat
|
Constructor Summary | |
JDBCMessageStore(JDBCPersistenceAdapter persistenceAdapter,
JDBCAdapter adapter,
WireFormat wireFormat,
java.lang.String destinationName)
|
Method Summary | |
void |
addMessage(ActiveMQMessage message)
Adds a message to the message store |
ActiveMQMessage |
getMessage(MessageIdentity identity)
Looks up a message using either the String messageID or the messageNumber. |
protected long |
getMessageSequenceId(MessageIdentity identity)
|
void |
recover(RecoveryListener listener)
Recover any messages to be delivered. |
void |
removeAllMessages()
Removes all the messages from the message store. |
void |
removeMessage(MessageAck ack)
Removes a message from the message store. |
void |
start()
Called to start the service |
void |
stop()
Called to shutdown the service |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Field Detail |
protected final WireFormat wireFormat
protected final java.lang.String destinationName
protected final LongSequenceGenerator sequenceGenerator
protected final JDBCAdapter adapter
protected final JDBCPersistenceAdapter persistenceAdapter
Constructor Detail |
public JDBCMessageStore(JDBCPersistenceAdapter persistenceAdapter, JDBCAdapter adapter, WireFormat wireFormat, java.lang.String destinationName)
Method Detail |
public void addMessage(ActiveMQMessage message) throws javax.jms.JMSException
MessageStore
addMessage
in interface MessageStore
javax.jms.JMSException
public ActiveMQMessage getMessage(MessageIdentity identity) throws javax.jms.JMSException
MessageStore
getMessage
in interface MessageStore
identity
- which contains either the messageID or the messageNumber
javax.jms.JMSException
protected long getMessageSequenceId(MessageIdentity identity) throws javax.jms.JMSException
identity
-
javax.jms.JMSException
public void removeMessage(MessageAck ack) throws javax.jms.JMSException
MessageStore
removeMessage
in interface MessageStore
ack
- the ack request that cause the message to be removed. It conatins
the identity which contains the messageID of the message that needs to be removed.
javax.jms.JMSException
public void recover(RecoveryListener listener) throws javax.jms.JMSException
MessageStore
recover
in interface MessageStore
listener
-
javax.jms.JMSException
public void start() throws javax.jms.JMSException
Service
start
in interface Service
javax.jms.JMSException
public void stop() throws javax.jms.JMSException
Service
stop
in interface Service
javax.jms.JMSException
public void removeAllMessages() throws javax.jms.JMSException
MessageStore
removeAllMessages
in interface MessageStore
javax.jms.JMSException
MessageStore.removeAllMessages()
|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |