Methods in org.jboss.messaging.core.client that throw MessagingException |
void |
ClientSession.acknowledge()
|
void |
ClientSession.addDestination(SimpleString address,
boolean temporary)
|
SessionBindingQueryResponseMessage |
ClientSession.bindingQuery(SimpleString address)
|
void |
ClientConsumer.close()
|
void |
ClientConnection.close()
|
void |
ClientSession.close()
|
void |
ClientProducer.close()
|
void |
ClientBrowser.close()
|
void |
ClientSession.commit()
|
ClientBrowser |
ClientSession.createBrowser(SimpleString queueName)
|
ClientBrowser |
ClientSession.createBrowser(SimpleString queueName,
SimpleString filterString)
|
ClientSession |
ClientConnection.createClientSession(boolean xa,
boolean autoCommitSends,
boolean autoCommitAcks,
int ackBatchSize)
|
ClientSession |
ClientConnection.createClientSession(boolean xa,
boolean autoCommitSends,
boolean autoCommitAcks,
int ackBatchSize,
boolean blockOnAcknowledge,
boolean cacheProducers)
|
ClientConnection |
ClientConnectionFactory.createConnection()
|
ClientConnection |
ClientConnectionFactory.createConnection(java.lang.String username,
java.lang.String password)
|
ClientConsumer |
ClientSession.createConsumer(SimpleString queueName)
|
ClientConsumer |
ClientSession.createConsumer(SimpleString queueName,
SimpleString filterString,
boolean noLocal,
boolean autoDeleteQueue,
boolean direct)
|
ClientProducer |
ClientSession.createProducer(SimpleString address)
|
ClientProducer |
ClientSession.createProducerWithWindowSize(SimpleString address,
int windowSize)
|
void |
ClientSession.createQueue(SimpleString address,
SimpleString queueName,
SimpleString filterString,
boolean durable,
boolean temporary)
|
ClientProducer |
ClientSession.createRateLimitedProducer(SimpleString address,
int rate)
|
void |
ClientSession.deleteQueue(SimpleString queueName)
|
MessageHandler |
ClientConsumer.getMessageHandler()
|
boolean |
ClientBrowser.hasNextMessage()
|
ClientMessage |
ClientBrowser.nextMessage()
|
SessionQueueQueryResponseMessage |
ClientSession.queueQuery(SimpleString queueName)
|
ClientMessage |
ClientConsumer.receive()
|
ClientMessage |
ClientConsumer.receive(long timeout)
|
ClientMessage |
ClientConsumer.receiveImmediate()
|
void |
ClientSession.removeDestination(SimpleString address,
boolean temporary)
|
void |
ClientBrowser.reset()
|
void |
ClientSession.rollback()
|
void |
ClientProducer.send(ClientMessage message)
|
void |
ClientProducer.send(SimpleString address,
ClientMessage message)
|
void |
ClientConsumer.setMessageHandler(MessageHandler handler)
|
void |
ClientConnection.setRemotingSessionListener(RemotingSessionListener listener)
|
void |
ClientConnection.start()
|
void |
ClientConnection.stop()
|
Methods in org.jboss.messaging.core.client.impl that throw MessagingException |
void |
ClientSessionImpl.acknowledge()
|
void |
ClientSessionImpl.addDestination(SimpleString address,
boolean temporary)
|
SessionBindingQueryResponseMessage |
ClientSessionImpl.bindingQuery(SimpleString address)
|
void |
ClientSessionImpl.close()
|
void |
ClientProducerImpl.close()
|
void |
ClientBrowserImpl.close()
|
void |
ClientConnectionImpl.close()
|
void |
ClientConsumerImpl.close()
|
void |
ClientSessionImpl.commit()
|
ClientBrowser |
ClientSessionImpl.createBrowser(SimpleString queueName)
|
ClientBrowser |
ClientSessionImpl.createBrowser(SimpleString queueName,
SimpleString filterString)
|
ClientSession |
ClientConnectionImpl.createClientSession(boolean xa,
boolean autoCommitSends,
boolean autoCommitAcks,
int ackBatchSize)
|
ClientSession |
ClientConnectionImpl.createClientSession(boolean xa,
boolean autoCommitSends,
boolean autoCommitAcks,
int ackBatchSize,
boolean blockOnAcknowledge,
boolean cacheProducers)
|
ClientConnection |
ClientConnectionFactoryImpl.createConnection()
|
ClientConnection |
ClientConnectionFactoryImpl.createConnection(java.lang.String username,
java.lang.String password)
|
ClientConsumer |
ClientSessionImpl.createConsumer(SimpleString queueName)
|
ClientConsumer |
ClientSessionImpl.createConsumer(SimpleString queueName,
SimpleString filterString,
boolean noLocal,
boolean autoDeleteQueue,
boolean direct)
|
ClientProducer |
ClientSessionImpl.createProducer(SimpleString address)
|
ClientProducer |
ClientSessionImpl.createProducer(SimpleString address,
int windowSize,
int maxRate)
|
ClientProducer |
ClientSessionImpl.createProducerWithWindowSize(SimpleString address,
int windowSize)
|
void |
ClientSessionImpl.createQueue(SimpleString address,
SimpleString queueName,
SimpleString filterString,
boolean durable,
boolean temporary)
|
ClientProducer |
ClientSessionImpl.createRateLimitedProducer(SimpleString address,
int rate)
|
void |
ClientSessionImpl.deleteQueue(SimpleString queueName)
|
MessageHandler |
ClientConsumerImpl.getMessageHandler()
|
boolean |
ClientBrowserImpl.hasNextMessage()
|
ClientMessage |
ClientBrowserImpl.nextMessage()
|
SessionQueueQueryResponseMessage |
ClientSessionImpl.queueQuery(SimpleString queueName)
|
ClientMessage |
ClientConsumerImpl.receive()
|
ClientMessage |
ClientConsumerImpl.receive(long timeout)
|
ClientMessage |
ClientConsumerImpl.receiveImmediate()
|
void |
ClientConsumerInternal.recover(long lastDeliveryID)
|
void |
ClientSessionImpl.removeConsumer(ClientConsumerInternal consumer)
|
void |
ClientSessionInternal.removeConsumer(ClientConsumerInternal consumer)
|
void |
ClientSessionImpl.removeDestination(SimpleString address,
boolean temporary)
|
void |
ClientBrowserImpl.reset()
|
void |
ClientSessionImpl.rollback()
|
void |
ClientProducerImpl.send(ClientMessage msg)
|
void |
ClientProducerImpl.send(SimpleString address,
ClientMessage msg)
|
Packet |
RemotingConnectionImpl.sendBlocking(long targetID,
long executorID,
Packet packet)
send the packet and block until a response is received (oneWay is set to false ) |
Packet |
RemotingConnection.sendBlocking(long targetID,
long executorID,
Packet packet)
|
void |
RemotingConnectionImpl.sendOneWay(long targetID,
long executorID,
Packet packet)
|
void |
RemotingConnection.sendOneWay(long targetID,
long executorID,
Packet packet)
|
void |
ClientConsumerImpl.setMessageHandler(MessageHandler handler)
|
void |
ClientConnectionImpl.setRemotingSessionListener(RemotingSessionListener listener)
|
void |
ClientConnectionImpl.start()
|
void |
ClientConnectionImpl.stop()
|