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.
|
org.hornetq.ra.inflow | |
org.hornetq.rest | |
org.hornetq.rest.queue | |
org.hornetq.rest.queue.push | |
org.hornetq.rest.util |
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 |
ClientSessionImpl.createMessage(boolean durable) |
ClientMessage |
DelegatingSession.createMessage(boolean durable) |
ClientMessage |
ClientSessionImpl.createMessage(byte type,
boolean durable) |
ClientMessage |
DelegatingSession.createMessage(byte type,
boolean durable) |
ClientMessage |
ClientSessionImpl.createMessage(byte type,
boolean durable,
long expiration,
long timestamp,
byte priority) |
ClientMessage |
DelegatingSession.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 |
ClientConsumerInternal.acknowledge(ClientMessage message) |
void |
ClientConsumerImpl.acknowledge(ClientMessage message) |
void |
ClientConsumerInternal.individualAcknowledge(ClientMessage message) |
void |
ClientConsumerImpl.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) |
Modifier and Type | Method and Description |
---|---|
void |
HornetQMessageHandler.onMessage(ClientMessage message) |
Modifier and Type | Method and Description |
---|---|
static <T> T |
Hornetq.getEntity(ClientMessage message,
Class<T> type)
Extract an object using a built-in RESTEasy JAX-RS MessageBodyReader
|
static <T> T |
Hornetq.getEntity(ClientMessage message,
Class<T> type,
org.jboss.resteasy.spi.ResteasyProviderFactory factory)
Extract an object using a built-in RESTEasy JAX-RS MessageBodyReader
|
static <T> T |
Hornetq.getEntity(ClientMessage msg,
Class<T> type,
Type genericType,
org.jboss.resteasy.spi.ResteasyProviderFactory factory) |
static <T> T |
Hornetq.getEntity(ClientMessage message,
org.jboss.resteasy.util.GenericType<T> type,
org.jboss.resteasy.spi.ResteasyProviderFactory factory)
Extract an object using a built-in RESTEasy JAX-RS MessageBodyReader
|
static String |
Hornetq.getHttpHeader(ClientMessage message,
String name)
Get an HTTP header value from a JMS Message
|
static boolean |
Hornetq.isHttpMessage(ClientMessage msg)
Was this HornetQ message generated from a REST call?
|
static void |
Hornetq.setEntity(ClientMessage message,
Serializable object)
Sets the message body to a serialized
byte array of the object.
|
static void |
Hornetq.setEntity(ClientMessage message,
Serializable object,
String contentType)
Sets a message property to be the Content-Type passed in.
|
static void |
Hornetq.setHttpHeader(ClientMessage message,
String name,
String value) |
Modifier and Type | Field and Description |
---|---|
protected ClientMessage |
ConsumedMessage.message |
Modifier and Type | Method and Description |
---|---|
protected ClientMessage |
PostMessage.createHornetQMessage(javax.ws.rs.core.HttpHeaders headers,
byte[] body,
boolean durable,
Long ttl,
Long expiration,
Integer priority,
ClientSession session) |
ClientMessage |
Acknowledgement.getMessage() |
protected ClientMessage |
QueueConsumer.receive(long timeoutSecs) |
protected ClientMessage |
AcknowledgedQueueConsumer.receive(long timeoutSecs) |
protected ClientMessage |
QueueConsumer.receiveFromConsumer(long timeoutSecs) |
protected ClientMessage |
AcknowledgedQueueConsumer.receiveFromConsumer(long timeoutSecs) |
Modifier and Type | Method and Description |
---|---|
static ConsumedMessage |
ConsumedMessage.createConsumedMessage(ClientMessage message) |
Constructor and Description |
---|
Acknowledgement(String ackToken,
ClientMessage message) |
ConsumedHttpMessage(ClientMessage message) |
ConsumedMessage(ClientMessage message) |
ConsumedObjectMessage(ClientMessage message) |
Modifier and Type | Method and Description |
---|---|
protected String |
UriStrategy.createUri(ClientMessage message) |
protected String |
UriTemplateStrategy.createUri(ClientMessage message) |
void |
PushConsumerMessageHandler.onMessage(ClientMessage clientMessage) |
boolean |
PushStrategy.push(ClientMessage message)
Return false if unable to connect.
|
boolean |
UriStrategy.push(ClientMessage message) |
boolean |
HornetQPushStrategy.push(ClientMessage message) |
Modifier and Type | Method and Description |
---|---|
static void |
HttpMessageHelper.buildMessage(ClientMessage message,
org.jboss.resteasy.client.ClientRequest request,
String contentType) |
static void |
HttpMessageHelper.buildMessage(ClientMessage message,
javax.ws.rs.core.Response.ResponseBuilder builder) |
static void |
HttpMessageHelper.writeHttpMessage(javax.ws.rs.core.HttpHeaders headers,
byte[] body,
ClientMessage message) |
Copyright © 2016 JBoss, a division of Red Hat. All rights reserved.