Modifier and Type | Method and Description |
---|---|
Message |
Message.putBooleanProperty(SimpleString key,
boolean value)
Puts a boolean property in this message.
|
Message |
Message.putBooleanProperty(String key,
boolean value) |
Message |
Message.putByteProperty(SimpleString key,
byte value)
Puts a byte property in this message.
|
Message |
Message.putByteProperty(String key,
byte value) |
Message |
Message.putBytesProperty(SimpleString key,
byte[] value)
Puts a byte[] property in this message.
|
Message |
Message.putBytesProperty(String key,
byte[] value) |
Message |
Message.putCharProperty(SimpleString key,
char value)
Puts a char property in this message.
|
Message |
Message.putCharProperty(String key,
char value) |
Message |
Message.putDoubleProperty(SimpleString key,
double value)
Puts a double property in this message.
|
Message |
Message.putDoubleProperty(String key,
double value) |
Message |
Message.putFloatProperty(SimpleString key,
float value)
Puts a float property in this message.
|
Message |
Message.putFloatProperty(String key,
float value) |
Message |
Message.putIntProperty(SimpleString key,
int value)
Puts an int property in this message.
|
Message |
Message.putIntProperty(String key,
int value) |
Message |
Message.putLongProperty(SimpleString key,
long value)
Puts a long property in this message.
|
Message |
Message.putLongProperty(String key,
long value) |
Message |
Message.putObjectProperty(SimpleString key,
Object value)
Puts an Object property in this message.
|
Message |
Message.putObjectProperty(String key,
Object value) |
Message |
Message.putShortProperty(SimpleString key,
short value)
Puts a short property in this message.
|
Message |
Message.putShortProperty(String key,
short value) |
Message |
Message.putStringProperty(SimpleString key,
SimpleString value)
Puts a SimpleString property in this message.
|
Message |
Message.putStringProperty(String key,
String value)
Puts a String property in this message.
|
Message |
Message.setAddress(SimpleString address)
Sets the address to send this message to.
|
Message |
Message.setDurable(boolean durable)
Sets whether this message is durable or not.
|
Message |
Message.setExpiration(long expiration)
Sets the expiration of this message.
|
Message |
Message.setPriority(byte priority)
Sets the message priority.
|
Message |
Message.setTimestamp(long timestamp)
Sets the message timestamp.
|
Message |
Message.setUserID(UUID userID)
Sets the user ID
|
Message |
Message.writeBodyBufferBytes(byte[] bytes)
Writes the input byte array to the message body ActiveMQBuffer
|
Message |
Message.writeBodyBufferString(String string)
Writes the input String to the message body ActiveMQBuffer
|
Modifier and Type | Interface and Description |
---|---|
interface |
ClientMessage
A ClientMessage represents a message sent and/or received by ActiveMQ Artemis.
|
Modifier and Type | Method and Description |
---|---|
void |
ClientProducer.send(Message message)
Sends a message to an address.
|
void |
ClientProducer.send(Message message,
SendAcknowledgementHandler handler)
Sends a message to the specified address instead of the ClientProducer's address.
|
void |
ClientProducer.send(SimpleString address,
Message message)
Sends a message to the specified address instead of the ClientProducer's address.
|
void |
ClientProducer.send(SimpleString address,
Message message,
SendAcknowledgementHandler handler)
Sends a message to the specified address instead of the ClientProducer's address.
|
void |
ClientProducer.send(String address,
Message message)
Sends a message to the specified address instead of the ClientProducer's address.
|
void |
SendAcknowledgementHandler.sendAcknowledged(Message message)
Notifies the client that a message sent asynchronously has been received by the server.
|
Modifier and Type | Method and Description |
---|---|
static Object |
ManagementHelper.getResult(Message message)
Returns the result of an operation invocation or an attribute value.
|
static Object |
ManagementHelper.getResult(Message message,
Class desiredType)
Returns the result of an operation invocation or an attribute value.
|
static Object[] |
ManagementHelper.getResults(Message message)
Returns the result of an operation invocation or an attribute value.
|
static boolean |
ManagementHelper.hasOperationSucceeded(Message message)
Returns whether the invocation of the management operation on the server resource succeeded.
|
static boolean |
ManagementHelper.isAttributesResult(Message message)
Returns whether the JMS message corresponds to the result of a management attribute value.
|
static boolean |
ManagementHelper.isOperationResult(Message message)
Returns whether the JMS message corresponds to the result of a management operation invocation.
|
static void |
ManagementHelper.putAttribute(Message message,
String resourceName,
String attribute)
Stores a resource attribute in a message to retrieve the value from the server resource.
|
static void |
ManagementHelper.putOperationInvocation(Message message,
String resourceName,
String operationName)
Stores an operation invocation in a message to invoke the corresponding operation the value from the server resource.
|
static void |
ManagementHelper.putOperationInvocation(Message message,
String resourceName,
String operationName,
Object... parameters)
Stores an operation invocation in a message to invoke the corresponding operation the value from the server resource.
|
static Object[] |
ManagementHelper.retrieveOperationParameters(Message message)
Used by ActiveMQ Artemis management service.
|
static void |
ManagementHelper.storeResult(Message message,
Object result)
Used by ActiveMQ Artemis management service.
|
Modifier and Type | Interface and Description |
---|---|
interface |
ClientLargeMessageInternal |
interface |
ClientMessageInternal |
Modifier and Type | Class and Description |
---|---|
class |
ClientLargeMessageImpl
ClientLargeMessageImpl is only created when receiving large messages.
|
class |
ClientMessageImpl
A ClientMessageImpl
|
Modifier and Type | Method and Description |
---|---|
void |
ClientSessionImpl.acknowledge(ClientConsumer consumer,
Message message)
Acknowledges all messages received by the consumer so far.
|
void |
ClientSessionInternal.acknowledge(ClientConsumer consumer,
Message message) |
void |
ClientSessionImpl.expire(ClientConsumer consumer,
Message message) |
void |
ClientSessionInternal.expire(ClientConsumer consumer,
Message message) |
void |
ClientSessionImpl.individualAcknowledge(ClientConsumer consumer,
Message message) |
void |
ClientSessionInternal.individualAcknowledge(ClientConsumer consumer,
Message message) |
void |
ClientSessionImpl.scheduleConfirmation(SendAcknowledgementHandler handler,
Message message) |
void |
ClientSessionInternal.scheduleConfirmation(SendAcknowledgementHandler handler,
Message message) |
void |
ClientProducerImpl.send(Message msg) |
void |
ClientProducerImpl.send(Message message,
SendAcknowledgementHandler handler) |
void |
ClientProducerImpl.send(SimpleString address1,
Message msg) |
void |
ClientProducerImpl.send(SimpleString address1,
Message message,
SendAcknowledgementHandler handler) |
void |
ClientProducerImpl.send(String address1,
Message message) |
void |
ClientSessionImpl.setAddress(Message message,
SimpleString address) |
void |
ClientSessionInternal.setAddress(Message message,
SimpleString address)
This will set the address at the message
|
Modifier and Type | Interface and Description |
---|---|
interface |
MessageInternal |
Modifier and Type | Class and Description |
---|---|
class |
MessageImpl
A concrete implementation of a message
|
Modifier and Type | Method and Description |
---|---|
Message |
MessageImpl.putBooleanProperty(SimpleString key,
boolean value) |
Message |
MessageImpl.putBooleanProperty(String key,
boolean value) |
Message |
MessageImpl.putByteProperty(SimpleString key,
byte value) |
Message |
MessageImpl.putByteProperty(String key,
byte value) |
Message |
MessageImpl.putBytesProperty(SimpleString key,
byte[] value) |
Message |
MessageImpl.putBytesProperty(String key,
byte[] value) |
Message |
MessageImpl.putCharProperty(SimpleString key,
char value) |
Message |
MessageImpl.putCharProperty(String key,
char value) |
Message |
MessageImpl.putDoubleProperty(SimpleString key,
double value) |
Message |
MessageImpl.putDoubleProperty(String key,
double value) |
Message |
MessageImpl.putFloatProperty(SimpleString key,
float value) |
Message |
MessageImpl.putFloatProperty(String key,
float value) |
Message |
MessageImpl.putIntProperty(SimpleString key,
int value) |
Message |
MessageImpl.putIntProperty(String key,
int value) |
Message |
MessageImpl.putLongProperty(SimpleString key,
long value) |
Message |
MessageImpl.putLongProperty(String key,
long value) |
Message |
MessageImpl.putObjectProperty(SimpleString key,
Object value) |
Message |
MessageImpl.putObjectProperty(String key,
Object value) |
Message |
MessageImpl.putShortProperty(SimpleString key,
short value) |
Message |
MessageImpl.putShortProperty(String key,
short value) |
Message |
MessageImpl.putStringProperty(SimpleString key,
SimpleString value) |
Message |
MessageImpl.putStringProperty(String key,
String value) |
Message |
MessageImpl.putTypedProperties(TypedProperties otherProps) |
Message |
MessageImpl.setAddress(SimpleString address)
The only reason this is synchronized is because of encoding a message versus invalidating the buffer.
|
Message |
MessageImpl.writeBodyBufferBytes(byte[] bytes) |
Message |
MessageImpl.writeBodyBufferString(String string) |
Modifier and Type | Class and Description |
---|---|
class |
LargeServerMessageImpl |
Modifier and Type | Method and Description |
---|---|
Message |
DescribeJournal.MessageDescribe.getMsg() |
Message |
LargeServerMessageInSync.setDurable(boolean durable) |
Message |
LargeServerMessageInSync.setMessageID(long id) |
Constructor and Description |
---|
MessageDescribe(Message msg) |
Modifier and Type | Method and Description |
---|---|
void |
ActiveMQSessionContext.expireMessage(ClientConsumer consumer,
Message message) |
void |
ActiveMQSessionContext.sendACK(boolean individual,
boolean block,
ClientConsumer consumer,
Message message) |
Modifier and Type | Method and Description |
---|---|
Message |
SessionSendLargeMessage.getMessage() |
Message |
SessionReceiveLargeMessage.getMessage() |
Message |
MessagePacketI.getMessage() |
Message |
MessagePacket.getMessage() |
Modifier and Type | Method and Description |
---|---|
static void |
HQPropertiesConverter.replaceAMQProperties(Message message) |
static void |
HQPropertiesConverter.replaceHQProperties(Message message) |
Modifier and Type | Method and Description |
---|---|
Message |
ReplicatedLargeMessage.setDurable(boolean b) |
Message |
ReplicatedLargeMessage.setMessageID(long id) |
Modifier and Type | Interface and Description |
---|---|
interface |
LargeServerMessage |
interface |
ServerMessage
A ServerMessage
|
Modifier and Type | Method and Description |
---|---|
void |
BridgeImpl.sendAcknowledged(Message message) |
Modifier and Type | Class and Description |
---|---|
class |
ServerMessageImpl |
Modifier and Type | Method and Description |
---|---|
static void |
MessageUtil.clearProperties(Message message) |
static String |
MessageUtil.getJMSCorrelationID(Message message) |
static byte[] |
MessageUtil.getJMSCorrelationIDAsBytes(Message message) |
static SimpleString |
MessageUtil.getJMSReplyTo(Message message) |
static String |
MessageUtil.getJMSType(Message message) |
static Set<String> |
MessageUtil.getPropertyNames(Message message) |
static boolean |
MessageUtil.propertyExists(Message message,
String name) |
static void |
MessageUtil.setJMSCorrelationID(Message message,
String correlationID) |
static void |
MessageUtil.setJMSCorrelationIDAsBytes(Message message,
byte[] correlationID) |
static void |
MessageUtil.setJMSReplyTo(Message message,
SimpleString dest) |
static void |
MessageUtil.setJMSType(Message message,
String type) |
Modifier and Type | Method and Description |
---|---|
abstract void |
SessionContext.expireMessage(ClientConsumer consumer,
Message message) |
abstract void |
SessionContext.sendACK(boolean individual,
boolean block,
ClientConsumer consumer,
Message message) |
Copyright © 2016 The Apache Software Foundation. All rights reserved.