Package | Description |
---|---|
javax.jms |
The Jakarta Messaging API provides a common way for Java programs to create, send, receive and read an enterprise messaging system's messages.
|
org.apache.activemq.artemis.cli.commands.messages | |
org.apache.activemq.artemis.jms.bridge | |
org.apache.activemq.artemis.jms.bridge.impl | |
org.apache.activemq.artemis.jms.client | |
org.apache.activemq.artemis.jms.client.compatible1X |
Modifier and Type | Interface and Description |
---|---|
interface |
Queue
A
Queue object encapsulates a provider-specific queue name. |
interface |
TemporaryQueue
A
TemporaryQueue object is a unique Queue object created for the duration of a Connection . |
interface |
TemporaryTopic
A
TemporaryTopic object is a unique Topic object created for the duration of a Connection . |
interface |
Topic
A
Topic object encapsulates a provider-specific topic name. |
Modifier and Type | Method and Description |
---|---|
Destination |
MessageProducer.getDestination()
Gets the destination associated with this
MessageProducer . |
Destination |
Message.getJMSDestination()
Gets the
Destination object for this message. |
Destination |
JMSProducer.getJMSReplyTo()
Returns the
JMSReplyTo header value that has been set on this JMSProducer . |
Destination |
Message.getJMSReplyTo()
Gets the
Destination object to which a reply to this message should be sent. |
Modifier and Type | Method and Description |
---|---|
ConnectionConsumer |
Connection.createConnectionConsumer(Destination destination,
String messageSelector,
ServerSessionPool sessionPool,
int maxMessages)
Creates a connection consumer for this connection (optional operation) on the specific destination.
|
JMSConsumer |
JMSContext.createConsumer(Destination destination)
Creates a
JMSConsumer for the specified destination. |
MessageConsumer |
Session.createConsumer(Destination destination)
Creates a
MessageConsumer for the specified destination. |
JMSConsumer |
JMSContext.createConsumer(Destination destination,
String messageSelector)
Creates a
JMSConsumer for the specified destination, using a message selector. |
MessageConsumer |
Session.createConsumer(Destination destination,
String messageSelector)
Creates a
MessageConsumer for the specified destination, using a message selector. |
JMSConsumer |
JMSContext.createConsumer(Destination destination,
String messageSelector,
boolean noLocal)
Creates a
JMSConsumer for the specified destination, specifying a message selector and the noLocal
parameter. |
MessageConsumer |
Session.createConsumer(Destination destination,
String messageSelector,
boolean noLocal)
Creates a
MessageConsumer for the specified destination, specifying a message selector and the
noLocal parameter. |
MessageProducer |
Session.createProducer(Destination destination)
Creates a
MessageProducer to send messages to the specified destination. |
JMSProducer |
JMSProducer.send(Destination destination,
byte[] body)
Send a
BytesMessage with the specified body to the specified destination, using any send options, message
properties and message headers that have been defined on this JMSProducer . |
JMSProducer |
JMSProducer.send(Destination destination,
Map<String,Object> body)
Send a
MapMessage with the specified body to the specified destination, using any send options, message
properties and message headers that have been defined on this JMSProducer . |
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.
|
JMSProducer |
JMSProducer.send(Destination destination,
Serializable body)
Send an
ObjectMessage with the specified body to the specified destination, using any send options, message
properties and message headers that have been defined on this JMSProducer . |
JMSProducer |
JMSProducer.send(Destination destination,
String body)
Send a
TextMessage with the specified body to the specified destination, using any send options, message
properties and message headers that have been defined on this JMSProducer . |
void |
Message.setJMSDestination(Destination destination)
Sets the
Destination object for this message. |
JMSProducer |
JMSProducer.setJMSReplyTo(Destination replyTo)
Specifies that messages sent using this
JMSProducer will have their JMSReplyTo header value set to
the specified Destination object. |
void |
Message.setJMSReplyTo(Destination replyTo)
Sets the
Destination object to which a reply to this message should be sent. |
Modifier and Type | Method and Description |
---|---|
protected Destination |
DestAbstract.lookupDestination(Session session) |
Destination |
Producer.lookupDestination(Session session,
boolean isFQQN) |
Constructor and Description |
---|
ConsumerThread(Session session,
Destination destination,
int threadNr) |
ProducerThread(Session session,
Destination destination,
int threadNr) |
Modifier and Type | Method and Description |
---|---|
Destination |
DestinationFactory.createDestination() |
Modifier and Type | Method and Description |
---|---|
Destination |
JNDIDestinationFactory.createDestination() |
Modifier and Type | Class and Description |
---|---|
class |
ActiveMQDestination
ActiveMQ Artemis implementation of a JMS Destination.
|
class |
ActiveMQQueue
ActiveMQ Artemis implementation of a JMS Queue.
|
class |
ActiveMQTemporaryQueue
ActiveMQ Artemis implementation of a JMS TemporaryQueue.
|
class |
ActiveMQTemporaryTopic |
class |
ActiveMQTopic
ActiveMQ Artemis implementation of a JMS Topic.
|
Modifier and Type | Field and Description |
---|---|
protected Destination |
ActiveMQMessage.replyTo |
Modifier and Type | Method and Description |
---|---|
static Destination |
ActiveMQDestination.fromPrefixed1XName(String addr,
String name) |
Destination |
ActiveMQMessageProducer.getDestination() |
Destination |
ActiveMQMessage.getJMSDestination() |
Destination |
ActiveMQJMSProducer.getJMSReplyTo() |
Destination |
ActiveMQMessage.getJMSReplyTo() |
Modifier and Type | Method and Description |
---|---|
ConnectionConsumer |
ActiveMQConnection.createConnectionConsumer(Destination destination,
String messageSelector,
ServerSessionPool sessionPool,
int maxMessages) |
JMSConsumer |
ActiveMQJMSContext.createConsumer(Destination destination) |
MessageConsumer |
ActiveMQSession.createConsumer(Destination destination) |
JMSConsumer |
ActiveMQJMSContext.createConsumer(Destination destination,
String messageSelector) |
MessageConsumer |
ActiveMQSession.createConsumer(Destination destination,
String messageSelector) |
JMSConsumer |
ActiveMQJMSContext.createConsumer(Destination destination,
String messageSelector,
boolean noLocal) |
MessageConsumer |
ActiveMQSession.createConsumer(Destination destination,
String messageSelector,
boolean noLocal) |
MessageProducer |
ActiveMQSession.createProducer(Destination destination) |
static String |
ActiveMQMessage.prefixOf(Destination dest) |
JMSProducer |
ActiveMQJMSProducer.send(Destination destination,
byte[] body) |
JMSProducer |
ActiveMQJMSProducer.send(Destination destination,
Map<String,Object> body) |
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) |
JMSProducer |
ActiveMQJMSProducer.send(Destination destination,
Serializable body) |
JMSProducer |
ActiveMQJMSProducer.send(Destination destination,
String body) |
void |
ActiveMQMessage.setJMSDestination(Destination destination) |
JMSProducer |
ActiveMQJMSProducer.setJMSReplyTo(Destination replyTo) |
void |
ActiveMQMessage.setJMSReplyTo(Destination dest) |
Modifier and Type | Method and Description |
---|---|
Destination |
ActiveMQBytesCompatibleMessage.getJMSReplyTo() |
Destination |
ActiveMQCompatibleMessage.getJMSReplyTo() |
Destination |
ActiveMQMapCompatibleMessage.getJMSReplyTo() |
Destination |
ActiveMQObjectCompatibleMessage.getJMSReplyTo() |
Destination |
ActiveMQStreamCompatibleMessage.getJMSReplyTo() |
Destination |
ActiveMQTextCompatibleMessage.getJMSReplyTo() |
Modifier and Type | Method and Description |
---|---|
void |
ActiveMQBytesCompatibleMessage.setJMSReplyTo(Destination dest) |
void |
ActiveMQCompatibleMessage.setJMSReplyTo(Destination dest) |
void |
ActiveMQMapCompatibleMessage.setJMSReplyTo(Destination dest) |
void |
ActiveMQObjectCompatibleMessage.setJMSReplyTo(Destination dest) |
void |
ActiveMQStreamCompatibleMessage.setJMSReplyTo(Destination dest) |
void |
ActiveMQTextCompatibleMessage.setJMSReplyTo(Destination dest) |
Copyright © 2019 JBoss by Red Hat. All rights reserved.