public class JDBCMessageStore extends AbstractMessageStore
Modifier and Type | Field and Description |
---|---|
protected JDBCAdapter |
adapter |
protected org.apache.activemq.ActiveMQMessageAudit |
audit |
protected LinkedList<Long> |
pendingAdditions |
protected JDBCPersistenceAdapter |
persistenceAdapter |
protected TreeMap<Long,org.apache.activemq.command.Message> |
rolledBackAcks |
protected org.apache.activemq.wireformat.WireFormat |
wireFormat |
destination, FUTURE, indexListener, prioritizedMessages
Constructor and Description |
---|
JDBCMessageStore(JDBCPersistenceAdapter persistenceAdapter,
JDBCAdapter adapter,
org.apache.activemq.wireformat.WireFormat wireFormat,
org.apache.activemq.command.ActiveMQDestination destination,
org.apache.activemq.ActiveMQMessageAudit audit) |
Modifier and Type | Method and Description |
---|---|
void |
addMessage(ConnectionContext context,
org.apache.activemq.command.Message message) |
void |
addMessageReference(ConnectionContext context,
org.apache.activemq.command.MessageId messageId,
long expirationTime,
String messageRef) |
org.apache.activemq.command.Message |
getMessage(org.apache.activemq.command.MessageId messageId) |
int |
getMessageCount() |
String |
getMessageReference(org.apache.activemq.command.MessageId messageId) |
protected void |
onAdd(org.apache.activemq.command.Message message,
long sequenceId,
byte priority) |
void |
recover(MessageRecoveryListener listener) |
void |
recoverNextMessages(int maxReturned,
MessageRecoveryListener listener) |
void |
removeAllMessages(ConnectionContext context) |
void |
removeMessage(ConnectionContext context,
org.apache.activemq.command.MessageAck ack) |
void |
resetBatching() |
void |
setBatch(org.apache.activemq.command.MessageId messageId) |
void |
setPrioritizedMessages(boolean prioritizedMessages) |
String |
toString() |
void |
trackRollbackAck(org.apache.activemq.command.Message message) |
void |
updateMessage(org.apache.activemq.command.Message message) |
addMessage, asyncAddQueueMessage, asyncAddQueueMessage, asyncAddTopicMessage, asyncAddTopicMessage, dispose, getDestination, getIndexListener, isEmpty, isPrioritizedMessages, registerIndexListener, removeAsyncMessage, setMemoryUsage, start, stop
protected final org.apache.activemq.wireformat.WireFormat wireFormat
protected final JDBCAdapter adapter
protected final JDBCPersistenceAdapter persistenceAdapter
protected org.apache.activemq.ActiveMQMessageAudit audit
protected final LinkedList<Long> pendingAdditions
protected final TreeMap<Long,org.apache.activemq.command.Message> rolledBackAcks
public JDBCMessageStore(JDBCPersistenceAdapter persistenceAdapter, JDBCAdapter adapter, org.apache.activemq.wireformat.WireFormat wireFormat, org.apache.activemq.command.ActiveMQDestination destination, org.apache.activemq.ActiveMQMessageAudit audit) throws IOException
IOException
public void addMessage(ConnectionContext context, org.apache.activemq.command.Message message) throws IOException
IOException
public void updateMessage(org.apache.activemq.command.Message message) throws IOException
updateMessage
in interface MessageStore
updateMessage
in class AbstractMessageStore
IOException
protected void onAdd(org.apache.activemq.command.Message message, long sequenceId, byte priority)
public void addMessageReference(ConnectionContext context, org.apache.activemq.command.MessageId messageId, long expirationTime, String messageRef) throws IOException
IOException
public org.apache.activemq.command.Message getMessage(org.apache.activemq.command.MessageId messageId) throws IOException
IOException
public String getMessageReference(org.apache.activemq.command.MessageId messageId) throws IOException
IOException
public void removeMessage(ConnectionContext context, org.apache.activemq.command.MessageAck ack) throws IOException
IOException
public void recover(MessageRecoveryListener listener) throws Exception
Exception
public void removeAllMessages(ConnectionContext context) throws IOException
IOException
MessageStore.removeAllMessages(ConnectionContext)
public int getMessageCount() throws IOException
IOException
public void recoverNextMessages(int maxReturned, MessageRecoveryListener listener) throws Exception
maxReturned
- listener
- Exception
MessageStore.recoverNextMessages(int,
org.apache.activemq.store.MessageRecoveryListener)
public void trackRollbackAck(org.apache.activemq.command.Message message)
public void resetBatching()
MessageStore.resetBatching()
public void setBatch(org.apache.activemq.command.MessageId messageId)
setBatch
in interface MessageStore
setBatch
in class AbstractMessageStore
public void setPrioritizedMessages(boolean prioritizedMessages)
setPrioritizedMessages
in interface MessageStore
setPrioritizedMessages
in class AbstractMessageStore
Copyright © 2005–2018 FuseSource, Corp.. All rights reserved.