Modifier and Type | Method and Description |
---|---|
ClientMessage |
ClientMessage.acknowledge()
Acknowledges reception of this message.
|
ClientMessage |
ClientSession.createMessage(boolean durable)
Creates a ClientMessage.
|
ClientMessage |
ClientSession.createMessage(byte type,
boolean durable)
Creates a ClientMessage.
|
ClientMessage |
ClientSession.createMessage(byte type,
boolean durable,
long expiration,
long timestamp,
byte priority)
Creates a ClientMessage.
|
ClientMessage |
ClientMessage.individualAcknowledge()
Acknowledges reception of a single message.
|
ClientMessage |
ClientMessage.putBooleanProperty(SimpleString key,
boolean value)
Overridden from
Message to enable fluent API |
ClientMessage |
ClientMessage.putBooleanProperty(String key,
boolean value)
Overridden from
Message to enable fluent API |
ClientMessage |
ClientMessage.putByteProperty(SimpleString key,
byte value)
Overridden from
Message to enable fluent API |
ClientMessage |
ClientMessage.putByteProperty(String key,
byte value)
Overridden from
Message to enable fluent API |
ClientMessage |
ClientMessage.putBytesProperty(SimpleString key,
byte[] value)
Overridden from
Message to enable fluent API |
ClientMessage |
ClientMessage.putBytesProperty(String key,
byte[] value)
Overridden from
Message to enable fluent API |
ClientMessage |
ClientMessage.putCharProperty(SimpleString key,
char value)
Overridden from
Message to enable fluent API |
ClientMessage |
ClientMessage.putCharProperty(String key,
char value)
Overridden from
Message to enable fluent API |
ClientMessage |
ClientMessage.putDoubleProperty(SimpleString key,
double value)
Overridden from
Message to enable fluent API |
ClientMessage |
ClientMessage.putDoubleProperty(String key,
double value)
Overridden from
Message to enable fluent API |
ClientMessage |
ClientMessage.putFloatProperty(SimpleString key,
float value)
Overridden from
Message to enable fluent API |
ClientMessage |
ClientMessage.putFloatProperty(String key,
float value)
Overridden from
Message to enable fluent API |
ClientMessage |
ClientMessage.putIntProperty(SimpleString key,
int value)
Overridden from
Message to enable fluent API |
ClientMessage |
ClientMessage.putIntProperty(String key,
int value)
Overridden from
Message to enable fluent API |
ClientMessage |
ClientMessage.putLongProperty(SimpleString key,
long value)
Overridden from
Message to enable fluent API |
ClientMessage |
ClientMessage.putLongProperty(String key,
long value)
Overridden from
Message to enable fluent API |
ClientMessage |
ClientMessage.putShortProperty(SimpleString key,
short value)
Overridden from
Message to enable fluent API |
ClientMessage |
ClientMessage.putShortProperty(String key,
short value)
Overridden from
Message to enable fluent API |
ClientMessage |
ClientMessage.putStringProperty(SimpleString key,
SimpleString value)
Overridden from
Message to enable fluent API |
ClientMessage |
ClientMessage.putStringProperty(String key,
String value)
Overridden from
Message to enable fluent API |
ClientMessage |
ClientConsumer.receive()
Receives a message from a queue.
|
ClientMessage |
ClientConsumer.receive(long timeout)
Receives a message from a queue.
|
ClientMessage |
ClientConsumer.receiveImmediate()
Receives a message from a queue.
|
ClientMessage |
ClientRequestor.request(ClientMessage request)
Sends a message to the request address and wait indefinitely for a reply.
|
ClientMessage |
ClientRequestor.request(ClientMessage request,
long timeout)
Sends a message to the request address and wait for the given timeout for a reply.
|
ClientMessage |
ClientMessage.setBodyInputStream(InputStream bodyInputStream)
Sets the body's IntputStream.
|
ClientMessage |
ClientMessage.setDeliveryCount(int deliveryCount)
Sets the delivery count for this message.
|
ClientMessage |
ClientMessage.setOutputStream(OutputStream out)
Sets the OutputStream that will receive the content of a message received in a non blocking way.
|
ClientMessage |
ClientMessage.writeBodyBufferBytes(byte[] bytes)
Overridden from
Message to enable fluent API |
ClientMessage |
ClientMessage.writeBodyBufferString(String string)
Overridden from
Message to enable fluent API |
Modifier and Type | Method and Description |
---|---|
void |
MessageHandler.onMessage(ClientMessage message)
Notifies the MessageHandler that a message has been received.
|
ClientMessage |
ClientRequestor.request(ClientMessage request)
Sends a message to the request address and wait indefinitely for a reply.
|
ClientMessage |
ClientRequestor.request(ClientMessage request,
long timeout)
Sends a message to the request address and wait for the given timeout for a reply.
|
Modifier and Type | Method and Description |
---|---|
static void |
DestinationAction.performCoreManagement(String brokerURL,
String user,
String password,
DestinationAction.ManagementCallback<ClientMessage> cb) |
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 |
---|---|
ClientMessage |
ClientSessionImpl.createMessage(boolean durable) |
ClientMessage |
ClientSessionImpl.createMessage(byte type,
boolean durable) |
ClientMessage |
ClientSessionImpl.createMessage(byte type,
boolean durable,
long expiration,
long timestamp,
byte priority) |
ClientMessage |
ClientConsumerImpl.receive() |
ClientMessage |
ClientConsumerImpl.receive(long timeout) |
ClientMessage |
ClientConsumerImpl.receiveImmediate() |
Modifier and Type | Method and Description |
---|---|
void |
ClientConsumerImpl.acknowledge(ClientMessage message) |
void |
ClientConsumerInternal.acknowledge(ClientMessage message) |
void |
ClientConsumerImpl.individualAcknowledge(ClientMessage message) |
void |
ClientConsumerInternal.individualAcknowledge(ClientMessage message) |
Modifier and Type | Field and Description |
---|---|
protected ClientMessage |
ActiveMQMessage.message |
Modifier and Type | Method and Description |
---|---|
ClientMessage |
ActiveMQMessage.getCoreMessage() |
Modifier and Type | Method and Description |
---|---|
static ActiveMQMessage |
ActiveMQMessage.createMessage(ClientMessage message,
ClientSession session) |
static ActiveMQMessage |
ActiveMQMessage.createMessage(ClientMessage message,
ClientSession session,
ConnectionFactoryOptions options) |
void |
JMSMessageListenerWrapper.onMessage(ClientMessage message)
In this method we apply the JMS acknowledgement and redelivery semantics
as per JMS spec
|
Constructor and Description |
---|
ActiveMQBytesMessage(ClientMessage message,
ClientSession session)
Constructor on receipt at client side
|
ActiveMQMapMessage(ClientMessage message,
ClientSession session) |
ActiveMQMessage(ClientMessage message,
ClientSession session)
Constructor for when receiving a message from the server
|
ActiveMQObjectMessage(ClientMessage message,
ClientSession session,
ConnectionFactoryOptions options) |
ActiveMQStreamMessage(ClientMessage message,
ClientSession session) |
ActiveMQTextMessage(ClientMessage message,
ClientSession session) |
Modifier and Type | Method and Description |
---|---|
void |
ActiveMQMessageHandler.onMessage(ClientMessage message) |
Modifier and Type | Method and Description |
---|---|
static <T> T |
ActiveMQ.getEntity(ClientMessage message,
Class<T> type)
Extract an object using a built-in RESTEasy JAX-RS MessageBodyReader
|
static <T> T |
ActiveMQ.getEntity(ClientMessage message,
Class<T> type,
org.jboss.resteasy.spi.ResteasyProviderFactory factory)
Extract an object using a built-in RESTEasy JAX-RS MessageBodyReader
|
static <T> T |
ActiveMQ.getEntity(ClientMessage msg,
Class<T> type,
Type genericType,
org.jboss.resteasy.spi.ResteasyProviderFactory factory) |
static <T> T |
ActiveMQ.getEntity(ClientMessage message,
org.jboss.resteasy.util.GenericType<T> type,
org.jboss.resteasy.spi.ResteasyProviderFactory factory)
Extract an object using a built-in RESTEasy JAX-RS MessageBodyReader
|
static String |
ActiveMQ.getHttpHeader(ClientMessage message,
String name)
Get an HTTP header value from a JMS Message
|
static boolean |
ActiveMQ.isHttpMessage(ClientMessage msg)
Was this ActiveMQ Artemis message generated from a REST call?
|
static void |
ActiveMQ.setEntity(ClientMessage message,
Serializable object)
Sets the message body to a serialized
byte array of the object.
|
static void |
ActiveMQ.setEntity(ClientMessage message,
Serializable object,
String contentType)
Sets a message property to be the Content-Type passed in.
|
static void |
ActiveMQ.setHttpHeader(ClientMessage message,
String name,
String value) |
Modifier and Type | Field and Description |
---|---|
protected ClientMessage |
ConsumedMessage.message |
Modifier and Type | Method and Description |
---|---|
protected ClientMessage |
PostMessage.createActiveMQMessage(javax.ws.rs.core.HttpHeaders headers,
byte[] body,
boolean durable,
Long ttl,
Long expiration,
Integer priority,
ClientSession session) |
ClientMessage |
Acknowledgement.getMessage() |
protected ClientMessage |
AcknowledgedQueueConsumer.receive(long timeoutSecs) |
protected ClientMessage |
QueueConsumer.receive(long timeoutSecs) |
protected ClientMessage |
AcknowledgedQueueConsumer.receiveFromConsumer(long timeoutSecs) |
protected ClientMessage |
QueueConsumer.receiveFromConsumer(long timeoutSecs) |
Modifier and Type | Method and Description |
---|---|
static ConsumedMessage |
ConsumedMessage.createConsumedMessage(ClientMessage message,
ConnectionFactoryOptions options) |
Constructor and Description |
---|
Acknowledgement(String ackToken,
ClientMessage message) |
ConsumedHttpMessage(ClientMessage message) |
ConsumedMessage(ClientMessage message) |
ConsumedObjectMessage(ClientMessage message,
ConnectionFactoryOptions options) |
Modifier and Type | Method and Description |
---|---|
protected String |
UriStrategy.createUri(ClientMessage message) |
protected String |
UriTemplateStrategy.createUri(ClientMessage message) |
void |
PushConsumerMessageHandler.onMessage(ClientMessage clientMessage) |
boolean |
UriStrategy.push(ClientMessage message) |
boolean |
ActiveMQPushStrategy.push(ClientMessage message) |
boolean |
PushStrategy.push(ClientMessage message)
Return false if unable to connect.
|
Modifier and Type | Method and Description |
---|---|
static void |
HttpMessageHelper.buildMessage(ClientMessage message,
org.jboss.resteasy.client.ClientRequest request,
String contentType,
ConnectionFactoryOptions jmsOptions) |
static void |
HttpMessageHelper.writeHttpMessage(javax.ws.rs.core.HttpHeaders headers,
byte[] body,
ClientMessage message) |
Copyright © 2016 The Apache Software Foundation. All rights reserved.