public class TempKahaDBStore.KahaDBMessageStore extends AbstractMessageStore
Modifier and Type | Field and Description |
---|---|
protected KahaDestination |
dest |
destination, FUTURE, indexListener, prioritizedMessages
Constructor and Description |
---|
TempKahaDBStore.KahaDBMessageStore(org.apache.activemq.command.ActiveMQDestination destination) |
Modifier and Type | Method and Description |
---|---|
void |
addMessage(ConnectionContext context,
org.apache.activemq.command.Message message) |
org.apache.activemq.command.ActiveMQDestination |
getDestination() |
org.apache.activemq.command.Message |
getMessage(org.apache.activemq.command.MessageId identity) |
int |
getMessageCount() |
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 identity) |
void |
setMemoryUsage(MemoryUsage memoryUsage) |
void |
start() |
void |
stop() |
addMessage, asyncAddQueueMessage, asyncAddQueueMessage, asyncAddTopicMessage, asyncAddTopicMessage, dispose, getIndexListener, isEmpty, isPrioritizedMessages, registerIndexListener, removeAsyncMessage, setPrioritizedMessages, updateMessage
protected KahaDestination dest
public TempKahaDBStore.KahaDBMessageStore(org.apache.activemq.command.ActiveMQDestination destination)
public org.apache.activemq.command.ActiveMQDestination getDestination()
getDestination
in interface MessageStore
getDestination
in class AbstractMessageStore
public void addMessage(ConnectionContext context, org.apache.activemq.command.Message message) throws IOException
IOException
public void removeMessage(ConnectionContext context, org.apache.activemq.command.MessageAck ack) throws IOException
IOException
public void removeAllMessages(ConnectionContext context) throws IOException
IOException
public org.apache.activemq.command.Message getMessage(org.apache.activemq.command.MessageId identity) throws IOException
IOException
public int getMessageCount() throws IOException
IOException
public void recover(MessageRecoveryListener listener) throws Exception
Exception
public void recoverNextMessages(int maxReturned, MessageRecoveryListener listener) throws Exception
Exception
public void resetBatching()
public void setBatch(org.apache.activemq.command.MessageId identity) throws IOException
setBatch
in interface MessageStore
setBatch
in class AbstractMessageStore
IOException
public void setMemoryUsage(MemoryUsage memoryUsage)
setMemoryUsage
in interface MessageStore
setMemoryUsage
in class AbstractMessageStore
public void start() throws Exception
start
in interface org.apache.activemq.Service
start
in class AbstractMessageStore
Exception
public void stop() throws Exception
stop
in interface org.apache.activemq.Service
stop
in class AbstractMessageStore
Exception
Copyright © 2005–2017 FuseSource, Corp.. All rights reserved.