Package | Description |
---|---|
org.apache.activemq.artemis.api.core.client |
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(org.apache.activemq.artemis.api.core.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(org.apache.activemq.artemis.api.core.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(org.apache.activemq.artemis.api.core.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(org.apache.activemq.artemis.api.core.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(org.apache.activemq.artemis.api.core.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(org.apache.activemq.artemis.api.core.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(org.apache.activemq.artemis.api.core.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(org.apache.activemq.artemis.api.core.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(org.apache.activemq.artemis.api.core.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(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.
|
Copyright © 2017 The Apache Software Foundation. All Rights Reserved.