|
SonicMQ API | ||||||||
PREV NEXT | FRAMES NO FRAMES All Classes |
ILoadBalancer
s should extend
AbstractLoadBalancer
.receive
or when the message
listener the session has called to process the message successfully
returns.
SonicStream
sender.
BytesMessage
object is used to send a message containing a
stream of uninterpreted bytes.acknowledge
method.
SonicInputStreamController
instance
and closes the JMS objects created by the controller instance.
QueueBrowser
.
QueueRequestor
and its session.
TopicRequestor
and its session.
TransactionInProgressException
, since it should
not be called for an XASession
object.
Connection
object is a client's active connection to its JMS
provider.Connection
objects provide a special
facility
for creating a ConnectionConsumer
(optional).ConnectionFactory
object encapsulates a set of connection
configuration
parameters that has been defined by an administrator.ConnectionMetaData
object provides information describing the
Connection
object.dest
.
QueueBrowser
object to peek at the messages on
the specified queue.
QueueBrowser
object to peek at the messages on
the specified queue using a message selector.
QueueBrowser
object to peek at the messages on
the specified queue.
QueueBrowser
object to peek at the messages on
the specified queue using a message selector.
QueueBrowser
object to peek at the messages on
the specified queue.
QueueBrowser
object to peek at the messages on
the specified queue using a message selector.
BytesMessage
object.
MessageConsumer
for the specified destination.
MessageConsumer
for the specified destination,
using a message selector.
MessageConsumer
for the specified destination, using a
message selector.
javax.jms.MessageConsumer
.
javax.jms.MessageConsumer
.
javax.jms.MessageConsumer
.
MessageConsumer
for the specified destination.
MessageConsumer
for the specified destination,
using a message selector.
MessageConsumer
for the specified destination, using a
message selector.
MapMessage
object.
Message
object.
ObjectMessage
object.
ObjectMessage
object.
MessageProducer
to send messages to the specified
destination.
MessageProducer
to send messages to the specified
destination.
Queue
name.
Queue
name.
Queue
name.
QueueSession
object.
XAQueueSession
object.
QueueSession
object with an associated name.
QueueReceiver
object to receive messages from the
specified queue.
QueueReceiver
object to receive messages from the
specified queue using a message selector.
QueueSender
object to send messages to the
specified queue.
Session
object.
Session
object.
Session
object with an associated name.
SonicInputStreamController
object.
SonicInputStreamController
object.
SonicOutputStreamController
object.
SonicOutputStreamController
object.
SonicOutputStream
instance with the specified ID.
StreamMessage
object.
TemporaryQueue
object.
TemporaryQueue
object.
TemporaryQueue
object.
TemporaryQueue
object whose name contains
the customID string.
TemporaryTopic
object.
TemporaryTopic
object.
TemporaryTopic
object.
TextMessage
object.
TextMessage
object.
Topic
name.
Topic
name.
Topic
name.
TopicSession
object.
XATopicSession
object.
TopicSession
object with an associated name.
XAConnection
with the default user identity.
XAConnection
with the default user identity.
XAConnection
with the default user identity.
XAConnection
with the default user identity.
XAQueueSession
object.
XAQueueSession
object with an associated name.
XASession
object.
XASession
object with an associated name.
XATopicSession
object.
XATopicSession
object with an associated name.
PERSISTENT
.
PERSISTENT
and
NON_PERSISTENT
.Destination
object encapsulates a provider-specific
address.object
is a MultiDestination made up of the same
component Destinations.
Connection
object, it informs the Connection
object's
ExceptionListener
, if one has been registered.java.lang.Integer
.
java.lang.Boolean
.
java.lang.Integer
.
boolean
value with the specified name.
boolean
property with the
specified name.
IBrokerContext
s that belong
to the same cluster as the broker represented by this IBrokerContext
.
IBrokerContext
s that belong
to the same cluster as the broker represented by this IBrokerContext
optionally excluding those that are not assigned any load balancing weight.
byte
value with the specified name.
byte
property with the specified
name.
SonicOutputStream
status as instance of StreamStatus
.
MessageProducer
.
double
value with the specified name.
double
property with the specified
name.
SonicStreamException
instance.
ExceptionListener
object for this connection.
float
value with the specified name.
float
property with the specified
name.
SonicStream
instance.
int
value with the specified name.
int
property with the specified
name.
receive()
operation or by the async listener that are currently waiting in the buffer.
send()
operation that are currently waiting in the buffer.
DeliveryMode
value specified for this message.
Destination
object for this message.
Destination
object to which a reply to this
message should be sent.
SonicStreamException
instance.
long
value with the specified name.
long
property with the specified
name.
Enumeration
of all the names in the
MapMessage
object.
receive()
operations performed by this
consumer since the time it was created.
send()
operations performed by this
producer since the time it was created.
MessageListener
.
NoLocal
attribute for this subscriber.
SonicInputStreamController
instance.
SonicInputStreamController
instance sends notifications.
SonicStream
instance for notifications.
SonicStream
instance.
Enumeration
of all the property names.
Queue
associated with this queue receiver.
QueueSender
.
XAQueueSession
.
SonicInputStreamController
instance will
wait for a segment of the stream to arrive.
ServerSession
's Session
.
XASession
.
short
value with the specified name.
short
property with the specified
name.
SonicStream
instance (and its associated segments) from other SonicStream
instances.
SonicStream
instance.
String
value with the specified name.
String
property with the specified
name.
TopicPublisher
.
Topic
associated with this subscriber.
XATopicSession
.
ILoadBalancer
implementation about broker's and their acceptors for use in
load balancing.ILoadBalancer
to assist it in making load balancing
decisions.IllegalStateException
with the specified reason
and error code.
IllegalStateException
with the specified
reason.
InvalidClientIDException
with the specified
reason and error code.
InvalidClientIDException
with the specified
reason.
InvalidDestinationException
with the specified
reason and error code.
InvalidDestinationException
with the specified
reason.
InvalidSelectorException
with the specified
reason and error code.
InvalidSelectorException
with the specified
reason.
SonicStream
is available to be read.
SonicStream
is available to be read.
MapMessage
object.
JMSException
with the specified reason and
error code.
JMSException
with the specified reason and with
the error code defaulting to null.
JMSSecurityException
with the specified
reason and error code.
JMSSecurityException
with the specified
reason.
MapMessage
object is used to send a set of name-value pairs.Message
interface is the root interface of all JMS
messages.MessageConsumer
object to receive messages
from a destination.StreamMessage
or
BytesMessage
is being read.MessageEOFException
with the specified
reason and error code.
MessageEOFException
with the specified
reason.
MessageFormatException
with the specified
reason and error code.
MessageFormatException
with the specified
reason.
MessageListener
object is used to receive asynchronously
delivered messages.MessageNotReadableException
with the specified
reason and error code.
MessageNotReadableException
with the specified
reason.
MessageNotWriteableException
with the specified
reason and error code.
MessageNotWriteableException
with the specified
reason.
MessageProducer
object to send messages to a
destination.ObjectMessage
object is used to send a message that contains
a serializable object in the Java programming language ("Java object").IConnectionContext
containing information
about the incoming connection.
Queue
object encapsulates a provider-specific queue name.QueueBrowser
object to look at messages on a
queue without removing them.QueueConnection
object is an active connection to a
point-to-point JMS provider.QueueConnectionFactory
object to create
QueueConnection
objects with a point-to-point JMS provider.QueueConnectionFactory
.QueueReceiver
object to receive messages that
have been delivered to a queue.QueueRequestor
helper class simplifies
making service requests.QueueRequestor
class.
QueueSender
object to send messages to a queue.QueueSession
object provides methods for creating
QueueReceiver
, QueueSender
,
QueueBrowser
, and TemporaryQueue
objects.boolean
from the bytes message stream.
boolean
from the stream message.
byte
value from the stream message.
byte[]
object (the read buffer).
double
from the bytes message stream.
double
from the stream message.
float
from the bytes message stream.
float
from the stream message.
String
from the stream message.
RejectionListener
is used to report errors for message delivered to the broker
asynchronously.SonicStream
instance and releases its associated resources.
SonicStream
instance and releases its associated resources.
ResourceAllocationException
with the specified
reason and error code.
ResourceAllocationException
with the specified
reason.
TransactionInProgressException
, since it should
not be called for an XASession
object.
MessageProducer
's
default delivery mode, priority, and time to live.
ServerSession
object is an application server object that
is used by a server to associate a thread with a JMS session (optional).ServerSessionPool
object is an object implemented by an
application server to provide a pool of ServerSession
objects
for processing the messages of a ConnectionConsumer
(optional).Session
object is a single-threaded context for producing and consuming
messages.getAcknowledgeMode
if the session is transacted.
boolean
value with the specified name into the Map.
boolean
property value with the specified name into
the message.
byte
value with the specified name into the Map.
byte
property value with the specified name into
the message.
org.w3c.dom.Document
and stores it
as the internal document for this message.
double
value with the specified name into the Map.
double
property value with the specified name into
the message.
float
value with the specified name into the Map.
float
property value with the specified name into
the message.
int
value with the specified name into the Map.
int
property value with the specified name into
the message.
DeliveryMode
value for this message.
Destination
object for this message.
Destination
object to which a reply to this
message should be sent.
SonicStreamException
instance.
Exception
.
long
value with the specified name into the Map.
long
property value with the specified name into
the message.
MessageListener
.
ILoadBalancer
implementation to the
the new to which to redirect a client connection.
short
value with the specified name into the Map.
short
property value with the specified name into
the message.
String
value with the specified name into the Map.
String
property value with the specified name into
the message.
SonicStream
objects, and to receive data via those stream instances.SonicStream
objects, and to receive data via those stream instances.java.io.InputStream or java.io.OutputStream
api.Session
's run
method to be called
to process messages that were just assigned to it.
StreamMessage
object is used to send a stream of primitive
types in the Java programming language.SonicInputStreamController
has been closed
or when a JMS connection drop has been detected.
TemporaryQueue
object is a unique Queue
object
created for the duration of a Connection
.TemporaryTopic
object is a unique Topic
object
created for the duration of a Connection
.TextMessage
object is used to send a message containing a
java.lang.String
.Topic
object encapsulates a provider-specific topic name.TopicConnection
object is an active connection to a
publish/subscribe JMS provider.TopicConnectionFactory
object to create
TopicConnection
objects with a publish/subscribe JMS provider.TopicConnectionFactory
.TopicPublisher
object to publish messages on a
topic.TopicRequestor
helper class simplifies
making service requests.TopicRequestor
class.
TopicSession
object provides methods for creating
TopicPublisher
, TopicSubscriber
, and
TemporaryTopic
objects.TopicSubscriber
object to receive messages that
have been published to a topic.TransactionInProgressException
with the
specified reason and error code.
TransactionInProgressException
with the
specified reason.
Session.commit
results in a rollback of the current
transaction.TransactionRolledBackException
with the
specified reason and error code.
TransactionRolledBackException
with the
specified reason.
Since the message cannot be forwarded on to a remote broker, it will be placed on the dead message queue.
TemporaryTopic
for stream messages.
boolean
to the bytes message stream as a 1-byte
value.
boolean
to the stream message.
byte
to the bytes message stream as a 1-byte
value.
byte
to the stream message.
char
to the bytes message stream as a 2-byte
value, high byte first.
char
to the stream message.
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.
double
to the stream message.
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.
float
to the stream message.
int
to the bytes message stream as four bytes,
high byte first.
int
to the stream message.
long
to the bytes message stream as eight bytes,
high byte first.
long
to the stream message.
short
to the bytes message stream as two bytes,
high byte first.
short
to the stream message.
String
to the stream message.
XAConnection
interface extends the capability of
Connection
by providing an XASession
(optional).XAConnectionFactory
interface is a base interface for the
XAQueueConnectionFactory
and
XATopicConnectionFactory
interfaces.XAQueueConnection
provides the same create options as
QueueConnection
(optional).XAQueueConnectionFactory
provides the same create options as
a QueueConnectionFactory
(optional).XAQueueSession
provides a regular QueueSession
,
which can be used to
create QueueReceiver
, QueueSender
, and
QueueBrowser
objects (optional).XASession
interface extends the capability of
Session
by adding access to a JMS provider's support for the
Java Transaction API (JTA) (optional).XATopicConnection
provides the same create options as
TopicConnection
(optional).XATopicConnectionFactory
provides the same create options as
a TopicConnectionFactory
(optional).XATopicSession
provides a regular TopicSession
.java.lang.StringBuffer
.
|
SonicMQ API | ||||||||
PREV NEXT | FRAMES NO FRAMES All Classes |