Package | Description |
---|---|
org.hornetq.api.core |
Core Messaging API.
|
org.hornetq.api.core.client |
Core Client Messaging API.
|
org.hornetq.spi.core.protocol | |
org.hornetq.spi.core.remoting |
Remoting SPI.
|
Modifier and Type | Method and Description |
---|---|
boolean |
Interceptor.intercept(org.hornetq.core.protocol.core.Packet packet,
RemotingConnection connection)
Intercepts a packet which is received before it is sent to the channel
|
Modifier and Type | Method and Description |
---|---|
void |
SessionFailureListener.beforeReconnect(HornetQException exception)
Notifies that a connection has failed due to the specified exception.
|
Modifier and Type | Method and Description |
---|---|
void |
ClientMessage.acknowledge()
Acknowledge reception of this message.
|
void |
ClientSession.addMetaData(java.lang.String key,
java.lang.String data)
Attach any metadata to the session.
|
void |
ClientSession.addMetaDataV1(java.lang.String key,
java.lang.String data)
Deprecated.
|
void |
ClientSession.addUniqueMetaData(java.lang.String key,
java.lang.String data)
Attach any metadata to the session.
|
ClientSession.BindingQuery |
ClientSession.bindingQuery(SimpleString address)
Queries information on a binding.
|
void |
ClientProducer.close()
Closes the ClientProducer.
|
void |
ClientConsumer.close()
Closes the consumer.
|
void |
ClientSession.close()
Closes the session.
|
void |
ClientSession.commit()
Commits the current transaction.
|
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.
|
ClientConsumer |
ClientSession.createConsumer(java.lang.String queueName)
Creates a ClientConsumer to consume messages from the queue with the given name.
|
ClientConsumer |
ClientSession.createConsumer(java.lang.String queueName,
boolean browseOnly)
Creates a ClientConsumer to consume or browse messages from the queue with the given name.
|
ClientConsumer |
ClientSession.createConsumer(java.lang.String queueName,
java.lang.String filter)
Creates a ClientConsumer to consume messages matching the filter from the queue with the given name.
|
ClientConsumer |
ClientSession.createConsumer(java.lang.String queueName,
java.lang.String filter,
boolean browseOnly)
Creates a ClientConsumer to consume or browse messages matching the filter from the queue with the given name.
|
ClientConsumer |
ClientSession.createConsumer(java.lang.String queueName,
java.lang.String 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()
Creates a producer with no default address.
|
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
|
ClientProducer |
ClientSession.createProducer(java.lang.String address)
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.createQueue(java.lang.String address,
java.lang.String queueName)
Creates a non-temporary queue non-durable queue.
|
void |
ClientSession.createQueue(java.lang.String address,
java.lang.String queueName,
boolean durable)
Creates a non-temporary queue.
|
void |
ClientSession.createQueue(java.lang.String address,
java.lang.String queueName,
java.lang.String filter,
boolean durable)
Creates a non-temporaryqueue.
|
ClientSession |
ClientSessionFactory.createSession()
Creates a non-transacted session.
|
ClientSession |
ClientSessionFactory.createSession(boolean autoCommitSends,
boolean autoCommitAcks)
Creates a session.
|
ClientSession |
ClientSessionFactory.createSession(boolean xa,
boolean autoCommitSends,
boolean autoCommitAcks)
Creates a session.
|
ClientSession |
ClientSessionFactory.createSession(boolean xa,
boolean autoCommitSends,
boolean autoCommitAcks,
boolean preAcknowledge)
Creates a session.
|
ClientSession |
ClientSessionFactory.createSession(boolean autoCommitSends,
boolean autoCommitAcks,
int ackBatchSize)
Creates a session.
|
ClientSession |
ClientSessionFactory.createSession(java.lang.String username,
java.lang.String password,
boolean xa,
boolean autoCommitSends,
boolean autoCommitAcks,
boolean preAcknowledge,
int ackBatchSize)
Creates an authenticated session.
|
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.createTemporaryQueue(java.lang.String address,
java.lang.String queueName)
Creates a temporary queue.
|
void |
ClientSession.createTemporaryQueue(java.lang.String address,
java.lang.String queueName,
java.lang.String filter)
Creates a temporary queue with a filter.
|
ClientSession |
ClientSessionFactory.createTransactedSession()
Creates a transacted session.
|
ClientSession |
ClientSessionFactory.createXASession()
Creates a session with XA transaction semantics.
|
void |
ClientSession.deleteQueue(SimpleString queueName)
Deletes the queue.
|
void |
ClientSession.deleteQueue(java.lang.String queueName)
Deletes the queue.
|
MessageHandler |
ClientConsumer.getMessageHandler()
Returns the MessageHandler associated to this consumer.
|
ClientSession.QueueQuery |
ClientSession.queueQuery(SimpleString queueName)
Queries information on a queue.
|
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.
|
void |
ClientSession.rollback()
Rolls back the current transaction.
|
void |
ClientSession.rollback(boolean considerLastMessageAsDelivered)
Rolls back the current transaction.
|
void |
ClientMessage.saveToOutputStream(java.io.OutputStream out)
Saves the content of the message to the OutputStream.
|
void |
ClientProducer.send(Message message)
Sends a message to an address.
|
void |
ClientProducer.send(SimpleString address,
Message message)
Sends a message to the specified address instead of the ClientProducer's address.
|
void |
ClientProducer.send(java.lang.String address,
Message message)
Sends a message to the specified address instead of the ClientProducer's address.
|
void |
ClientConsumer.setMessageHandler(MessageHandler handler)
Sets the MessageHandler for this consumer to consume messages asynchronously.
|
void |
ClientMessage.setOutputStream(java.io.OutputStream out)
Sets the OutputStream that will receive the content of a message received in a non blocking way.
|
void |
ClientSession.start()
Starts the session.
|
void |
ClientSession.stop()
Stops the session.
|
boolean |
ClientMessage.waitOutputStreamCompletion(long timeMilliseconds)
Wait the outputStream completion of the message.
|
Modifier and Type | Method and Description |
---|---|
void |
RemotingConnection.fail(HornetQException me)
called when the underlying connection fails.
|
Modifier and Type | Method and Description |
---|---|
void |
ConnectionLifeCycleListener.connectionException(java.lang.Object connectionID,
HornetQException me)
called when an error occurs on the connection.
|
Copyright © 2009 Red Hat Inc. All Rights Reserved.