Modifier and Type | Method and Description |
---|---|
static InternalMessage |
InternalMessage.createBytesMessage(MessageStore store,
AMQMessageHeader header,
byte[] messageBody) |
static InternalMessage |
InternalMessage.createBytesMessage(MessageStore store,
AMQMessageHeader header,
byte[] messageBody,
boolean persist) |
static InternalMessage |
InternalMessage.createListMessage(MessageStore store,
AMQMessageHeader header,
List<? extends Object> messageBody) |
static InternalMessage |
InternalMessage.createMapMessage(MessageStore store,
AMQMessageHeader header,
Map<? extends Object,? extends Object> messageBody) |
static InternalMessage |
InternalMessage.createStringMessage(MessageStore store,
AMQMessageHeader header,
String messageBody) |
static InternalMessage |
InternalMessage.createStringMessage(MessageStore store,
AMQMessageHeader header,
String messageBody,
boolean persistent) |
Modifier and Type | Method and Description |
---|---|
MessageStore |
VirtualHost.getMessageStore() |
Modifier and Type | Method and Description |
---|---|
MessageStore |
ServerSession.getMessageStore() |
Modifier and Type | Method and Description |
---|---|
MessageStore |
AMQChannel.getMessageStore() |
Constructor and Description |
---|
AMQChannel(AMQPConnection_0_8 connection,
int channelId,
MessageStore messageStore) |
Modifier and Type | Class and Description |
---|---|
class |
AbstractJDBCMessageStore |
class |
MemoryMessageStore
A simple message store that stores the messages in a thread-safe structure in memory.
|
class |
NullMessageStore |
Modifier and Type | Method and Description |
---|---|
MessageStore |
MessageStoreProvider.getMessageStore() |
MessageStore |
NullMessageStore.getMessageStore() |
MessageStore |
AbstractMemoryStore.getMessageStore() |
Modifier and Type | Class and Description |
---|---|
class |
AbstractBDBMessageStore |
class |
BDBMessageStore
Implementation of a MessageStore backed by BDB JE.
|
Modifier and Type | Method and Description |
---|---|
MessageStore |
BDBConfigurationStore.getMessageStore() |
Modifier and Type | Class and Description |
---|---|
class |
AbstractDerbyMessageStore |
class |
DerbyMessageStore
Implementation of a MessageStore backed by Apache Derby.
|
Modifier and Type | Method and Description |
---|---|
MessageStore |
DerbyConfigurationStore.getMessageStore() |
Modifier and Type | Class and Description |
---|---|
class |
GenericAbstractJDBCMessageStore |
class |
GenericJDBCMessageStore
Implementation of a MessageStore backed by a Generic JDBC Database.
|
Modifier and Type | Method and Description |
---|---|
MessageStore |
GenericJDBCConfigurationStore.getMessageStore() |
Constructor and Description |
---|
AsyncAutoCommitTransaction(MessageStore transactionLog,
AsyncAutoCommitTransaction.FutureRecorder recorder) |
AutoCommitTransaction(MessageStore transactionLog) |
DistributedTransaction(AMQSessionModel session,
MessageStore store,
VirtualHostImpl vhost) |
DtxBranch(Transaction.StoredXidRecord storedXidRecord,
MessageStore store,
VirtualHostImpl vhost) |
DtxBranch(Xid xid,
MessageStore store,
VirtualHostImpl vhost) |
LocalTransaction(MessageStore transactionLog) |
LocalTransaction(MessageStore transactionLog,
LocalTransaction.ActivityTimeAccessor activityTime) |
Modifier and Type | Method and Description |
---|---|
protected MessageStore |
ProvidedStoreVirtualHostImpl.createMessageStore() |
protected abstract MessageStore |
AbstractVirtualHost.createMessageStore() |
MessageStore |
VirtualHostImpl.getMessageStore() |
MessageStore |
AbstractVirtualHost.getMessageStore() |
Modifier and Type | Method and Description |
---|---|
protected MessageStore |
BDBVirtualHostImpl.createMessageStore() |
protected MessageStore |
BDBHAVirtualHostImpl.createMessageStore() |
MessageStore |
BDBHAReplicaVirtualHostImpl.getMessageStore() |
Modifier and Type | Method and Description |
---|---|
protected MessageStore |
DerbyVirtualHostImpl.createMessageStore() |
Modifier and Type | Method and Description |
---|---|
protected MessageStore |
JDBCVirtualHostImpl.createMessageStore() |
Modifier and Type | Method and Description |
---|---|
protected MessageStore |
MemoryVirtualHost.createMessageStore() |
Copyright © 2006–2016 The Apache Software Foundation. All rights reserved.