Package | Description |
---|---|
org.hornetq.api.core.client |
Core Client Messaging API.
|
org.hornetq.core.client.impl | |
org.hornetq.jms.client |
Implementation of the JMS API.
|
Modifier and Type | Method and Description |
---|---|
ClientMessage |
ClientSession.createMessage(boolean durable)
Creates a ClientMessage.
|
ClientMessage |
ClientSession.createMessage(byte type,
boolean durable)
Creates a ClientMessage.
|
ClientMessage |
ClientSession.createMessage(byte type,
boolean durable,
long expiration,
long timestamp,
byte priority)
Creates a ClientMessage.
|
ClientMessage |
ClientConsumer.receive()
Receives a message from a queue.
|
ClientMessage |
ClientConsumer.receive(long timeout)
Receives a message from a queue.
|
ClientMessage |
ClientConsumer.receiveImmediate()
Receives a message from a queue.
|
ClientMessage |
ClientRequestor.request(ClientMessage request)
Sends a message to the request address and wait indefinitely for a reply.
|
ClientMessage |
ClientRequestor.request(ClientMessage request,
long timeout)
Sends a message to the request address and wait for the given timeout for a reply.
|
Modifier and Type | Method and Description |
---|---|
void |
MessageHandler.onMessage(ClientMessage message)
Notifies the MessageHandler that a message has been received.
|
ClientMessage |
ClientRequestor.request(ClientMessage request)
Sends a message to the request address and wait indefinitely for a reply.
|
ClientMessage |
ClientRequestor.request(ClientMessage request,
long timeout)
Sends a message to the request address and wait for the given timeout for a reply.
|
Modifier and Type | Interface and Description |
---|---|
interface |
ClientLargeMessageInternal
A ClientLargeMessageInternal
|
interface |
ClientMessageInternal
A ClientMessageInternal
|
Modifier and Type | Class and Description |
---|---|
class |
ClientLargeMessageImpl
ClientLargeMessageImpl is only created when receiving large messages.
|
class |
ClientMessageImpl
A ClientMessageImpl
|
Modifier and Type | Method and Description |
---|---|
ClientMessage |
DelegatingSession.createMessage(boolean durable) |
ClientMessage |
ClientSessionImpl.createMessage(boolean durable) |
ClientMessage |
DelegatingSession.createMessage(byte type,
boolean durable) |
ClientMessage |
ClientSessionImpl.createMessage(byte type,
boolean durable) |
ClientMessage |
DelegatingSession.createMessage(byte type,
boolean durable,
long expiration,
long timestamp,
byte priority) |
ClientMessage |
ClientSessionImpl.createMessage(byte type,
boolean durable,
long expiration,
long timestamp,
byte priority) |
ClientMessage |
ClientConsumerImpl.receive() |
ClientMessage |
ClientConsumerImpl.receive(long timeout) |
ClientMessage |
ClientConsumerImpl.receiveImmediate() |
Modifier and Type | Method and Description |
---|---|
void |
ClientConsumerImpl.acknowledge(ClientMessage message) |
void |
ClientConsumerInternal.acknowledge(ClientMessage message) |
void |
ClientConsumerImpl.individualAcknowledge(ClientMessage message) |
void |
ClientConsumerInternal.individualAcknowledge(ClientMessage message) |
Modifier and Type | Field and Description |
---|---|
protected ClientMessage |
HornetQMessage.message |
Modifier and Type | Method and Description |
---|---|
ClientMessage |
HornetQMessage.getCoreMessage() |
Modifier and Type | Method and Description |
---|---|
static HornetQMessage |
HornetQMessage.createMessage(ClientMessage message,
ClientSession session) |
void |
JMSMessageListenerWrapper.onMessage(ClientMessage message)
In this method we apply the JMS acknowledgement and redelivery semantics
as per JMS spec
|
Constructor and Description |
---|
HornetQBytesMessage(ClientMessage message,
ClientSession session)
Constructor on receipt at client side
|
HornetQMapMessage(ClientMessage message,
ClientSession session) |
HornetQMessage(ClientMessage message,
ClientSession session)
Constructor for when receiving a message from the server
|
HornetQObjectMessage(ClientMessage message,
ClientSession session) |
HornetQStreamMessage(ClientMessage message,
ClientSession session) |
HornetQTextMessage(ClientMessage message,
ClientSession session) |
Copyright © 2014 JBoss, a division of Red Hat. All rights reserved.