|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.codehaus.activemq.store.jdbc.JDBCMessageStore
Field Summary | |
protected JDBCAdapter |
adapter
|
protected String |
destinationName
|
protected JDBCPersistenceAdapter |
persistenceAdapter
|
protected LongSequenceGenerator |
sequenceGenerator
|
protected WireFormat |
wireFormat
|
Constructor Summary | |
JDBCMessageStore(JDBCPersistenceAdapter persistenceAdapter,
JDBCAdapter adapter,
WireFormat wireFormat,
String destinationName)
|
Method Summary | |
MessageIdentity |
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. |
void |
recover(QueueMessageContainer container)
Recover any messages to be delivered onto the dispatch queue. |
void |
removeMessage(MessageIdentity identity,
MessageAck ack)
|
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 String destinationName
protected final LongSequenceGenerator sequenceGenerator
protected final JDBCAdapter adapter
protected final JDBCPersistenceAdapter persistenceAdapter
Constructor Detail |
public JDBCMessageStore(JDBCPersistenceAdapter persistenceAdapter, JDBCAdapter adapter, WireFormat wireFormat, String destinationName)
Method Detail |
public MessageIdentity addMessage(ActiveMQMessage message) throws JMSException
MessageStore
addMessage
in interface MessageStore
JMSException
public ActiveMQMessage getMessage(MessageIdentity identity) throws JMSException
MessageStore
getMessage
in interface MessageStore
identity
- which contains either the messageID or the messageNumber
JMSException
public void removeMessage(MessageIdentity identity, MessageAck ack) throws JMSException
removeMessage
in interface MessageStore
JMSException
public void recover(QueueMessageContainer container) throws JMSException
MessageStore
recover
in interface MessageStore
container
-
JMSException
public void start() throws JMSException
Service
start
in interface Service
JMSException
public void stop() throws JMSException
Service
stop
in interface Service
JMSException
|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |