Package | Description |
---|---|
org.hornetq.api.core |
Core Messaging API.
|
org.hornetq.api.core.client |
Core Client Messaging API.
|
org.hornetq.api.core.management |
Management API for HornetQ servers and its Core resources.
|
org.hornetq.spi.core.protocol |
Modifier and Type | Field and Description |
---|---|
static SimpleString |
FilterConstants.DURABLE
Value for the Durable header when the message is durable.
|
static SimpleString |
Message.HDR_ACTUAL_EXPIRY_TIME |
static SimpleString |
Message.HDR_DUPLICATE_DETECTION_ID |
static SimpleString |
Message.HDR_GROUP_ID |
static SimpleString |
Message.HDR_LARGE_BODY_SIZE |
static SimpleString |
Message.HDR_LARGE_COMPRESSED |
static SimpleString |
Message.HDR_LAST_VALUE_NAME |
static SimpleString |
Message.HDR_ORIG_MESSAGE_ID |
static SimpleString |
Message.HDR_ORIGINAL_ADDRESS |
static SimpleString |
Message.HDR_SCHEDULED_DELIVERY_TIME |
static SimpleString |
FilterConstants.HORNETQ_DURABLE
Name of the HornetQ Message durable header.
|
static SimpleString |
FilterConstants.HORNETQ_EXPIRATION
Name of the HornetQ Message expiration header.
|
static SimpleString |
FilterConstants.HORNETQ_PREFIX
All HornetQ headers are prepended by this prefix.
|
static SimpleString |
FilterConstants.HORNETQ_PRIORITY
Name of the HornetQ Message priority header.
|
static SimpleString |
FilterConstants.HORNETQ_SIZE
Name of the HornetQ Message size header.
|
static SimpleString |
FilterConstants.HORNETQ_TIMESTAMP
Name of the HornetQ Message timestamp header.
|
static SimpleString |
FilterConstants.HORNETQ_USERID
Name of the HornetQ UserID header.
|
static SimpleString |
FilterConstants.NON_DURABLE
Value for the Durable header when the message is non-durable.
|
Modifier and Type | Method and Description |
---|---|
SimpleString |
SimpleString.concat(char c)
Concatenates a SimpleString and a char
|
SimpleString |
SimpleString.concat(SimpleString toAdd)
Concatenates 2 SimpleString's
|
SimpleString |
SimpleString.concat(java.lang.String toAdd)
Concatenates a SimpleString and a String
|
SimpleString |
Message.getAddress()
Returns the address this message is sent to.
|
SimpleString |
Message.getSimpleStringProperty(SimpleString key)
Returns the property corresponding to the specified key as a SimpleString.
|
SimpleString |
Message.getSimpleStringProperty(java.lang.String key) |
SimpleString |
HornetQBuffer.readNullableSimpleString()
Gets a SimpleString (potentially
null ) at the current readerIndex |
SimpleString |
HornetQBuffer.readSimpleString()
Gets a non-null SimpleString at the current
readerIndex |
SimpleString[] |
SimpleString.split(char delim)
Splits this SimpleString into an array of SimpleString using the char param as the delimiter.
|
static SimpleString |
SimpleString.toSimpleString(java.lang.String string)
Returns a SimpleString constructed from the
string parameter. |
Modifier and Type | Method and Description |
---|---|
java.util.Set<SimpleString> |
Message.getPropertyNames()
Returns all the names of the properties for this message.
|
Modifier and Type | Method and Description |
---|---|
int |
SimpleString.compareTo(SimpleString o) |
SimpleString |
SimpleString.concat(SimpleString toAdd)
Concatenates 2 SimpleString's
|
boolean |
Message.containsProperty(SimpleString key)
Returns
true if this message contains a property with the given key, false else. |
java.lang.Boolean |
Message.getBooleanProperty(SimpleString key)
Returns the property corresponding to the specified key as a Boolean.
|
java.lang.Byte |
Message.getByteProperty(SimpleString key)
Returns the property corresponding to the specified key as a Byte.
|
byte[] |
Message.getBytesProperty(SimpleString key)
Returns the property corresponding to the specified key as a byte[].
|
java.lang.Double |
Message.getDoubleProperty(SimpleString key)
Returns the property corresponding to the specified key as a Double.
|
java.lang.Float |
Message.getFloatProperty(SimpleString key)
Returns the property corresponding to the specified key as a Float.
|
java.lang.Integer |
Message.getIntProperty(SimpleString key)
Returns the property corresponding to the specified key as an Integer.
|
java.lang.Long |
Message.getLongProperty(SimpleString key)
Returns the property corresponding to the specified key as a Long.
|
java.lang.Object |
Message.getObjectProperty(SimpleString key)
Returns the property corresponding to the specified key
|
java.lang.Short |
Message.getShortProperty(SimpleString key)
Returns the property corresponding to the specified key as a Short.
|
SimpleString |
Message.getSimpleStringProperty(SimpleString key)
Returns the property corresponding to the specified key as a SimpleString.
|
java.lang.String |
Message.getStringProperty(SimpleString key)
Returns the property corresponding to the specified key as a String.
|
void |
Message.putBooleanProperty(SimpleString key,
boolean value)
Puts a boolean property in this message.
|
void |
Message.putByteProperty(SimpleString key,
byte value)
Puts a byte property in this message.
|
void |
Message.putBytesProperty(SimpleString key,
byte[] value)
Puts a byte[] property in this message.
|
void |
Message.putDoubleProperty(SimpleString key,
double value)
Puts a double property in this message.
|
void |
Message.putFloatProperty(SimpleString key,
float value)
Puts a float property in this message.
|
void |
Message.putIntProperty(SimpleString key,
int value)
Puts a int property in this message.
|
void |
Message.putLongProperty(SimpleString key,
long value)
Puts a long property in this message.
|
void |
Message.putObjectProperty(SimpleString key,
java.lang.Object value)
Puts an Object property in this message.
|
void |
Message.putShortProperty(SimpleString key,
short value)
Puts a short property in this message.
|
void |
Message.putStringProperty(SimpleString key,
SimpleString value)
Puts a SimpleString property in this message.
|
java.lang.Object |
Message.removeProperty(SimpleString key)
Removes the property corresponding to the specified key.
|
void |
Message.setAddress(SimpleString address)
Sets the address to send this message to.
|
static int |
SimpleString.sizeofNullableString(SimpleString str)
returns the size of a SimpleString which could be null
|
static int |
SimpleString.sizeofString(SimpleString str)
returns the size of a SimpleString
|
boolean |
SimpleString.startsWith(SimpleString other)
returns true if the SimpleString parameter starts with the same data as this one.
|
void |
HornetQBuffer.writeNullableSimpleString(SimpleString val)
Sets the specified SimpleString (potentially
null ) at the current writerIndex |
void |
HornetQBuffer.writeSimpleString(SimpleString val)
Sets the specified non-null SimpleString at the current
writerIndex |
Modifier and Type | Method and Description |
---|---|
SimpleString |
ClientProducer.getAddress()
Returns the address where messages will be sent.
|
SimpleString |
ClientSession.QueueQuery.getAddress()
Returns the address that the queue is bound to.
|
SimpleString |
ClientSession.QueueQuery.getFilterString()
Returns the queue's filter string (or
null if the queue has no filter). |
Modifier and Type | Method and Description |
---|---|
java.util.List<SimpleString> |
ClientSession.BindingQuery.getQueueNames()
Returns the names of the queues bound to the binding.
|
Modifier and Type | Method and Description |
---|---|
ClientSession.BindingQuery |
ClientSession.bindingQuery(SimpleString address)
Queries information on a binding.
|
ClientConsumer |
ClientSession.createConsumer(SimpleString queueName)
Creates a ClientConsumer to consume message from the queue with the given name.
|
ClientConsumer |
ClientSession.createConsumer(SimpleString queueName,
boolean browseOnly)
Creates a ClientConsumer to consume or browse messages from the queue with the given name.
|
ClientConsumer |
ClientSession.createConsumer(SimpleString queueName,
SimpleString filter)
Creates a ClientConsumer to consume messages matching the filter from the queue with the given name.
|
ClientConsumer |
ClientSession.createConsumer(SimpleString queueName,
SimpleString filter,
boolean browseOnly)
Creates a ClientConsumer to consume or browse messages matching the filter from the queue with the given name.
|
ClientConsumer |
ClientSession.createConsumer(SimpleString queueName,
SimpleString filter,
int windowSize,
int maxRate,
boolean browseOnly)
Creates a ClientConsumer to consume or browse messages matching the filter from the queue with the given name.
|
ClientProducer |
ClientSession.createProducer(SimpleString address)
Creates a producer which sends messages to the given address
|
ClientProducer |
ClientSession.createProducer(SimpleString address,
int rate)
Creates a producer which sends messages to the given address
|
void |
ClientSession.createQueue(SimpleString address,
SimpleString queueName)
Creates a non-temporary queue non-durable queue.
|
void |
ClientSession.createQueue(SimpleString address,
SimpleString queueName,
boolean durable)
Creates a non-temporary queue.
|
void |
ClientSession.createQueue(SimpleString address,
SimpleString queueName,
SimpleString filter,
boolean durable)
Creates a non-temporary queue.
|
void |
ClientSession.createTemporaryQueue(SimpleString address,
SimpleString queueName)
Creates a temporary queue.
|
void |
ClientSession.createTemporaryQueue(SimpleString address,
SimpleString queueName,
SimpleString filter)
Creates a temporary queue with a filter.
|
void |
ClientSession.deleteQueue(SimpleString queueName)
Deletes the queue.
|
ClientSession.QueueQuery |
ClientSession.queueQuery(SimpleString queueName)
Queries information on a queue.
|
void |
ClientProducer.send(SimpleString address,
Message message)
Sends a message to the specified address instead of the ClientProducer's address.
|
Constructor and Description |
---|
ClientRequestor(ClientSession session,
SimpleString requestAddress)
Constructor for the ClientRequestor.
|
Modifier and Type | Method and Description |
---|---|
javax.management.ObjectName |
ObjectNameBuilder.getAddressObjectName(SimpleString address)
Returns the ObjectName used by AddressControl.
|
javax.management.ObjectName |
ObjectNameBuilder.getQueueObjectName(SimpleString address,
SimpleString name)
Returns the ObjectName used by QueueControl.
|
Modifier and Type | Method and Description |
---|---|
void |
SessionCallback.sendProducerCreditsMessage(int credits,
SimpleString address) |
Copyright © 2009 Red Hat Inc. All Rights Reserved.