|
||||||||||
PREV NEXT | FRAMES NO FRAMES |
Packages that use HornetQException | |
---|---|
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. |
Uses of HornetQException in org.hornetq.api.core |
---|
Methods in org.hornetq.api.core that throw HornetQException | |
---|---|
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 |
Uses of HornetQException in org.hornetq.api.core.client |
---|
Methods in org.hornetq.api.core.client with parameters of type HornetQException | |
---|---|
void |
SessionFailureListener.beforeReconnect(HornetQException exception)
Notifies that a connection has failed due to the specified exception. |
Methods in org.hornetq.api.core.client that throw HornetQException | |
---|---|
void |
ClientMessage.acknowledge()
Acknowledge reception of this message. |
void |
ClientSession.addMetaData(String key,
String data)
Attach any metadata to the session. |
void |
ClientSession.addMetaDataV1(String key,
String data)
Deprecated. Use ClientSession.addMetaData(String, String) |
void |
ClientSession.addUniqueMetaData(String key,
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 |
ClientSession.close()
Closes the session. |
void |
ClientConsumer.close()
Closes the consumer. |
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(String queueName)
Creates a ClientConsumer to consume messages from the queue with the given name. |
ClientConsumer |
ClientSession.createConsumer(String queueName,
boolean browseOnly)
Creates a ClientConsumer to consume or browse messages from the queue with the given name. |
ClientConsumer |
ClientSession.createConsumer(String queueName,
String filter)
Creates a ClientConsumer to consume messages matching the filter from the queue with the given name. |
ClientConsumer |
ClientSession.createConsumer(String queueName,
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(String queueName,
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(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(String address,
String queueName)
Creates a non-temporary queue non-durable queue. |
void |
ClientSession.createQueue(String address,
String queueName,
boolean durable)
Creates a non-temporary queue. |
void |
ClientSession.createQueue(String address,
String queueName,
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(String username,
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(String address,
String queueName)
Creates a temporary queue. |
void |
ClientSession.createTemporaryQueue(String address,
String queueName,
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(String queueName)
Deletes the queue. |
MessageHandler |
ClientConsumer.getMessageHandler()
Returns the MessageHandler associated to this consumer. |
void |
ClientMessage.individualAcknowledge()
Acknowledge reception of a single message. |
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(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(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(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. |
Uses of HornetQException in org.hornetq.spi.core.protocol |
---|
Methods in org.hornetq.spi.core.protocol with parameters of type HornetQException | |
---|---|
void |
RemotingConnection.fail(HornetQException me)
called when the underlying connection fails. |
Uses of HornetQException in org.hornetq.spi.core.remoting |
---|
Methods in org.hornetq.spi.core.remoting with parameters of type HornetQException | |
---|---|
void |
ConnectionLifeCycleListener.connectionException(Object connectionID,
HornetQException me)
called when an error occurs on the connection. |
|
||||||||||
PREV NEXT | FRAMES NO FRAMES |