public interface ClientSessionInternal extends ClientSession
ClientSession.AddressQuery, ClientSession.QueueQuery
JMS_SESSION_IDENTIFIER_PROPERTY
TMENDRSCAN, TMFAIL, TMJOIN, TMNOFLAGS, TMONEPHASE, TMRESUME, TMSTARTRSCAN, TMSUCCESS, TMSUSPEND, XA_OK, XA_RDONLY
addFailoverListener, addFailureListener, addMetaData, addressQuery, addUniqueMetaData, close, commit, commit, createAddress, createAddress, createAddress, createConsumer, createConsumer, createConsumer, createConsumer, createConsumer, createConsumer, createConsumer, createConsumer, createConsumer, createConsumer, createConsumer, createConsumer, createMessage, createMessage, createMessage, createProducer, createProducer, createProducer, createProducer, createQueue, createQueue, createQueue, createQueue, createQueue, createQueue, createQueue, createQueue, createQueue, createQueue, createQueue, createQueue, createQueue, createQueue, createQueue, createQueue, createQueue, createQueue, createQueue, createQueue, createQueue, createSharedQueue, createSharedQueue, createSharedQueue, createSharedQueue, createSharedQueue, createSharedQueue, createTemporaryQueue, createTemporaryQueue, createTemporaryQueue, createTemporaryQueue, createTemporaryQueue, createTemporaryQueue, createTemporaryQueue, createTemporaryQueue, createTemporaryQueue, createTemporaryQueue, deleteQueue, deleteQueue, getSessionFactory, 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(ClientConsumer consumer, Message message) throws ActiveMQException
ActiveMQException
void individualAcknowledge(ClientConsumer consumer, Message message) throws ActiveMQException
ActiveMQException
boolean isCacheLargeMessageClient()
int getMinLargeMessageSize()
boolean isCompressLargeMessages()
void expire(ClientConsumer consumer, Message message) throws ActiveMQException
ActiveMQException
void addConsumer(ClientConsumerInternal consumer)
void addProducer(ClientProducerInternal producer)
void removeConsumer(ClientConsumerInternal consumer) throws ActiveMQException
ActiveMQException
void removeProducer(ClientProducerInternal producer)
void handleReceiveMessage(ConsumerContext consumerID, ClientMessageInternal message) throws Exception
Exception
void handleReceiveLargeMessage(ConsumerContext consumerID, ClientLargeMessageInternal clientLargeMessage, long largeMessageSize) throws Exception
Exception
void handleReceiveContinuation(ConsumerContext consumerID, byte[] chunk, int flowControlSize, boolean isContinues) throws Exception
Exception
void handleConsumerDisconnect(ConsumerContext consumerContext) throws ActiveMQException
ActiveMQException
void preHandleFailover(RemotingConnection connection)
boolean handleFailover(RemotingConnection backupConnection, ActiveMQException cause)
RemotingConnection getConnection()
void cleanUp(boolean failingOver) throws ActiveMQException
ActiveMQException
void setForceNotSameRM(boolean force)
void workDone()
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 ActiveMQException
ActiveMQException
void markRollbackOnly()
void startCall()
void endCall()
startCall()
void setStopSignal()
boolean isConfirmationWindowEnabled()
void scheduleConfirmation(SendAcknowledgementHandler handler, Message message)
handler
- boolean isClosing()
String getNodeId()
boolean isWritable(ReadyListener callback)
SessionContext getSessionContext()
Copyright © 2019 JBoss by Red Hat. All rights reserved.