Overview  Package   Class  Use  Deprecated  Index
Home >> All >> org >> activemq >> store >> [ jdbc overview ]	PREV CLASS  NEXT CLASS
SUMMARY:  JAVADOC |  SOURCE |  DOWNLOAD | NESTED | FIELD | CONSTR | METHOD	DETAIL: FIELD | CONSTR | METHOD

---

org.activemq.store.jdbc
Class JDBCMessageStore  

java.lang.Object
  org.activemq.store.jdbc.JDBCMessageStore

All Implemented Interfaces:

org.activemq.store.MessageStore, org.activemq.service.Service

Direct Known Subclasses:

JDBCTopicMessageStore

---

public class JDBCMessageStore

extends java.lang.Object

implements org.activemq.store.MessageStore

Version:

$Revision: 1.1 $

---

Field Summary
protected  JDBCAdapter	adapter
protected  java.lang.String	destinationName
protected  JDBCPersistenceAdapter	persistenceAdapter
protected  org.activemq.util.LongSequenceGenerator	sequenceGenerator
protected  org.activemq.io.WireFormat	wireFormat

 

Constructor Summary

JDBCMessageStore(JDBCPersistenceAdapter persistenceAdapter, JDBCAdapter adapter, org.activemq.io.WireFormat wireFormat, java.lang.String destinationName)

 

Method Summary
void	addMessage(org.activemq.message.ActiveMQMessage message)           Adds a message to the message store
org.activemq.message.ActiveMQMessage	getMessage(org.activemq.service.MessageIdentity identity)           Looks up a message using either the String messageID or the messageNumber.
protected  long	getMessageSequenceId(org.activemq.service.MessageIdentity identity)
void	recover(org.activemq.store.RecoveryListener listener)           Recover any messages to be delivered.
void	removeAllMessages()           Removes all the messages from the message store.
void	removeMessage(org.activemq.message.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

wireFormat

protected final org.activemq.io.WireFormat wireFormat

---

destinationName

protected final java.lang.String destinationName

---

sequenceGenerator

protected final org.activemq.util.LongSequenceGenerator sequenceGenerator

---

adapter

protected final JDBCAdapter adapter

---

persistenceAdapter

protected final JDBCPersistenceAdapter persistenceAdapter

Constructor Detail

JDBCMessageStore

public JDBCMessageStore(JDBCPersistenceAdapter persistenceAdapter,
                        JDBCAdapter adapter,
                        org.activemq.io.WireFormat wireFormat,
                        java.lang.String destinationName)

Method Detail

addMessage

public void addMessage(org.activemq.message.ActiveMQMessage message)
                throws javax.jms.JMSException

Description copied from interface: org.activemq.store.MessageStore

Adds a message to the message store

Specified by:

addMessage in interface org.activemq.store.MessageStore

---

getMessage

public org.activemq.message.ActiveMQMessage getMessage(org.activemq.service.MessageIdentity identity)
                                                throws javax.jms.JMSException

Description copied from interface: org.activemq.store.MessageStore

Looks up a message using either the String messageID or the messageNumber. Implementations are encouraged to fill in the missing key if its easy to do so.

Specified by:

getMessage in interface org.activemq.store.MessageStore

---

getMessageSequenceId

protected long getMessageSequenceId(org.activemq.service.MessageIdentity identity)
                             throws javax.jms.JMSException

---

removeMessage

public void removeMessage(org.activemq.message.MessageAck ack)
                   throws javax.jms.JMSException

Description copied from interface: org.activemq.store.MessageStore

Removes a message from the message store.

Specified by:

removeMessage in interface org.activemq.store.MessageStore

---

recover

public void recover(org.activemq.store.RecoveryListener listener)
             throws javax.jms.JMSException

Description copied from interface: org.activemq.store.MessageStore

Recover any messages to be delivered.

Specified by:

recover in interface org.activemq.store.MessageStore

---

start

public void start()
           throws javax.jms.JMSException

Description copied from interface: org.activemq.service.Service

Called to start the service

Specified by:

start in interface org.activemq.service.Service

---

stop

public void stop()
          throws javax.jms.JMSException

Description copied from interface: org.activemq.service.Service

Called to shutdown the service

Specified by:

stop in interface org.activemq.service.Service

---

removeAllMessages

public void removeAllMessages()
                       throws javax.jms.JMSException

Description copied from interface: org.activemq.store.MessageStore

Removes all the messages from the message store.

Specified by:

removeAllMessages in interface org.activemq.store.MessageStore

---

Overview  Package   Class  Use  Deprecated  Index
Home >> All >> org >> activemq >> store >> [ jdbc overview ]	PREV CLASS  NEXT CLASS
SUMMARY:  JAVADOC |  SOURCE |  DOWNLOAD | NESTED | FIELD | CONSTR | METHOD	DETAIL: FIELD | CONSTR | METHOD

---