Modifier and Type | Method and Description |
---|---|
<M extends ServerMessage<? extends StorableMessageMetaData>> |
DefaultDestination.send(M message,
String routingAddress,
InstanceProperties instanceProperties,
ServerTransaction txn,
Action<? super MessageInstance> postEnqueueAction) |
<M extends ServerMessage<? extends StorableMessageMetaData>> |
AbstractExchange.send(M message,
String routingAddress,
InstanceProperties instanceProperties,
ServerTransaction txn,
Action<? super MessageInstance> postEnqueueAction) |
Modifier and Type | Class and Description |
---|---|
class |
AbstractServerMessageImpl<X extends AbstractServerMessageImpl<X,T>,T extends StorableMessageMetaData> |
interface |
EnqueueableMessage<T extends StorableMessageMetaData> |
interface |
ServerMessage<T extends StorableMessageMetaData> |
Modifier and Type | Method and Description |
---|---|
<M extends ServerMessage<? extends StorableMessageMetaData>> |
MessageDestination.send(M message,
String routingAddress,
InstanceProperties instanceProperties,
ServerTransaction txn,
Action<? super MessageInstance> postEnqueueAction)
Routes a message
|
Modifier and Type | Class and Description |
---|---|
class |
InternalMessageMetaData |
Modifier and Type | Interface and Description |
---|---|
interface |
MessageMetaDataType<M extends StorableMessageMetaData> |
static interface |
MessageMetaDataType.Factory<M extends StorableMessageMetaData> |
Modifier and Type | Class and Description |
---|---|
class |
MessageMetaData_0_10 |
Modifier and Type | Class and Description |
---|---|
class |
MessageMetaData
Encapsulates a publish body and a content header.
|
Modifier and Type | Class and Description |
---|---|
class |
MessageMetaData_1_0 |
Modifier and Type | Method and Description |
---|---|
<M extends ServerMessage<? extends StorableMessageMetaData>> |
AbstractQueue.send(M message,
String routingAddress,
InstanceProperties instanceProperties,
ServerTransaction txn,
Action<? super MessageInstance> postEnqueueAction) |
Modifier and Type | Interface and Description |
---|---|
interface |
MessageHandle<M extends StorableMessageMetaData> |
class |
StoredMemoryMessage<T extends StorableMessageMetaData> |
interface |
StoredMessage<M extends StorableMessageMetaData> |
Modifier and Type | Method and Description |
---|---|
<T extends StorableMessageMetaData> |
AbstractJDBCMessageStore.addMessage(T metaData) |
<T extends StorableMessageMetaData> |
MessageStore.addMessage(T metaData) |
<T extends StorableMessageMetaData> |
NullMessageStore.addMessage(T metaData) |
<T extends StorableMessageMetaData> |
MemoryMessageStore.addMessage(T metaData) |
Modifier and Type | Method and Description |
---|---|
<T extends StorableMessageMetaData> |
AbstractBDBMessageStore.addMessage(T metaData) |
Modifier and Type | Method and Description |
---|---|
StorableMessageMetaData |
MessageMetaDataBinding.entryToObject(com.sleepycat.je.DatabaseEntry entry) |
Modifier and Type | Method and Description |
---|---|
void |
MessageMetaDataBinding.objectToEntry(StorableMessageMetaData metaData,
com.sleepycat.je.DatabaseEntry entry) |
Copyright © 2006–2016 The Apache Software Foundation. All rights reserved.