org.codehaus.activemq.store.jdbc
Class JDBCMessageStore

java.lang.Object
  extended byorg.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 $

Field Summary
protected  JDBCAdapter adapter
           
protected  String destinationName
           
protected  JDBCPersistenceAdapter persistenceAdapter
           
protected  org.codehaus.activemq.util.LongSequenceGenerator sequenceGenerator
           
protected  org.codehaus.activemq.io.WireFormat wireFormat
           
 
Constructor Summary
JDBCMessageStore(JDBCPersistenceAdapter persistenceAdapter, JDBCAdapter adapter, org.codehaus.activemq.io.WireFormat wireFormat, String destinationName)
           
 
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
 

Field Detail

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
Constructor Detail

JDBCMessageStore

public JDBCMessageStore(JDBCPersistenceAdapter persistenceAdapter,
                        JDBCAdapter adapter,
                        org.codehaus.activemq.io.WireFormat wireFormat,
                        String destinationName)
Method Detail

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.