| Package | Description | 
|---|---|
| com.caucho.amqp.marshal | |
| com.caucho.ejb.message | |
| com.caucho.jms | |
| com.caucho.jms.connection | |
| com.caucho.jms.jca | |
| com.caucho.jms.jdbc | |
| com.caucho.jms.message | |
| com.caucho.jms.selector | |
| javax.jms | 
| Modifier and Type | Method and Description | 
|---|---|
Message | 
AmqpJmsDecoder.decode(AmqpReader in,
      Message prevValue)  | 
| Modifier and Type | Method and Description | 
|---|---|
Message | 
AmqpJmsDecoder.decode(AmqpReader in,
      Message prevValue)  | 
void | 
AmqpJmsEncoder.encodeData(AmqpWriter out,
          Message msg)  | 
java.lang.String | 
AmqpJmsEncoder.getContentType(Message value)  | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
MessageListenerAdapter.onMessage(Message message)  | 
| Modifier and Type | Method and Description | 
|---|---|
Message | 
Jms.receive(Destination dest)  | 
Message | 
Jms.receive(Destination dest,
       long timeout)  | 
Message | 
Jms.receiveNoWait(Destination dest)  | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
Jms.send(Destination dest,
    Message msg)  | 
void | 
Jms.send(Destination dest,
    Message msg,
    int deliveryMode,
    int priority,
    long ttl)  | 
| Modifier and Type | Method and Description | 
|---|---|
Message | 
JmsSession.createMessage()
Creates a message. 
 | 
Message | 
MessageConsumerImpl.receive()
Receives the next message, blocking until a message is available. 
 | 
Message | 
MessageConsumerImpl.receive(long timeout)
Receives a message from the queue. 
 | 
protected Message | 
MessageConsumerImpl.receiveImpl(long timeout)
Receives a message from the queue. 
 | 
protected Message | 
TopicSubscriberImpl.receiveImpl(long timeout)  | 
Message | 
MessageConsumerImpl.receiveNoWait()
Receives a message from the queue. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
TopicPublisherImpl.publish(Message message)
Publishes a message to the topic 
 | 
void | 
TopicPublisherImpl.publish(Message message,
       int deliveryMode,
       int priority,
       long timeToLive)
Publishes a message to the topic 
 | 
void | 
TopicPublisherImpl.publish(Topic topic,
       Message message)
Publishes a message to the topic 
 | 
void | 
TopicPublisherImpl.publish(Topic topic,
       Message message,
       int deliveryMode,
       int priority,
       long timeToLive)
Publishes a message to the topic 
 | 
void | 
JmsSession.send(AbstractDestination queue,
    Message appMessage,
    int deliveryMode,
    int priority,
    long timeout)
Adds a message to the session message queue. 
 | 
void | 
MessageProducerImpl.send(Destination destination,
    Message message)
Sends a message to the destination 
 | 
void | 
MessageProducerImpl.send(Destination destination,
    Message message,
    int deliveryMode,
    int priority,
    long timeToLive)
Sends a message to the destination 
 | 
void | 
MessageProducerImpl.send(Message message)
Sends a message to the destination 
 | 
void | 
MessageProducerImpl.send(Message message,
    int deliveryMode,
    int priority,
    long timeToLive)
Sends a message to the destination 
 | 
void | 
QueueSenderImpl.send(Queue queue,
    Message message)
Sends a message to the queue 
 | 
void | 
QueueSenderImpl.send(Queue queue,
    Message message,
    int deliveryMode,
    int priority,
    long timeToLive)
Sends a message to the queue 
 | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
ListenerEndpoint.onMessage(Message message)
Runs the endpoint. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
JdbcTopic.send(Message message)
Sends the message to the queue. 
 | 
long | 
JdbcMessage.send(Message message,
    int queue,
    int priority,
    long expireTime)
Sends the message to the queue. 
 | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
BytesMessageImpl
A byte-stream message. 
 | 
class  | 
MapMessageImpl
A stream message. 
 | 
class  | 
MessageImpl
A basic message. 
 | 
class  | 
ObjectMessageImpl
An object message. 
 | 
class  | 
StreamMessageImpl
A stream message. 
 | 
class  | 
TextMessageImpl
A text message. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
MessageImpl | 
MessageFactory.copy(Message msg)
Copy the message. 
 | 
MessageType | 
MessageFactory.getMessageType(Message msg)
Returns the message type. 
 | 
java.io.InputStream | 
MessageFactory.headerToInputStream(Message msg)
Creates an input stream from the header. 
 | 
void | 
MessageFactory.writeHeader(WriteStream out,
           Message msg)  | 
| Constructor and Description | 
|---|
MessageImpl(Message msg)
Create a message, copying the properties 
 | 
| Modifier and Type | Method and Description | 
|---|---|
java.lang.Object | 
OrSelector.evaluate(Message message)
Evaluate the message. 
 | 
java.lang.Object | 
LikeSelector.evaluate(Message message)
Evaluate the message. 
 | 
java.lang.Object | 
BooleanBinarySelector.evaluate(Message message)
Evaluate the message. 
 | 
boolean | 
Selector.isMatch(Message message)  | 
| Modifier and Type | Interface and Description | 
|---|---|
interface  | 
BytesMessage
The main message. 
 | 
interface  | 
MapMessage
The main message. 
 | 
interface  | 
ObjectMessage
The main message. 
 | 
interface  | 
StreamMessage
The main message. 
 | 
interface  | 
TextMessage
The main message. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
Message | 
Session.createMessage()  | 
Message | 
MessageConsumer.receive()  | 
Message | 
MessageConsumer.receive(long timeout)  | 
Message | 
MessageConsumer.receiveNoWait()  | 
Message | 
TopicRequestor.request(Message message)  | 
Message | 
QueueRequestor.request(Message message)  | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
MessageListener.onMessage(Message message)  | 
void | 
TopicPublisher.publish(Message message)  | 
void | 
TopicPublisher.publish(Message message,
       int deliveryMode,
       int priority,
       long timeToLive)  | 
void | 
TopicPublisher.publish(Topic topic,
       Message message)  | 
void | 
TopicPublisher.publish(Topic topic,
       Message message,
       int deliveryMode,
       int priority,
       long timeToLive)  | 
Message | 
TopicRequestor.request(Message message)  | 
Message | 
QueueRequestor.request(Message message)  | 
void | 
MessageProducer.send(Destination destination,
    Message message)  | 
void | 
MessageProducer.send(Destination destination,
    Message message,
    int deliveryMode,
    int priority,
    long timeToLive)  | 
void | 
QueueSender.send(Message message)  | 
void | 
MessageProducer.send(Message message)  | 
void | 
QueueSender.send(Message message,
    int deliveryMode,
    int priority,
    long timeToLive)  | 
void | 
MessageProducer.send(Message message,
    int deliveryMode,
    int priority,
    long timeToLive)  | 
void | 
QueueSender.send(Queue queue,
    Message message)  | 
void | 
QueueSender.send(Queue queue,
    Message message,
    int deliveryMode,
    int priority,
    long timeToLive)  |