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) |