org.codehaus.activemq.store.jdbc
Class JDBCMessageStore
java.lang.Object
org.codehaus.activemq.store.jdbc.JDBCMessageStore
- All Implemented Interfaces:
- org.codehaus.activemq.store.MessageStore, org.codehaus.activemq.service.Service
- Direct Known Subclasses:
- JDBCTopicMessageStore
- public class JDBCMessageStore
- extends Object
- implements org.codehaus.activemq.store.MessageStore
- Version:
- $Revision: 1.3 $
Method Summary |
org.codehaus.activemq.service.MessageIdentity |
addMessage(org.codehaus.activemq.message.ActiveMQMessage message)
|
org.codehaus.activemq.message.ActiveMQMessage |
getMessage(org.codehaus.activemq.service.MessageIdentity identity)
|
void |
recover(org.codehaus.activemq.service.QueueMessageContainer container)
|
void |
removeAllMessages()
|
void |
removeMessage(org.codehaus.activemq.service.MessageIdentity identity,
org.codehaus.activemq.message.MessageAck ack)
|
void |
start()
|
void |
stop()
|
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
wireFormat
protected final org.codehaus.activemq.io.WireFormat wireFormat
destinationName
protected final String destinationName
sequenceGenerator
protected final org.codehaus.activemq.util.LongSequenceGenerator sequenceGenerator
adapter
protected final JDBCAdapter adapter
persistenceAdapter
protected final JDBCPersistenceAdapter persistenceAdapter
JDBCMessageStore
public JDBCMessageStore(JDBCPersistenceAdapter persistenceAdapter,
JDBCAdapter adapter,
org.codehaus.activemq.io.WireFormat wireFormat,
String destinationName)
addMessage
public org.codehaus.activemq.service.MessageIdentity addMessage(org.codehaus.activemq.message.ActiveMQMessage message)
throws JMSException
- Specified by:
addMessage
in interface org.codehaus.activemq.store.MessageStore
- Throws:
JMSException
getMessage
public org.codehaus.activemq.message.ActiveMQMessage getMessage(org.codehaus.activemq.service.MessageIdentity identity)
throws JMSException
- Specified by:
getMessage
in interface org.codehaus.activemq.store.MessageStore
- Throws:
JMSException
removeMessage
public void removeMessage(org.codehaus.activemq.service.MessageIdentity identity,
org.codehaus.activemq.message.MessageAck ack)
throws JMSException
- Specified by:
removeMessage
in interface org.codehaus.activemq.store.MessageStore
- Throws:
JMSException
recover
public void recover(org.codehaus.activemq.service.QueueMessageContainer container)
throws JMSException
- Specified by:
recover
in interface org.codehaus.activemq.store.MessageStore
- Throws:
JMSException
start
public void start()
throws JMSException
- Specified by:
start
in interface org.codehaus.activemq.service.Service
- Throws:
JMSException
stop
public void stop()
throws JMSException
- Specified by:
stop
in interface org.codehaus.activemq.service.Service
- Throws:
JMSException
removeAllMessages
public void removeAllMessages()
throws JMSException
- Specified by:
removeAllMessages
in interface org.codehaus.activemq.store.MessageStore
- Throws:
JMSException
- See Also:
MessageStore.removeAllMessages()
Copyright © 2004-2005 Protique, Ltd.. All Rights Reserved.