org.hornetq.core.client.impl
public interface ClientSessionInternal extends ClientSession
ClientSession.BindingQuery, ClientSession.QueueQuery
TMENDRSCAN, TMFAIL, TMJOIN, TMNOFLAGS, TMONEPHASE, TMRESUME, TMSTARTRSCAN, TMSUCCESS, TMSUSPEND, XA_OK, XA_RDONLY
addFailoverListener, addFailureListener, addMetaData, addUniqueMetaData, bindingQuery, close, commit, createConsumer, createConsumer, createConsumer, createConsumer, createConsumer, createConsumer, createConsumer, createConsumer, createConsumer, createConsumer, createMessage, createMessage, createMessage, createProducer, createProducer, createProducer, createProducer, createQueue, createQueue, createQueue, createQueue, createQueue, createQueue, createTemporaryQueue, createTemporaryQueue, createTemporaryQueue, createTemporaryQueue, deleteQueue, deleteQueue, getVersion, getXAResource, isAutoCommitAcks, isAutoCommitSends, isBlockOnAcknowledge, isClosed, isRollbackOnly, isXA, queueQuery, removeFailoverListener, removeFailureListener, rollback, rollback, setSendAcknowledgementHandler, start, stop
commit, end, forget, getTransactionTimeout, isSameRM, prepare, recover, rollback, setTransactionTimeout, start
String getName()
void acknowledge(long consumerID, long messageID) throws HornetQException
HornetQException
void individualAcknowledge(long consumerID, long messageID) throws HornetQException
HornetQException
boolean isCacheLargeMessageClient()
int getMinLargeMessageSize()
boolean isCompressLargeMessages()
void expire(long consumerID, long messageID) throws HornetQException
HornetQException
void addConsumer(ClientConsumerInternal consumer)
void addProducer(ClientProducerInternal producer)
void removeConsumer(ClientConsumerInternal consumer) throws HornetQException
HornetQException
void removeProducer(ClientProducerInternal producer)
void handleReceiveMessage(long consumerID, SessionReceiveMessage message) throws Exception
Exception
void handleReceiveLargeMessage(long consumerID, SessionReceiveLargeMessage message) throws Exception
Exception
void handleReceiveContinuation(long consumerID, SessionReceiveContinuationMessage continuation) throws Exception
Exception
void preHandleFailover(CoreRemotingConnection connection)
void handleFailover(CoreRemotingConnection backupConnection, HornetQException cause)
RemotingConnection getConnection()
Channel getChannel()
void cleanUp(boolean failingOver) throws HornetQException
HornetQException
void returnBlocking()
void setForceNotSameRM(boolean force)
ClientSessionFactoryInternal getSessionFactory()
void workDone()
void forceDelivery(long consumerID, long sequence) throws HornetQException
HornetQException
void sendProducerCreditsMessage(int credits, SimpleString address)
ClientProducerCredits getCredits(SimpleString address, boolean anon)
void returnCredits(SimpleString address)
void handleReceiveProducerCredits(SimpleString address, int credits)
void handleReceiveProducerFailCredits(SimpleString address, int credits)
ClientProducerCreditManager getProducerCreditManager()
void setAddress(Message message, SimpleString address)
void setPacketSize(int packetSize)
void resetIfNeeded() throws HornetQException
HornetQException
void startCall()
void endCall()
startCall()
void setStopSignal()
Copyright © 2015 JBoss, a division of Red Hat. All Rights Reserved.