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.jms.client |
Modifier and Type | Interface and Description |
---|---|
interface |
QueueReceiver
A client uses a
QueueReceiver object to receive messages that
have been delivered to a queue. |
interface |
TopicSubscriber
A client uses a
TopicSubscriber object to receive messages that
have been published to a topic. |
Modifier and Type | Method and Description |
---|---|
MessageConsumer |
Session.createConsumer(Destination destination)
Creates a
MessageConsumer for the specified destination. |
MessageConsumer |
Session.createConsumer(Destination destination,
String messageSelector)
Creates a
MessageConsumer for the specified destination,
using a message selector. |
MessageConsumer |
Session.createConsumer(Destination destination,
String messageSelector,
boolean noLocal)
Creates a
MessageConsumer for the specified destination, specifying a
message selector and the noLocal parameter. |
MessageConsumer |
Session.createDurableConsumer(Topic topic,
String name)
Creates an unshared durable subscription on the specified topic (if one
does not already exist) and creates a consumer on that durable
subscription.
|
MessageConsumer |
Session.createDurableConsumer(Topic topic,
String name,
String messageSelector,
boolean noLocal)
Creates an unshared durable subscription on the specified topic (if one
does not already exist), specifying a message selector and the
noLocal parameter, and creates a consumer on that durable
subscription. |
MessageConsumer |
Session.createSharedConsumer(Topic topic,
String sharedSubscriptionName)
Creates a shared non-durable subscription with the specified name on the
specified topic (if one does not already exist) and creates a consumer on
that subscription.
|
MessageConsumer |
Session.createSharedConsumer(Topic topic,
String sharedSubscriptionName,
String messageSelector)
Creates a shared non-durable subscription with the specified name on the
specified topic (if one does not already exist) specifying a message selector,
and creates a consumer on that subscription.
|
MessageConsumer |
Session.createSharedDurableConsumer(Topic topic,
String name)
Creates a shared durable subscription on the specified topic (if one does
not already exist), specifying a message selector and the
noLocal
parameter, and creates a consumer on that durable subscription. |
MessageConsumer |
Session.createSharedDurableConsumer(Topic topic,
String name,
String messageSelector)
Creates a shared durable subscription on the specified topic (if one
does not already exist), specifying a message selector,
and creates a consumer on that durable subscription.
|
Modifier and Type | Class and Description |
---|---|
class |
ActiveMQMessageConsumer
ActiveMQ Artemis implementation of a JMS MessageConsumer.
|
Modifier and Type | Method and Description |
---|---|
MessageConsumer |
ActiveMQSession.createConsumer(Destination destination) |
MessageConsumer |
ActiveMQSession.createConsumer(Destination destination,
String messageSelector) |
MessageConsumer |
ActiveMQSession.createConsumer(Destination destination,
String messageSelector,
boolean noLocal) |
MessageConsumer |
ActiveMQSession.createDurableConsumer(Topic topic,
String name) |
MessageConsumer |
ActiveMQSession.createDurableConsumer(Topic topic,
String name,
String messageSelector,
boolean noLocal) |
MessageConsumer |
ActiveMQSession.createSharedConsumer(Topic topic,
String sharedSubscriptionName) |
MessageConsumer |
ActiveMQSession.createSharedConsumer(Topic topic,
String name,
String messageSelector)
Note: Needs to throw an exception if a subscriptionName is already in use by another topic, or if the messageSelector is different
validate multiple subscriptions on the same session.
|
MessageConsumer |
ActiveMQSession.createSharedDurableConsumer(Topic topic,
String name) |
MessageConsumer |
ActiveMQSession.createSharedDurableConsumer(Topic topic,
String name,
String messageSelector) |
Copyright © 2018 JBoss by Red Hat. All rights reserved.