Package | Description |
---|---|
javax.jms |
JMS 1.1 API.
|
org.hornetq.api.jms.management |
Management API for HornetQ JMS resources.
|
org.hornetq.jms.client |
Implementation of the JMS API.
|
Modifier and Type | Class and Description |
---|---|
class |
IllegalStateException
This exception is thrown when a method is
invoked at an illegal or inappropriate time or if the provider is
not in an appropriate state for the requested operation.
|
class |
InvalidClientIDException
This exception must be thrown when a
client attempts to set a connection's client ID to a value that
is rejected by a provider.
|
class |
InvalidDestinationException
This exception must be thrown when a
destination either is not understood by a provider or is no
longer valid.
|
class |
InvalidSelectorException
This exception must be thrown when a
JMS client attempts to give a provider a message selector with
invalid syntax.
|
class |
JMSSecurityException
This exception must be thrown when a provider rejects a user
name/password submitted by a client.
|
class |
MessageEOFException
This exception must be thrown when an unexpected
end of stream has been reached when a
StreamMessage or
BytesMessage is being read. |
class |
MessageFormatException
This exception must be thrown when a JMS client
attempts to use a data type not supported by a message or attempts to
read data in a message as the wrong type.
|
class |
MessageNotReadableException
This exception must be thrown when a JMS client attempts to read a
write-only message.
|
class |
MessageNotWriteableException
This exception must be thrown when a JMS client attempts to write to a
read-only message.
|
class |
ResourceAllocationException
This exception is thrown when a provider is unable to allocate the
resources required by a method.
|
class |
TransactionInProgressException
This exception is thrown when an
operation is invalid because a transaction is in progress.
|
class |
TransactionRolledBackException
This exception must be thrown when a
call to
Session.commit results in a rollback of the current
transaction. |
Modifier and Type | Method and Description |
---|---|
void |
ExceptionListener.onException(JMSException exception)
Notifies user of a JMS exception.
|
Modifier and Type | Method and Description |
---|---|
void |
Message.acknowledge()
Acknowledges all consumed messages of the session of this consumed
message.
|
void |
Message.clearBody()
Clears out the message body.
|
void |
Message.clearProperties()
Clears a message's properties.
|
void |
TopicRequestor.close() |
void |
Session.close()
Closes the session.
|
void |
QueueRequestor.close() |
void |
QueueBrowser.close()
Closes the
QueueBrowser . |
void |
MessageProducer.close()
Closes the message producer.
|
void |
MessageConsumer.close()
Closes the message consumer.
|
void |
ConnectionConsumer.close()
Closes the connection consumer.
|
void |
Connection.close()
Closes the connection.
|
void |
XASession.commit()
Throws a
TransactionInProgressException , since it should
not be called for an XASession object. |
void |
Session.commit()
Commits all messages done in this transaction and releases any locks
currently held.
|
QueueBrowser |
Session.createBrowser(Queue queue)
Creates a
QueueBrowser object to peek at the messages on
the specified queue. |
QueueBrowser |
QueueSession.createBrowser(Queue queue)
Creates a
QueueBrowser object to peek at the messages on
the specified queue. |
QueueBrowser |
Session.createBrowser(Queue queue,
String messageSelector)
Creates a
QueueBrowser object to peek at the messages on
the specified queue using a message selector. |
QueueBrowser |
QueueSession.createBrowser(Queue queue,
String messageSelector)
Creates a
QueueBrowser object to peek at the messages on
the specified queue using a message selector. |
BytesMessage |
Session.createBytesMessage()
Creates a
BytesMessage object. |
Connection |
ConnectionFactory.createConnection()
Creates a connection with the default user identity.
|
Connection |
ConnectionFactory.createConnection(String userName,
String password)
Creates a connection with the specified user identity.
|
ConnectionConsumer |
Connection.createConnectionConsumer(Destination destination,
String messageSelector,
ServerSessionPool sessionPool,
int maxMessages)
Creates a connection consumer for this connection (optional operation).
|
ConnectionConsumer |
QueueConnection.createConnectionConsumer(Queue queue,
String messageSelector,
ServerSessionPool sessionPool,
int maxMessages)
Creates a connection consumer for this connection (optional operation).
|
ConnectionConsumer |
TopicConnection.createConnectionConsumer(Topic topic,
String messageSelector,
ServerSessionPool sessionPool,
int maxMessages)
Creates a connection consumer for this connection (optional operation).
|
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
MessageConsumer for the specified destination, using a
message selector. |
ConnectionConsumer |
TopicConnection.createDurableConnectionConsumer(Topic topic,
String subscriptionName,
String messageSelector,
ServerSessionPool sessionPool,
int maxMessages)
Create a durable connection consumer for this connection (optional operation).
|
ConnectionConsumer |
Connection.createDurableConnectionConsumer(Topic topic,
String subscriptionName,
String messageSelector,
ServerSessionPool sessionPool,
int maxMessages)
Create a durable connection consumer for this connection (optional operation).
|
TopicSubscriber |
TopicSession.createDurableSubscriber(Topic topic,
String name)
Creates a durable subscriber to the specified topic.
|
TopicSubscriber |
Session.createDurableSubscriber(Topic topic,
String name)
Creates a durable subscriber to the specified topic.
|
TopicSubscriber |
TopicSession.createDurableSubscriber(Topic topic,
String name,
String messageSelector,
boolean noLocal)
Creates a durable subscriber to the specified topic, using a
message selector or specifying whether messages published by its
own connection should be delivered to it.
|
TopicSubscriber |
Session.createDurableSubscriber(Topic topic,
String name,
String messageSelector,
boolean noLocal)
Creates a durable subscriber to the specified topic, using a
message selector and specifying whether messages published by its
own connection should be delivered to it.
|
MapMessage |
Session.createMapMessage()
Creates a
MapMessage object. |
Message |
Session.createMessage()
Creates a
Message object. |
ObjectMessage |
Session.createObjectMessage()
Creates an
ObjectMessage object. |
ObjectMessage |
Session.createObjectMessage(Serializable object)
Creates an initialized
ObjectMessage object. |
MessageProducer |
Session.createProducer(Destination destination)
Creates a
MessageProducer to send messages to the specified
destination. |
TopicPublisher |
TopicSession.createPublisher(Topic topic)
Creates a publisher for the specified topic.
|
Queue |
Session.createQueue(String queueName)
Creates a queue identity given a
Queue name. |
Queue |
QueueSession.createQueue(String queueName)
Creates a queue identity given a
Queue name. |
QueueConnection |
QueueConnectionFactory.createQueueConnection()
Creates a queue connection with the default user identity.
|
QueueConnection |
QueueConnectionFactory.createQueueConnection(String userName,
String password)
Creates a queue connection with the specified user identity.
|
QueueSession |
XAQueueConnection.createQueueSession(boolean transacted,
int acknowledgeMode)
Creates an
XAQueueSession object. |
QueueSession |
QueueConnection.createQueueSession(boolean transacted,
int acknowledgeMode)
Creates a
QueueSession object. |
QueueReceiver |
QueueSession.createReceiver(Queue queue)
Creates a
QueueReceiver object to receive messages from the
specified queue. |
QueueReceiver |
QueueSession.createReceiver(Queue queue,
String messageSelector)
Creates a
QueueReceiver object to receive messages from the
specified queue using a message selector. |
QueueSender |
QueueSession.createSender(Queue queue)
Creates a
QueueSender object to send messages to the
specified queue. |
Session |
XAConnection.createSession(boolean transacted,
int acknowledgeMode)
Creates an
Session object. |
Session |
Connection.createSession(boolean transacted,
int acknowledgeMode)
Creates a
Session object. |
StreamMessage |
Session.createStreamMessage()
Creates a
StreamMessage object. |
TopicSubscriber |
TopicSession.createSubscriber(Topic topic)
Creates a nondurable subscriber to the specified topic.
|
TopicSubscriber |
TopicSession.createSubscriber(Topic topic,
String messageSelector,
boolean noLocal)
Creates a nondurable subscriber to the specified topic, using a
message selector or specifying whether messages published by its
own connection should be delivered to it.
|
TemporaryQueue |
Session.createTemporaryQueue()
Creates a
TemporaryQueue object. |
TemporaryQueue |
QueueSession.createTemporaryQueue()
Creates a
TemporaryQueue object. |
TemporaryTopic |
TopicSession.createTemporaryTopic()
Creates a
TemporaryTopic object. |
TemporaryTopic |
Session.createTemporaryTopic()
Creates a
TemporaryTopic object. |
TextMessage |
Session.createTextMessage()
Creates a
TextMessage object. |
TextMessage |
Session.createTextMessage(String text)
Creates an initialized
TextMessage object. |
Topic |
TopicSession.createTopic(String topicName)
Creates a topic identity given a
Topic name. |
Topic |
Session.createTopic(String topicName)
Creates a topic identity given a
Topic name. |
TopicConnection |
TopicConnectionFactory.createTopicConnection()
Creates a topic connection with the default user identity.
|
TopicConnection |
TopicConnectionFactory.createTopicConnection(String userName,
String password)
Creates a topic connection with the specified user identity.
|
TopicSession |
XATopicConnection.createTopicSession(boolean transacted,
int acknowledgeMode)
Creates an
XATopicSession object. |
TopicSession |
TopicConnection.createTopicSession(boolean transacted,
int acknowledgeMode)
Creates a
TopicSession object. |
XAConnection |
XAConnectionFactory.createXAConnection()
Creates an
XAConnection with the default user identity. |
XAConnection |
XAConnectionFactory.createXAConnection(String userName,
String password)
Creates an XA connection with the specified user identity.
|
XAQueueConnection |
XAQueueConnectionFactory.createXAQueueConnection()
Creates an XA queue connection with the default user identity.
|
XAQueueConnection |
XAQueueConnectionFactory.createXAQueueConnection(String userName,
String password)
Creates an XA queue connection with the specified user identity.
|
XAQueueSession |
XAQueueConnection.createXAQueueSession()
Creates an
XAQueueSession object. |
XASession |
XAConnection.createXASession()
Creates an
XASession object. |
XATopicConnection |
XATopicConnectionFactory.createXATopicConnection()
Creates an XA topic connection with the default user identity.
|
XATopicConnection |
XATopicConnectionFactory.createXATopicConnection(String userName,
String password)
Creates an XA topic connection with the specified user identity.
|
XATopicSession |
XATopicConnection.createXATopicSession()
Creates an
XATopicSession object. |
void |
TemporaryTopic.delete()
Deletes this temporary topic.
|
void |
TemporaryQueue.delete()
Deletes this temporary queue.
|
int |
Session.getAcknowledgeMode()
Returns the acknowledgement mode of the session.
|
long |
BytesMessage.getBodyLength()
Gets the number of bytes of the message body when the message
is in read-only mode.
|
boolean |
MapMessage.getBoolean(String name)
Returns the
boolean value with the specified name. |
boolean |
Message.getBooleanProperty(String name)
Returns the value of the
boolean property with the
specified name. |
byte |
MapMessage.getByte(String name)
Returns the
byte value with the specified name. |
byte |
Message.getByteProperty(String name)
Returns the value of the
byte property with the specified
name. |
byte[] |
MapMessage.getBytes(String name)
Returns the byte array value with the specified name.
|
char |
MapMessage.getChar(String name)
Returns the Unicode character value with the specified name.
|
String |
Connection.getClientID()
Gets the client identifier for this connection.
|
int |
MessageProducer.getDeliveryMode()
Gets the producer's default delivery mode.
|
Destination |
MessageProducer.getDestination()
Gets the destination associated with this
MessageProducer . |
boolean |
MessageProducer.getDisableMessageID()
Gets an indication of whether message IDs are disabled.
|
boolean |
MessageProducer.getDisableMessageTimestamp()
Gets an indication of whether message timestamps are disabled.
|
double |
MapMessage.getDouble(String name)
Returns the
double value with the specified name. |
double |
Message.getDoubleProperty(String name)
Returns the value of the
double property with the specified
name. |
Enumeration |
QueueBrowser.getEnumeration()
Gets an enumeration for browsing the current queue messages in the
order they would be received.
|
ExceptionListener |
Connection.getExceptionListener()
Gets the
ExceptionListener object for this connection. |
float |
MapMessage.getFloat(String name)
Returns the
float value with the specified name. |
float |
Message.getFloatProperty(String name)
Returns the value of the
float property with the specified
name. |
int |
MapMessage.getInt(String name)
Returns the
int value with the specified name. |
int |
Message.getIntProperty(String name)
Returns the value of the
int property with the specified
name. |
String |
Message.getJMSCorrelationID()
Gets the correlation ID for the message.
|
byte[] |
Message.getJMSCorrelationIDAsBytes()
Gets the correlation ID as an array of bytes for the message.
|
int |
Message.getJMSDeliveryMode()
Gets the
DeliveryMode value specified for this message. |
Destination |
Message.getJMSDestination()
Gets the
Destination object for this message. |
long |
Message.getJMSExpiration()
Gets the message's expiration value.
|
int |
ConnectionMetaData.getJMSMajorVersion()
Gets the JMS major version number.
|
String |
Message.getJMSMessageID()
Gets the message ID.
|
int |
ConnectionMetaData.getJMSMinorVersion()
Gets the JMS minor version number.
|
int |
Message.getJMSPriority()
Gets the message priority level.
|
String |
ConnectionMetaData.getJMSProviderName()
Gets the JMS provider name.
|
boolean |
Message.getJMSRedelivered()
Gets an indication of whether this message is being redelivered.
|
Destination |
Message.getJMSReplyTo()
Gets the
Destination object to which a reply to this
message should be sent. |
long |
Message.getJMSTimestamp()
Gets the message timestamp.
|
String |
Message.getJMSType()
Gets the message type identifier supplied by the client when the
message was sent.
|
String |
ConnectionMetaData.getJMSVersion()
Gets the JMS API version.
|
Enumeration |
ConnectionMetaData.getJMSXPropertyNames()
Gets an enumeration of the JMSX property names.
|
long |
MapMessage.getLong(String name)
Returns the
long value with the specified name. |
long |
Message.getLongProperty(String name)
Returns the value of the
long property with the specified
name. |
Enumeration |
MapMessage.getMapNames()
Returns an
Enumeration of all the names in the
MapMessage object. |
MessageListener |
Session.getMessageListener()
Returns the session's distinguished message listener (optional).
|
MessageListener |
MessageConsumer.getMessageListener()
Gets the message consumer's
MessageListener . |
String |
QueueBrowser.getMessageSelector()
Gets this queue browser's message selector expression.
|
String |
MessageConsumer.getMessageSelector()
Gets this message consumer's message selector expression.
|
ConnectionMetaData |
Connection.getMetaData()
Gets the metadata for this connection.
|
boolean |
TopicSubscriber.getNoLocal()
Gets the
NoLocal attribute for this subscriber. |
Serializable |
ObjectMessage.getObject()
Gets the serializable object containing this message's data.
|
Object |
MapMessage.getObject(String name)
Returns the value of the object with the specified name.
|
Object |
Message.getObjectProperty(String name)
Returns the value of the Java object property with the specified name.
|
int |
MessageProducer.getPriority()
Gets the producer's default priority.
|
Enumeration |
Message.getPropertyNames()
Returns an
Enumeration of all the property names. |
int |
ConnectionMetaData.getProviderMajorVersion()
Gets the JMS provider major version number.
|
int |
ConnectionMetaData.getProviderMinorVersion()
Gets the JMS provider minor version number.
|
String |
ConnectionMetaData.getProviderVersion()
Gets the JMS provider version.
|
Queue |
QueueSender.getQueue()
Gets the queue associated with this
QueueSender . |
Queue |
QueueReceiver.getQueue()
Gets the
Queue associated with this queue receiver. |
Queue |
QueueBrowser.getQueue()
Gets the queue associated with this queue browser.
|
String |
Queue.getQueueName()
Gets the name of this queue.
|
QueueSession |
XAQueueSession.getQueueSession()
Gets the queue session associated with this
XAQueueSession . |
ServerSession |
ServerSessionPool.getServerSession()
Return a server session from the pool.
|
ServerSessionPool |
ConnectionConsumer.getServerSessionPool()
Gets the server session pool associated with this connection consumer.
|
Session |
XASession.getSession()
Gets the session associated with this
XASession . |
Session |
ServerSession.getSession()
Return the
ServerSession 's Session . |
short |
MapMessage.getShort(String name)
Returns the
short value with the specified name. |
short |
Message.getShortProperty(String name)
Returns the value of the
short property with the specified
name. |
String |
MapMessage.getString(String name)
Returns the
String value with the specified name. |
String |
Message.getStringProperty(String name)
Returns the value of the
String property with the specified
name. |
String |
TextMessage.getText()
Gets the string containing this message's data.
|
long |
MessageProducer.getTimeToLive()
Gets the default length of time in milliseconds from its dispatch time
that a produced message should be retained by the message system.
|
Topic |
TopicSubscriber.getTopic()
Gets the
Topic associated with this subscriber. |
Topic |
TopicPublisher.getTopic()
Gets the topic associated with this
TopicPublisher . |
String |
Topic.getTopicName()
Gets the name of this topic.
|
TopicSession |
XATopicSession.getTopicSession()
Gets the topic session associated with this
XATopicSession . |
boolean |
XASession.getTransacted()
Indicates whether the session is in transacted mode.
|
boolean |
Session.getTransacted()
Indicates whether the session is in transacted mode.
|
boolean |
MapMessage.itemExists(String name)
Indicates whether an item exists in this
MapMessage object. |
boolean |
Message.propertyExists(String name)
Indicates whether a property value exists.
|
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.
|
boolean |
StreamMessage.readBoolean()
Reads a
boolean from the stream message. |
boolean |
BytesMessage.readBoolean()
Reads a
boolean from the bytes message stream. |
byte |
StreamMessage.readByte()
Reads a
byte value from the stream message. |
byte |
BytesMessage.readByte()
Reads a signed 8-bit value from the bytes message stream.
|
int |
StreamMessage.readBytes(byte[] value)
Reads a byte array field from the stream message into the
specified
byte[] object (the read buffer). |
int |
BytesMessage.readBytes(byte[] value)
Reads a byte array from the bytes message stream.
|
int |
BytesMessage.readBytes(byte[] value,
int length)
Reads a portion of the bytes message stream.
|
char |
StreamMessage.readChar()
Reads a Unicode character value from the stream message.
|
char |
BytesMessage.readChar()
Reads a Unicode character value from the bytes message stream.
|
double |
StreamMessage.readDouble()
Reads a
double from the stream message. |
double |
BytesMessage.readDouble()
Reads a
double from the bytes message stream. |
float |
StreamMessage.readFloat()
Reads a
float from the stream message. |
float |
BytesMessage.readFloat()
Reads a
float from the bytes message stream. |
int |
StreamMessage.readInt()
Reads a 32-bit integer from the stream message.
|
int |
BytesMessage.readInt()
Reads a signed 32-bit integer from the bytes message stream.
|
long |
StreamMessage.readLong()
Reads a 64-bit integer from the stream message.
|
long |
BytesMessage.readLong()
Reads a signed 64-bit integer from the bytes message stream.
|
Object |
StreamMessage.readObject()
Reads an object from the stream message.
|
short |
StreamMessage.readShort()
Reads a 16-bit integer from the stream message.
|
short |
BytesMessage.readShort()
Reads a signed 16-bit number from the bytes message stream.
|
String |
StreamMessage.readString()
Reads a
String from the stream message. |
int |
BytesMessage.readUnsignedByte()
Reads an unsigned 8-bit number from the bytes message stream.
|
int |
BytesMessage.readUnsignedShort()
Reads an unsigned 16-bit number from the bytes message stream.
|
String |
BytesMessage.readUTF()
Reads a string that has been encoded using a modified UTF-8
format from the bytes message stream.
|
Message |
MessageConsumer.receive()
Receives the next message produced for this message consumer.
|
Message |
MessageConsumer.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.
|
void |
Session.recover()
Stops message delivery in this session, and restarts message delivery
with the oldest unacknowledged message.
|
Message |
TopicRequestor.request(Message message) |
Message |
QueueRequestor.request(Message message) |
void |
StreamMessage.reset()
Puts the message body in read-only mode and repositions the stream
to the beginning.
|
void |
BytesMessage.reset()
Puts the message body in read-only mode and repositions the stream of
bytes to the beginning.
|
void |
XASession.rollback()
Throws a
TransactionInProgressException , since it should
not be called for an XASession object. |
void |
Session.rollback()
Rolls back any messages done in this transaction and releases any locks
currently held.
|
void |
MessageProducer.send(Destination destination,
Message message)
Sends a message to a destination for an unidentified message producer.
|
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 |
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 |
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 to the destination, specifying delivery mode, priority, and
time to live.
|
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.
|
void |
MapMessage.setBoolean(String name,
boolean value)
Sets a
boolean value with the specified name into the Map. |
void |
Message.setBooleanProperty(String name,
boolean value)
Sets a
boolean property value with the specified name into
the message. |
void |
MapMessage.setByte(String name,
byte value)
Sets a
byte value with the specified name into the Map. |
void |
Message.setByteProperty(String name,
byte value)
Sets a
byte property value with the specified name into
the message. |
void |
MapMessage.setBytes(String name,
byte[] value)
Sets a byte array value with the specified name into the Map.
|
void |
MapMessage.setBytes(String name,
byte[] value,
int offset,
int length)
Sets a portion of the byte array value with the specified name into the
Map.
|
void |
MapMessage.setChar(String name,
char value)
Sets a Unicode character value with the specified name into the Map.
|
void |
Connection.setClientID(String clientID)
Sets the client identifier for this connection.
|
void |
MessageProducer.setDeliveryMode(int deliveryMode)
Sets the producer's default delivery mode.
|
void |
MessageProducer.setDisableMessageID(boolean value)
Sets whether message IDs are disabled.
|
void |
MessageProducer.setDisableMessageTimestamp(boolean value)
Sets whether message timestamps are disabled.
|
void |
MapMessage.setDouble(String name,
double value)
Sets a
double value with the specified name into the Map. |
void |
Message.setDoubleProperty(String name,
double value)
Sets a
double property value with the specified name into
the message. |
void |
Connection.setExceptionListener(ExceptionListener listener)
Sets an exception listener for this connection.
|
void |
MapMessage.setFloat(String name,
float value)
Sets a
float value with the specified name into the Map. |
void |
Message.setFloatProperty(String name,
float value)
Sets a
float property value with the specified name into
the message. |
void |
MapMessage.setInt(String name,
int value)
Sets an
int value with the specified name into the Map. |
void |
Message.setIntProperty(String name,
int value)
Sets an
int property value with the specified name into
the message. |
void |
Message.setJMSCorrelationID(String correlationID)
Sets the correlation ID for the message.
|
void |
Message.setJMSCorrelationIDAsBytes(byte[] correlationID)
Sets the correlation ID as an array of bytes for the message.
|
void |
Message.setJMSDeliveryMode(int deliveryMode)
Sets the
DeliveryMode value for this message. |
void |
Message.setJMSDestination(Destination destination)
Sets the
Destination object for this message. |
void |
Message.setJMSExpiration(long expiration)
Sets the message's expiration value.
|
void |
Message.setJMSMessageID(String id)
Sets the message ID.
|
void |
Message.setJMSPriority(int priority)
Sets the priority level for this message.
|
void |
Message.setJMSRedelivered(boolean redelivered)
Specifies whether this message is being redelivered.
|
void |
Message.setJMSReplyTo(Destination replyTo)
Sets the
Destination object to which a reply to this
message should be sent. |
void |
Message.setJMSTimestamp(long timestamp)
Sets the message timestamp.
|
void |
Message.setJMSType(String type)
Sets the message type.
|
void |
MapMessage.setLong(String name,
long value)
Sets a
long value with the specified name into the Map. |
void |
Message.setLongProperty(String name,
long value)
Sets a
long property value with the specified name into
the message. |
void |
Session.setMessageListener(MessageListener listener)
Sets the session's distinguished message listener (optional).
|
void |
MessageConsumer.setMessageListener(MessageListener listener)
Sets the message consumer's
MessageListener . |
void |
ObjectMessage.setObject(Serializable object)
Sets the serializable object containing this message's data.
|
void |
MapMessage.setObject(String name,
Object value)
Sets an object value with the specified name into the Map.
|
void |
Message.setObjectProperty(String name,
Object value)
Sets a Java object property value with the specified name into the
message.
|
void |
MessageProducer.setPriority(int defaultPriority)
Sets the producer's default priority.
|
void |
MapMessage.setShort(String name,
short value)
Sets a
short value with the specified name into the Map. |
void |
Message.setShortProperty(String name,
short value)
Sets a
short property value with the specified name into
the message. |
void |
MapMessage.setString(String name,
String value)
Sets a
String value with the specified name into the Map. |
void |
Message.setStringProperty(String name,
String value)
Sets a
String property value with the specified name into
the message. |
void |
TextMessage.setText(String string)
Sets the string containing this message's data.
|
void |
MessageProducer.setTimeToLive(long timeToLive)
Sets the default length of time in milliseconds from its dispatch time
that a produced message should be retained by the message system.
|
void |
ServerSession.start()
Cause the
Session 's run method to be called
to process messages that were just assigned to it. |
void |
Connection.start()
Starts (or restarts) a connection's delivery of incoming messages.
|
void |
Connection.stop()
Temporarily stops a connection's delivery of incoming messages.
|
void |
TopicSession.unsubscribe(String name)
Unsubscribes a durable subscription that has been created by a client.
|
void |
Session.unsubscribe(String name)
Unsubscribes a durable subscription that has been created by a client.
|
void |
StreamMessage.writeBoolean(boolean value)
Writes a
boolean to the stream message. |
void |
BytesMessage.writeBoolean(boolean value)
Writes a
boolean to the bytes message stream as a 1-byte
value. |
void |
StreamMessage.writeByte(byte value)
Writes a
byte to the stream message. |
void |
BytesMessage.writeByte(byte value)
Writes a
byte to the bytes message stream as a 1-byte
value. |
void |
StreamMessage.writeBytes(byte[] value)
Writes a byte array field to the stream message.
|
void |
BytesMessage.writeBytes(byte[] value)
Writes a byte array to the bytes message stream.
|
void |
StreamMessage.writeBytes(byte[] value,
int offset,
int length)
Writes a portion of a byte array as a byte array field to the stream
message.
|
void |
BytesMessage.writeBytes(byte[] value,
int offset,
int length)
Writes a portion of a byte array to the bytes message stream.
|
void |
StreamMessage.writeChar(char value)
Writes a
char to the stream message. |
void |
BytesMessage.writeChar(char value)
Writes a
char to the bytes message stream as a 2-byte
value, high byte first. |
void |
StreamMessage.writeDouble(double value)
Writes a
double to the stream message. |
void |
BytesMessage.writeDouble(double value)
Converts the
double argument to a long using
the
doubleToLongBits method in class Double ,
and then writes that long value to the bytes message
stream as an 8-byte quantity, high byte first. |
void |
StreamMessage.writeFloat(float value)
Writes a
float to the stream message. |
void |
BytesMessage.writeFloat(float value)
Converts the
float argument to an int using
the
floatToIntBits method in class Float ,
and then writes that int value to the bytes message
stream as a 4-byte quantity, high byte first. |
void |
StreamMessage.writeInt(int value)
Writes an
int to the stream message. |
void |
BytesMessage.writeInt(int value)
Writes an
int to the bytes message stream as four bytes,
high byte first. |
void |
StreamMessage.writeLong(long value)
Writes a
long to the stream message. |
void |
BytesMessage.writeLong(long value)
Writes a
long to the bytes message stream as eight bytes,
high byte first. |
void |
StreamMessage.writeObject(Object value)
Writes an object to the stream message.
|
void |
BytesMessage.writeObject(Object value)
Writes an object to the bytes message stream.
|
void |
StreamMessage.writeShort(short value)
Writes a
short to the stream message. |
void |
BytesMessage.writeShort(short value)
Writes a
short to the bytes message stream as two bytes,
high byte first. |
void |
StreamMessage.writeString(String value)
Writes a
String to the stream message. |
void |
BytesMessage.writeUTF(String value)
Writes a string to the bytes message stream using UTF-8 encoding in a
machine-independent manner.
|
Constructor and Description |
---|
QueueRequestor(QueueSession session,
Queue queue) |
TopicRequestor(TopicSession session,
Topic topic) |
Modifier and Type | Method and Description |
---|---|
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 a 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 a operation invocation in a JMS message to invoke the corresponding operation the value from the server resource.
|
Modifier and Type | Method and Description |
---|---|
static JMSException |
JMSExceptionHelper.convertFromHornetQException(HornetQException me) |
Modifier and Type | Method and Description |
---|---|
void |
HornetQMessage.acknowledge() |
void |
HornetQConnection.authorize() |
protected void |
HornetQMessage.checkRead() |
protected void |
HornetQMessage.checkWrite() |
void |
HornetQTextMessage.clearBody() |
void |
HornetQStreamMessage.clearBody() |
void |
HornetQObjectMessage.clearBody() |
void |
HornetQMessage.clearBody() |
void |
HornetQMapMessage.clearBody() |
void |
HornetQBytesMessage.clearBody() |
void |
HornetQMessage.clearProperties() |
void |
HornetQSession.close() |
void |
HornetQQueueBrowser.close() |
void |
HornetQMessageProducer.close() |
void |
HornetQMessageConsumer.close() |
void |
HornetQConnection.close() |
void |
HornetQSession.commit() |
QueueBrowser |
HornetQSession.createBrowser(Queue queue) |
QueueBrowser |
HornetQSession.createBrowser(Queue queue,
String filterString) |
BytesMessage |
HornetQSession.createBytesMessage() |
Connection |
HornetQConnectionFactory.createConnection() |
Connection |
HornetQConnectionFactory.createConnection(String username,
String password) |
ConnectionConsumer |
HornetQConnection.createConnectionConsumer(Destination destination,
String messageSelector,
ServerSessionPool sessionPool,
int maxMessages) |
ConnectionConsumer |
HornetQConnection.createConnectionConsumer(Queue queue,
String messageSelector,
ServerSessionPool sessionPool,
int maxMessages) |
ConnectionConsumer |
HornetQConnection.createConnectionConsumer(Topic topic,
String messageSelector,
ServerSessionPool sessionPool,
int maxMessages) |
protected HornetQConnection |
HornetQConnectionFactory.createConnectionInternal(String username,
String password,
boolean isXA,
int type) |
MessageConsumer |
HornetQSession.createConsumer(Destination destination) |
MessageConsumer |
HornetQSession.createConsumer(Destination destination,
String messageSelector) |
MessageConsumer |
HornetQSession.createConsumer(Destination destination,
String messageSelector,
boolean noLocal) |
ConnectionConsumer |
HornetQConnection.createDurableConnectionConsumer(Topic topic,
String subscriptionName,
String messageSelector,
ServerSessionPool sessionPool,
int maxMessages) |
TopicSubscriber |
HornetQSession.createDurableSubscriber(Topic topic,
String name) |
TopicSubscriber |
HornetQSession.createDurableSubscriber(Topic topic,
String name,
String messageSelector,
boolean noLocal) |
MapMessage |
HornetQSession.createMapMessage() |
Message |
HornetQSession.createMessage() |
ObjectMessage |
HornetQSession.createObjectMessage() |
ObjectMessage |
HornetQSession.createObjectMessage(Serializable object) |
MessageProducer |
HornetQSession.createProducer(Destination destination) |
TopicPublisher |
HornetQSession.createPublisher(Topic topic) |
Queue |
HornetQSession.createQueue(String queueName) |
QueueConnection |
HornetQConnectionFactory.createQueueConnection() |
QueueConnection |
HornetQConnectionFactory.createQueueConnection(String username,
String password) |
QueueSession |
HornetQConnection.createQueueSession(boolean transacted,
int acknowledgeMode) |
QueueReceiver |
HornetQSession.createReceiver(Queue queue) |
QueueReceiver |
HornetQSession.createReceiver(Queue queue,
String messageSelector) |
QueueSender |
HornetQSession.createSender(Queue queue) |
Session |
HornetQConnection.createSession(boolean transacted,
int acknowledgeMode) |
StreamMessage |
HornetQSession.createStreamMessage() |
TopicSubscriber |
HornetQSession.createSubscriber(Topic topic) |
TopicSubscriber |
HornetQSession.createSubscriber(Topic topic,
String messageSelector,
boolean noLocal) |
TemporaryQueue |
HornetQSession.createTemporaryQueue() |
TemporaryTopic |
HornetQSession.createTemporaryTopic() |
TextMessage |
HornetQSession.createTextMessage() |
TextMessage |
HornetQSession.createTextMessage(String text) |
Topic |
HornetQSession.createTopic(String topicName) |
TopicConnection |
HornetQConnectionFactory.createTopicConnection() |
TopicConnection |
HornetQConnectionFactory.createTopicConnection(String username,
String password) |
TopicSession |
HornetQConnection.createTopicSession(boolean transacted,
int acknowledgeMode) |
XAConnection |
HornetQConnectionFactory.createXAConnection() |
XAConnection |
HornetQConnectionFactory.createXAConnection(String username,
String password) |
XAQueueConnection |
HornetQConnectionFactory.createXAQueueConnection() |
XAQueueConnection |
HornetQConnectionFactory.createXAQueueConnection(String username,
String password) |
XAQueueSession |
HornetQConnection.createXAQueueSession() |
XASession |
HornetQConnection.createXASession() |
XATopicConnection |
HornetQConnectionFactory.createXATopicConnection() |
XATopicConnection |
HornetQConnectionFactory.createXATopicConnection(String username,
String password) |
XATopicSession |
HornetQConnection.createXATopicSession() |
void |
HornetQDestination.delete() |
void |
HornetQSession.deleteTemporaryQueue(HornetQDestination tempQueue) |
void |
HornetQSession.deleteTemporaryTopic(HornetQDestination tempTopic) |
int |
HornetQSession.getAcknowledgeMode() |
long |
HornetQBytesMessage.getBodyLength() |
boolean |
HornetQMapMessage.getBoolean(String name) |
boolean |
HornetQMessage.getBooleanProperty(String name) |
byte |
HornetQMapMessage.getByte(String name) |
byte |
HornetQMessage.getByteProperty(String name) |
byte[] |
HornetQMapMessage.getBytes(String name) |
char |
HornetQMapMessage.getChar(String name) |
String |
HornetQConnection.getClientID() |
ClientSessionFactory |
HornetQConnectionFactory.getCoreFactory()
Deprecated.
|
int |
HornetQMessageProducer.getDeliveryMode() |
Destination |
HornetQMessageProducer.getDestination() |
boolean |
HornetQMessageProducer.getDisableMessageID() |
boolean |
HornetQMessageProducer.getDisableMessageTimestamp() |
double |
HornetQMapMessage.getDouble(String name) |
double |
HornetQMessage.getDoubleProperty(String name) |
Enumeration |
HornetQQueueBrowser.getEnumeration() |
ExceptionListener |
HornetQConnection.getExceptionListener() |
float |
HornetQMapMessage.getFloat(String name) |
float |
HornetQMessage.getFloatProperty(String name) |
int |
HornetQMapMessage.getInt(String name) |
int |
HornetQMessage.getIntProperty(String name) |
String |
HornetQMessage.getJMSCorrelationID() |
byte[] |
HornetQMessage.getJMSCorrelationIDAsBytes() |
int |
HornetQMessage.getJMSDeliveryMode() |
Destination |
HornetQMessage.getJMSDestination() |
long |
HornetQMessage.getJMSExpiration() |
int |
HornetQConnectionMetaData.getJMSMajorVersion() |
int |
HornetQConnectionMetaData.getJMSMinorVersion() |
int |
HornetQMessage.getJMSPriority() |
String |
HornetQConnectionMetaData.getJMSProviderName() |
boolean |
HornetQMessage.getJMSRedelivered() |
Destination |
HornetQMessage.getJMSReplyTo() |
long |
HornetQMessage.getJMSTimestamp() |
String |
HornetQMessage.getJMSType() |
String |
HornetQConnectionMetaData.getJMSVersion() |
Enumeration |
HornetQConnectionMetaData.getJMSXPropertyNames() |
long |
HornetQMapMessage.getLong(String name) |
long |
HornetQMessage.getLongProperty(String name) |
Enumeration |
HornetQMapMessage.getMapNames() |
MessageListener |
HornetQSession.getMessageListener() |
MessageListener |
HornetQMessageConsumer.getMessageListener() |
String |
HornetQQueueBrowser.getMessageSelector() |
String |
HornetQMessageConsumer.getMessageSelector() |
ConnectionMetaData |
HornetQConnection.getMetaData() |
boolean |
HornetQMessageConsumer.getNoLocal() |
Serializable |
HornetQObjectMessage.getObject() |
Object |
HornetQMapMessage.getObject(String name) |
Object |
HornetQMessage.getObjectProperty(String name) |
int |
HornetQMessageProducer.getPriority() |
Enumeration |
HornetQMessage.getPropertyNames() |
int |
HornetQConnectionMetaData.getProviderMajorVersion() |
int |
HornetQConnectionMetaData.getProviderMinorVersion() |
String |
HornetQConnectionMetaData.getProviderVersion() |
Queue |
HornetQQueueBrowser.getQueue() |
Queue |
HornetQMessageProducer.getQueue() |
Queue |
HornetQMessageConsumer.getQueue() |
QueueSession |
HornetQSession.getQueueSession() |
Session |
HornetQSession.getSession() |
short |
HornetQMapMessage.getShort(String name) |
short |
HornetQMessage.getShortProperty(String name) |
String |
HornetQMapMessage.getString(String name) |
String |
HornetQMessage.getStringProperty(String name) |
String |
HornetQTextMessage.getText() |
long |
HornetQMessageProducer.getTimeToLive() |
Topic |
HornetQMessageProducer.getTopic() |
Topic |
HornetQMessageConsumer.getTopic() |
TopicSession |
HornetQSession.getTopicSession() |
boolean |
HornetQSession.getTransacted() |
boolean |
HornetQMapMessage.itemExists(String name) |
boolean |
HornetQMessage.propertyExists(String name) |
void |
HornetQMessageProducer.publish(Message message) |
void |
HornetQMessageProducer.publish(Message message,
int deliveryMode,
int priority,
long timeToLive) |
void |
HornetQMessageProducer.publish(Topic topic,
Message message) |
void |
HornetQMessageProducer.publish(Topic topic,
Message message,
int deliveryMode,
int priority,
long timeToLive) |
boolean |
HornetQStreamMessage.readBoolean() |
boolean |
HornetQBytesMessage.readBoolean() |
byte |
HornetQStreamMessage.readByte() |
byte |
HornetQBytesMessage.readByte() |
int |
HornetQStreamMessage.readBytes(byte[] value) |
int |
HornetQBytesMessage.readBytes(byte[] value) |
int |
HornetQBytesMessage.readBytes(byte[] value,
int length) |
char |
HornetQStreamMessage.readChar() |
char |
HornetQBytesMessage.readChar() |
double |
HornetQStreamMessage.readDouble() |
double |
HornetQBytesMessage.readDouble() |
float |
HornetQStreamMessage.readFloat() |
float |
HornetQBytesMessage.readFloat() |
int |
HornetQStreamMessage.readInt() |
int |
HornetQBytesMessage.readInt() |
long |
HornetQStreamMessage.readLong() |
long |
HornetQBytesMessage.readLong() |
Object |
HornetQStreamMessage.readObject() |
short |
HornetQStreamMessage.readShort() |
short |
HornetQBytesMessage.readShort() |
String |
HornetQStreamMessage.readString() |
int |
HornetQBytesMessage.readUnsignedByte() |
int |
HornetQBytesMessage.readUnsignedShort() |
String |
HornetQBytesMessage.readUTF() |
Message |
HornetQMessageConsumer.receive() |
Message |
HornetQMessageConsumer.receive(long timeout) |
Message |
HornetQMessageConsumer.receiveNoWait() |
void |
HornetQSession.recover() |
void |
HornetQStreamMessage.reset() |
void |
HornetQBytesMessage.reset() |
void |
HornetQSession.rollback() |
void |
HornetQMessage.saveToOutputStream(OutputStream output) |
void |
HornetQMessageProducer.send(Destination destination,
Message message) |
void |
HornetQMessageProducer.send(Destination destination,
Message message,
int deliveryMode,
int priority,
long timeToLive) |
void |
HornetQMessageProducer.send(Message message) |
void |
HornetQMessageProducer.send(Message message,
int deliveryMode,
int priority,
long timeToLive) |
void |
HornetQMessageProducer.send(Queue queue,
Message message) |
void |
HornetQMessageProducer.send(Queue queue,
Message message,
int deliveryMode,
int priority,
long timeToLive) |
void |
HornetQMapMessage.setBoolean(String name,
boolean value) |
void |
HornetQMessage.setBooleanProperty(String name,
boolean value) |
void |
HornetQMapMessage.setByte(String name,
byte value) |
void |
HornetQMessage.setByteProperty(String name,
byte value) |
void |
HornetQMapMessage.setBytes(String name,
byte[] value) |
void |
HornetQMapMessage.setBytes(String name,
byte[] value,
int offset,
int length) |
void |
HornetQMapMessage.setChar(String name,
char value) |
void |
HornetQConnection.setClientID(String clientID) |
void |
HornetQMessageProducer.setDeliveryMode(int deliveryMode) |
void |
HornetQMessageProducer.setDisableMessageID(boolean value) |
void |
HornetQMessageProducer.setDisableMessageTimestamp(boolean value) |
void |
HornetQMapMessage.setDouble(String name,
double value) |
void |
HornetQMessage.setDoubleProperty(String name,
double value) |
void |
HornetQConnection.setExceptionListener(ExceptionListener listener) |
void |
HornetQMapMessage.setFloat(String name,
float value) |
void |
HornetQMessage.setFloatProperty(String name,
float value) |
void |
HornetQMessage.setInputStream(InputStream input) |
void |
HornetQMapMessage.setInt(String name,
int value) |
void |
HornetQMessage.setIntProperty(String name,
int value) |
void |
HornetQMessage.setJMSCorrelationID(String correlationID) |
void |
HornetQMessage.setJMSCorrelationIDAsBytes(byte[] correlationID) |
void |
HornetQMessage.setJMSDeliveryMode(int deliveryMode) |
void |
HornetQMessage.setJMSDestination(Destination destination) |
void |
HornetQMessage.setJMSExpiration(long expiration) |
void |
HornetQMessage.setJMSMessageID(String jmsMessageID) |
void |
HornetQMessage.setJMSPriority(int priority) |
void |
HornetQMessage.setJMSRedelivered(boolean redelivered) |
void |
HornetQMessage.setJMSReplyTo(Destination dest) |
void |
HornetQMessage.setJMSTimestamp(long timestamp) |
void |
HornetQMessage.setJMSType(String type) |
void |
HornetQMapMessage.setLong(String name,
long value) |
void |
HornetQMessage.setLongProperty(String name,
long value) |
void |
HornetQSession.setMessageListener(MessageListener listener) |
void |
HornetQMessageConsumer.setMessageListener(MessageListener listener) |
void |
HornetQObjectMessage.setObject(Serializable object) |
void |
HornetQMapMessage.setObject(String name,
Object value) |
void |
HornetQMessage.setObjectProperty(String name,
Object value) |
void |
HornetQMessage.setOutputStream(OutputStream output) |
void |
HornetQMessageProducer.setPriority(int defaultPriority) |
void |
HornetQMapMessage.setShort(String name,
short value) |
void |
HornetQMessage.setShortProperty(String name,
short value) |
void |
HornetQMapMessage.setString(String name,
String value) |
void |
HornetQMessage.setStringProperty(String name,
String value) |
void |
HornetQTextMessage.setText(String text) |
void |
HornetQMessageProducer.setTimeToLive(long timeToLive) |
void |
HornetQSession.start() |
void |
HornetQConnection.start() |
void |
HornetQSession.stop() |
void |
HornetQConnection.stop() |
void |
HornetQSession.unsubscribe(String name) |
boolean |
HornetQMessage.waitCompletionOnStream(long timeWait) |
void |
HornetQStreamMessage.writeBoolean(boolean value) |
void |
HornetQBytesMessage.writeBoolean(boolean value) |
void |
HornetQStreamMessage.writeByte(byte value) |
void |
HornetQBytesMessage.writeByte(byte value) |
void |
HornetQStreamMessage.writeBytes(byte[] value) |
void |
HornetQBytesMessage.writeBytes(byte[] value) |
void |
HornetQStreamMessage.writeBytes(byte[] value,
int offset,
int length) |
void |
HornetQBytesMessage.writeBytes(byte[] value,
int offset,
int length) |
void |
HornetQStreamMessage.writeChar(char value) |
void |
HornetQBytesMessage.writeChar(char value) |
void |
HornetQStreamMessage.writeDouble(double value) |
void |
HornetQBytesMessage.writeDouble(double value) |
void |
HornetQStreamMessage.writeFloat(float value) |
void |
HornetQBytesMessage.writeFloat(float value) |
void |
HornetQStreamMessage.writeInt(int value) |
void |
HornetQBytesMessage.writeInt(int value) |
void |
HornetQStreamMessage.writeLong(long value) |
void |
HornetQBytesMessage.writeLong(long value) |
void |
HornetQStreamMessage.writeObject(Object value) |
void |
HornetQBytesMessage.writeObject(Object value) |
void |
HornetQStreamMessage.writeShort(short value) |
void |
HornetQBytesMessage.writeShort(short value) |
void |
HornetQStreamMessage.writeString(String value) |
void |
HornetQBytesMessage.writeUTF(String value) |
Copyright © 2012 JBoss by Red Hat. All Rights Reserved.