Package | Description |
---|---|
org.ow2.joram.jakarta.jms |
The
org.ow2.joram.jakarta.jms package holds the classes implementing the interfaces defined by the JMS 3.0 Jakarta specification. |
org.ow2.joram.jakarta.jms.admin |
The
org.ow2.joram.jakarta.jms.admin package holds the interfaces and implementation classes for administering a JORAM platform and creating the JMS administered objects. |
Modifier and Type | Class and Description |
---|---|
class |
Queue
Implements the
jakarta.jms.Queue interface. |
class |
TemporaryQueue
Implements the
jakarta.jms.TemporaryQueue interface. |
class |
TemporaryTopic
Implements the
jakarta.jms.TemporaryTopic interface. |
class |
Topic
Implements the
jakarta.jms.Topic interface. |
Modifier and Type | Field and Description |
---|---|
protected Destination |
MessageProducer.dest
The destination the producer sends messages to.
|
protected Destination |
MessageConsumer.dest
The destination the consumer gets its messages from.
|
Modifier and Type | Method and Description |
---|---|
Destination |
MessageConsumer.getDest() |
static Destination |
Destination.newInstance(String id,
String name,
byte type) |
Modifier and Type | Method and Description |
---|---|
(package private) void |
Session.acknowledge(Destination dest,
String msgId)
Method acknowledging one received message.
|
protected void |
Destination.doCreate(int serverId,
String name,
String className,
Properties props,
Destination dest,
byte type)
Administration method creating or retrieving a destination with a given name on a
given server, and returning its identifier.
|
private void |
MessageProducer.doSend(Destination dest,
jakarta.jms.Message message,
int deliveryMode,
int priority,
long timeToLive)
Actually sends a message to a given destination.
|
private void |
MessageProducer.doSend(Destination dest,
jakarta.jms.Message message,
int deliveryMode,
int priority,
long timeToLive,
jakarta.jms.CompletionListener completionListener)
Actually sends a message to a given destination.
|
static String |
Destination.getJMXBeanName(String base,
Destination dest) |
private void |
Session.prepareSend(Destination dest,
Message msg)
Method called by message producers when producing a message for
preparing the session to later commit it.
|
(package private) void |
Session.send(Destination dest,
jakarta.jms.Message msg,
int deliveryMode,
int priority,
long timeToLive,
boolean timestampDisabled,
long deliveryDelay,
jakarta.jms.CompletionListener completionListener,
MessageProducer messageProducer)
Called by MessageProducer.
|
Constructor and Description |
---|
MessageConsumer(Session sess,
Destination dest,
String selector)
Constructs a consumer.
|
MessageConsumer(Session sess,
Destination dest,
String selector,
String subName,
boolean noLocal,
boolean shared,
boolean durableSubscriber)
Constructs a consumer.
|
MessageProducer(Session sess,
Destination dest)
Constructs a producer.
|
QueueReceiver(QueueSession sess,
Destination queue,
String selector)
Constructs a receiver.
|
QueueSender(QueueSession sess,
Destination queue)
Constructs a sender.
|
TopicPublisher(TopicSession sess,
Destination topic)
Constructs a publisher.
|
TopicSubscriber(Session sess,
Destination topic,
String name,
String selector,
boolean noLocal,
boolean durableSubscriber)
Constructs a subscriber.
|
Modifier and Type | Class and Description |
---|---|
class |
ClusterDestination
A base class for clustered destinations.
|
class |
ClusterQueue
Clustered queue.
|
class |
ClusterTopic
Clustered topic.
|
Modifier and Type | Method and Description |
---|---|
Destination |
JoramAdmin.createQueue(int serverId,
String name)
Creates or retrieves a queue destination on the underlying JORAM server,
(re)binds the corresponding
Queue instance. |
Destination |
AdminWrapper.createQueue(int serverId,
String name)
Creates or retrieves a queue destination on a given JORAM server.
|
Destination |
AdminItf.createQueue(int serverId,
String name)
Creates or retrieves a queue destination on a given JORAM server.
|
Destination |
JoramAdmin.createQueue(int serverId,
String name,
String className,
Properties prop) |
Destination |
AdminWrapper.createQueue(int serverId,
String name,
String className,
Properties prop)
Creates or retrieves a queue destination on a given JORAM server.
|
static Destination |
AdminModule.createQueue(int serverId,
String name,
String className,
Properties prop)
Creates or retrieves a queue destination on a given JORAM server.
|
Destination |
AdminItf.createQueue(int serverId,
String name,
String className,
Properties prop)
Creates or retrieves a queue destination on a given JORAM server.
|
Destination |
JoramAdmin.createQueue(String name)
Creates or retrieves a queue destination on the underlying JORAM server,
(re)binds the corresponding
Queue instance. |
Destination |
AdminWrapper.createQueue(String name)
Creates or retrieves a queue destination on a given JORAM server.
|
Destination |
AdminItf.createQueue(String name)
Creates or retrieves a queue destination on a given JORAM server.
|
Destination |
JoramAdmin.createTopic(int serverId,
String name)
Creates or retrieves a topic destination on the underlying JORAM server,
(re)binds the corresponding
Topic instance. |
Destination |
AdminWrapper.createTopic(int serverId,
String name)
Creates or retrieves a topic destination on a given JORAM server.
|
Destination |
AdminItf.createTopic(int serverId,
String name)
Creates or retrieves a topic destination on a given JORAM server.
|
Destination |
JoramAdmin.createTopic(int serverId,
String name,
String className,
Properties prop) |
Destination |
AdminWrapper.createTopic(int serverId,
String name,
String className,
Properties prop)
Creates or retrieves a topic destination on a given JORAM server.
|
static Destination |
AdminModule.createTopic(int serverId,
String name,
String className,
Properties prop)
Creates or retrieves a topic destination on a given JORAM server.
|
Destination |
AdminItf.createTopic(int serverId,
String name,
String className,
Properties prop)
Creates or retrieves a topic destination on a given JORAM server.
|
Destination |
JoramAdmin.createTopic(String name)
Creates or retrieves a topic destination on the underlying JORAM server,
(re)binds the corresponding
Topic instance. |
Destination |
AdminWrapper.createTopic(String name)
Creates or retrieves a topic destination on the underlying JORAM server.
|
Destination |
AdminItf.createTopic(String name)
Creates or retrieves a topic destination on the underlying JORAM server.
|
protected Destination |
ClusterDestination.getDestination()
return the appropriate destination of cluster
|
Destination[] |
JoramAdmin.getDestinations()
This method creates and registers MBeans for all the destinations on
the local server.
|
Destination[] |
AdminWrapper.getDestinations()
Returns the list of all destinations that exist on the local server.
|
static Destination[] |
AdminModule.getDestinations()
Returns the list of all destinations that exist on the local server,
or null if none exist.
|
Destination[] |
AdminItf.getDestinations()
Returns the list of all destinations that exist on the local server.
|
Destination[] |
JoramAdmin.getDestinations(int serverId)
This method creates and registers MBeans for all the destinations of
the selected server.
|
Destination[] |
AdminWrapper.getDestinations(int serverId)
Returns the list of all destinations that exist on a given server.
|
static Destination[] |
AdminModule.getDestinations(int serverId)
Returns the list of all destinations that exist on a given server,
or null if none exist.
|
Destination[] |
AdminItf.getDestinations(int serverId)
Returns the list of all destinations that exist on a given server.
|
private Destination |
JoramAdmin.wrapDestination(Destination destination) |
private Destination[] |
JoramAdmin.wrapDestinations(Destination[] destinations) |
Modifier and Type | Method and Description |
---|---|
void |
ClusterDestination.addDestination(Destination dest)
Adds a destination to the cluster.
|
void |
ClusterDestination.addDestination(String location,
Destination dest)
Adds a destination to the cluster with the specified
location key. |
(package private) void |
JoramSaxWrapper.configureDestination(Destination dest) |
(package private) void |
JoramSaxWrapper.registerDestination(Destination dest) |
(package private) void |
JoramSaxWrapper.setDestinationDMQ(String name,
Destination dest,
String dmq) |
private Destination |
JoramAdmin.wrapDestination(Destination destination) |
private Destination[] |
JoramAdmin.wrapDestinations(Destination[] destinations) |
Copyright © 2022 ScalAgent D.T.. All rights reserved.