Package | Description |
---|---|
javax.jms |
The Java Message Service (JMS) API provides a common way for Java programs to create, send, receive and read an enterprise messaging system's messages.
|
org.apache.activemq.artemis.api.jms.management | |
org.apache.activemq.artemis.cli.commands.messages | |
org.apache.activemq.artemis.cli.factory.serialize | |
org.apache.activemq.artemis.jms.client | |
org.apache.activemq.artemis.jms.client.compatible1X |
Modifier and Type | Interface and Description |
---|---|
interface |
BytesMessage
A
BytesMessage object is used to send a message containing a
stream of uninterpreted bytes. |
interface |
MapMessage
A
MapMessage object is used to send a set of name-value pairs. |
interface |
ObjectMessage
An
ObjectMessage object is used to send a message that contains
a serializable object in the Java programming language ("Java object"). |
interface |
StreamMessage
A
StreamMessage object is used to send a stream of primitive
types in the Java programming language. |
interface |
TextMessage
A
TextMessage object is used to send a message containing a
java.lang.String . |
Modifier and Type | Method and Description |
---|---|
Message |
Session.createMessage()
Creates a
Message object. |
Message |
JMSContext.createMessage()
Creates a
Message object. |
Message |
MessageConsumer.receive()
Receives the next message produced for this message consumer.
|
Message |
JMSConsumer.receive()
Receives the next message produced for this
JMSConsumer . |
Message |
MessageConsumer.receive(long timeout)
Receives the next message that arrives within the specified
timeout interval.
|
Message |
JMSConsumer.receive(long timeout)
Receives the next message that arrives within the specified
timeout interval.
|
Message |
MessageConsumer.receiveNoWait()
Receives the next message if one is immediately available.
|
Message |
JMSConsumer.receiveNoWait()
Receives the next message if one is immediately available.
|
Message |
TopicRequestor.request(Message message)
Sends a request and waits for a reply.
|
Message |
QueueRequestor.request(Message message)
Sends a request and waits for a reply.
|
Modifier and Type | Method and Description |
---|---|
void |
CompletionListener.onCompletion(Message message)
Notifies the application that the message has been successfully sent
|
void |
CompletionListener.onException(Message message,
Exception exception)
Notifies user that the specified exception was thrown while attempting to
send the specified message.
|
void |
MessageListener.onMessage(Message message)
Passes a message to the listener.
|
void |
TopicPublisher.publish(Message message)
Publishes a message to the topic.
|
void |
TopicPublisher.publish(Message message,
int deliveryMode,
int priority,
long timeToLive)
Publishes a message to the topic, specifying delivery mode,
priority, and time to live.
|
void |
TopicPublisher.publish(Topic topic,
Message message)
Publishes a message to a topic for an unidentified message producer.
|
void |
TopicPublisher.publish(Topic topic,
Message message,
int deliveryMode,
int priority,
long timeToLive)
Publishes a message to a topic for an unidentified message
producer, specifying delivery mode, priority and time to live.
|
Message |
TopicRequestor.request(Message message)
Sends a request and waits for a reply.
|
Message |
QueueRequestor.request(Message message)
Sends a request and waits for a reply.
|
JMSProducer |
JMSProducer.send(Destination destination,
Message message)
Sends a message to the specified destination, using any send options,
message properties and message headers that have been defined on this
JMSProducer . |
void |
MessageProducer.send(Destination destination,
Message message)
Sends a message to a destination for an unidentified message producer
using the
MessageProducer 's default delivery mode, priority,
and time to live. |
void |
MessageProducer.send(Destination destination,
Message message,
CompletionListener completionListener)
Sends a message to a destination for an unidentified message producer,
using the
MessageProducer 's default delivery mode, priority,
and time to live, performing part of the work involved in sending the
message in a separate thread and notifying the specified
CompletionListener when the operation has completed. |
void |
MessageProducer.send(Destination destination,
Message message,
int deliveryMode,
int priority,
long timeToLive)
Sends a message to a destination for an unidentified message producer,
specifying delivery mode, priority and time to live.
|
void |
MessageProducer.send(Destination destination,
Message message,
int deliveryMode,
int priority,
long timeToLive,
CompletionListener completionListener)
Sends a message to a destination for an unidentified message producer,
specifying delivery mode, priority and time to live, performing part of
the work involved in sending the message in a separate thread and
notifying the specified CompletionListener when the operation
has completed.
|
void |
QueueSender.send(Message message)
Sends a message to the queue.
|
void |
MessageProducer.send(Message message)
Sends a message using the
MessageProducer 's default delivery
mode, priority, and time to live. |
void |
MessageProducer.send(Message message,
CompletionListener completionListener)
Sends a message using the
MessageProducer 's default delivery
mode, priority, and time to live, performing part of the work involved in
sending the message in a separate thread and notifying the specified
CompletionListener when the operation has completed. |
void |
QueueSender.send(Message message,
int deliveryMode,
int priority,
long timeToLive)
Sends a message to the queue, specifying delivery mode, priority, and
time to live.
|
void |
MessageProducer.send(Message message,
int deliveryMode,
int priority,
long timeToLive)
Sends a message, specifying delivery mode, priority, and time to live.
|
void |
MessageProducer.send(Message message,
int deliveryMode,
int priority,
long timeToLive,
CompletionListener completionListener)
Sends a message, specifying delivery mode, priority and time to live,
performing part of the work involved in sending the message in a separate
thread and notifying the specified CompletionListener when the
operation has completed.
|
void |
QueueSender.send(Queue queue,
Message message)
Sends a message to a queue for an unidentified message producer.
|
void |
QueueSender.send(Queue queue,
Message message,
int deliveryMode,
int priority,
long timeToLive)
Sends a message to a queue for an unidentified message producer,
specifying delivery mode, priority and time to live.
|
Modifier and Type | Method and Description |
---|---|
static Object |
JMSManagementHelper.getResult(Message message)
Returns the result of an operation invocation or an attribute value.
|
static Object |
JMSManagementHelper.getResult(Message message,
Class desiredType)
Returns the result of an operation invocation or an attribute value.
|
static Object[] |
JMSManagementHelper.getResults(Message message)
Returns the result of an operation invocation or an attribute value.
|
static boolean |
JMSManagementHelper.hasOperationSucceeded(Message message)
Returns whether the invocation of the management operation on the server resource succeeded.
|
static boolean |
JMSManagementHelper.isAttributesResult(Message message)
Returns whether the JMS message corresponds to the result of a management attribute value.
|
static boolean |
JMSManagementHelper.isOperationResult(Message message)
Returns whether the JMS message corresponds to the result of a management operation invocation.
|
static void |
JMSManagementHelper.putAttribute(Message message,
String resourceName,
String attribute)
Stores a resource attribute in a JMS message to retrieve the value from the server resource.
|
static void |
JMSManagementHelper.putOperationInvocation(Message message,
String resourceName,
String operationName)
Stores an operation invocation in a JMS message to invoke the corresponding operation the value from the server resource.
|
static void |
JMSManagementHelper.putOperationInvocation(Message message,
String resourceName,
String operationName,
Object... parameters)
Stores an operation invocation in a JMS message to invoke the corresponding operation the value from the server resource.
|
Modifier and Type | Method and Description |
---|---|
protected Message |
ProducerThread.createMessage(int i,
String threadName) |
Modifier and Type | Method and Description |
---|---|
Message |
MessageSerializer.read() |
Message |
XMLMessageSerializer.read() |
Modifier and Type | Method and Description |
---|---|
void |
MessageSerializer.write(Message message) |
void |
XMLMessageSerializer.write(Message message) |
Modifier and Type | Class and Description |
---|---|
class |
ActiveMQBytesMessage
ActiveMQ Artemis implementation of a JMS
BytesMessage . |
class |
ActiveMQMapMessage
ActiveMQ Artemis implementation of a JMS MapMessage.
|
class |
ActiveMQMessage
ActiveMQ Artemis implementation of a JMS Message.
|
class |
ActiveMQObjectMessage
ActiveMQ Artemis implementation of a JMS ObjectMessage.
|
class |
ActiveMQStreamMessage
ActiveMQ Artemis implementation of a JMS StreamMessage.
|
class |
ActiveMQTextMessage
ActiveMQ Artemis implementation of a JMS TextMessage.
|
Modifier and Type | Method and Description |
---|---|
Message |
ActiveMQJMSContext.createMessage() |
Message |
ActiveMQSession.createMessage() |
Message |
ActiveMQJMSConsumer.receive() |
Message |
ActiveMQMessageConsumer.receive() |
Message |
ActiveMQJMSConsumer.receive(long timeout) |
Message |
ActiveMQMessageConsumer.receive(long timeout) |
Message |
ActiveMQJMSConsumer.receiveNoWait() |
Message |
ActiveMQMessageConsumer.receiveNoWait() |
Modifier and Type | Method and Description |
---|---|
void |
ActiveMQMessageProducer.publish(Message message) |
void |
ActiveMQMessageProducer.publish(Message message,
int deliveryMode,
int priority,
long timeToLive) |
void |
ActiveMQMessageProducer.publish(Topic topic,
Message message) |
void |
ActiveMQMessageProducer.publish(Topic topic,
Message message,
int deliveryMode,
int priority,
long timeToLive) |
JMSProducer |
ActiveMQJMSProducer.send(Destination destination,
Message message) |
void |
ActiveMQMessageProducer.send(Destination destination,
Message message) |
void |
ActiveMQMessageProducer.send(Destination destination,
Message message,
CompletionListener completionListener) |
void |
ActiveMQMessageProducer.send(Destination destination,
Message message,
int deliveryMode,
int priority,
long timeToLive) |
void |
ActiveMQMessageProducer.send(Destination destination,
Message message,
int deliveryMode,
int priority,
long timeToLive,
CompletionListener completionListener) |
void |
ActiveMQMessageProducer.send(Message message) |
void |
ActiveMQMessageProducer.send(Message message,
CompletionListener completionListener) |
void |
ActiveMQMessageProducer.send(Message message,
int deliveryMode,
int priority,
long timeToLive) |
void |
ActiveMQMessageProducer.send(Message message,
int deliveryMode,
int priority,
long timeToLive,
CompletionListener completionListener) |
void |
ActiveMQMessageProducer.send(Queue queue,
Message message) |
void |
ActiveMQMessageProducer.send(Queue queue,
Message message,
int deliveryMode,
int priority,
long timeToLive) |
Constructor and Description |
---|
ActiveMQMessage(Message foreign,
byte type,
ClientSession session) |
ActiveMQMessage(Message foreign,
ClientSession session) |
Modifier and Type | Class and Description |
---|---|
class |
ActiveMQBytesCompatibleMessage |
class |
ActiveMQCompatibleMessage |
class |
ActiveMQMapCompatibleMessage |
class |
ActiveMQObjectCompatibleMessage |
class |
ActiveMQStreamCompatibleMessage |
class |
ActiveMQTextCompatibleMessage |
Constructor and Description |
---|
ActiveMQCompatibleMessage(Message foreign,
byte type,
ClientSession session) |
ActiveMQCompatibleMessage(Message foreign,
ClientSession session) |
Copyright © 2019 JBoss by Red Hat. All rights reserved.