org.hornetq.core.client.impl

Interface ClientSessionInternal

All Superinterfaces:

ClientSession, XAResource

All Known Implementing Classes:

ClientSessionImpl, DelegatingSession

public interface ClientSessionInternal
extends ClientSession

A ClientSessionInternal

Author:

Tim Fox

Nested Class Summary

Nested classes/interfaces inherited from interface org.hornetq.api.core.client.ClientSession

ClientSession.BindingQuery, ClientSession.QueueQuery

Field Summary

Fields inherited from interface javax.transaction.xa.XAResource

TMENDRSCAN, TMFAIL, TMJOIN, TMNOFLAGS, TMONEPHASE, TMRESUME, TMSTARTRSCAN, TMSUCCESS, TMSUSPEND, XA_OK, XA_RDONLY

Method Summary

Methods

Modifier and Type	Method and Description
void	acknowledge(long consumerID, long messageID)
void	addConsumer(ClientConsumerInternal consumer)
void	addProducer(ClientProducerInternal producer)
void	cleanUp(boolean failingOver)
void	expire(long consumerID, long messageID)
void	forceDelivery(long consumerID, long sequence)
Channel	getChannel()
RemotingConnection	getConnection()
ClientProducerCredits	getCredits(SimpleString address, boolean anon)
int	getMinLargeMessageSize()
String	getName()
ClientProducerCreditManager	getProducerCreditManager()
ClientSessionFactoryInternal	getSessionFactory()
void	handleFailover(CoreRemotingConnection backupConnection)
void	handleReceiveContinuation(long consumerID, SessionReceiveContinuationMessage continuation)
void	handleReceiveLargeMessage(long consumerID, SessionReceiveLargeMessage message)
void	handleReceiveMessage(long consumerID, SessionReceiveMessage message)
void	handleReceiveProducerCredits(SimpleString address, int credits)
void	individualAcknowledge(long consumerID, long messageID)
boolean	isCacheLargeMessageClient()
boolean	isCompressLargeMessages()
void	preHandleFailover(CoreRemotingConnection connection)
void	removeConsumer(ClientConsumerInternal consumer)
void	removeProducer(ClientProducerInternal producer)
void	resetIfNeeded()
void	returnBlocking()
void	returnCredits(SimpleString address)
void	sendProducerCreditsMessage(int credits, SimpleString address)
void	setAddress(Message message, SimpleString address)
void	setForceNotSameRM(boolean force)
void	setPacketSize(int packetSize)
void	workDone()

Methods inherited from interface org.hornetq.api.core.client.ClientSession

addFailureListener, addMetaData, addMetaDataV1, 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, removeFailureListener, rollback, rollback, setSendAcknowledgementHandler, start, stop

Methods inherited from interface javax.transaction.xa.XAResource

commit, end, forget, getTransactionTimeout, isSameRM, prepare, recover, rollback, setTransactionTimeout, start

Method Detail

getName

String getName()

acknowledge

void acknowledge(long consumerID,
               long messageID)
                 throws HornetQException

Throws:

HornetQException

individualAcknowledge

void individualAcknowledge(long consumerID,
                         long messageID)
                           throws HornetQException

Throws:

HornetQException

isCacheLargeMessageClient

boolean isCacheLargeMessageClient()

getMinLargeMessageSize

int getMinLargeMessageSize()

isCompressLargeMessages

boolean isCompressLargeMessages()

expire

void expire(long consumerID,
          long messageID)
            throws HornetQException

Throws:

HornetQException

addConsumer

void addConsumer(ClientConsumerInternal consumer)

addProducer

void addProducer(ClientProducerInternal producer)

removeConsumer

void removeConsumer(ClientConsumerInternal consumer)
                    throws HornetQException

Throws:

HornetQException

removeProducer

void removeProducer(ClientProducerInternal producer)

handleReceiveMessage

void handleReceiveMessage(long consumerID,
                        SessionReceiveMessage message)
                          throws Exception

Throws:

Exception

handleReceiveLargeMessage

void handleReceiveLargeMessage(long consumerID,
                             SessionReceiveLargeMessage message)
                               throws Exception

Throws:

Exception

handleReceiveContinuation

void handleReceiveContinuation(long consumerID,
                             SessionReceiveContinuationMessage continuation)
                               throws Exception

Throws:

Exception

preHandleFailover

void preHandleFailover(CoreRemotingConnection connection)

handleFailover

void handleFailover(CoreRemotingConnection backupConnection)

getConnection

RemotingConnection getConnection()

getChannel

Channel getChannel()

cleanUp

void cleanUp(boolean failingOver)
             throws Exception

Throws:

Exception

returnBlocking

void returnBlocking()

setForceNotSameRM

void setForceNotSameRM(boolean force)

getSessionFactory

ClientSessionFactoryInternal getSessionFactory()

workDone

void workDone()

forceDelivery

void forceDelivery(long consumerID,
                 long sequence)
                   throws HornetQException

Throws:

HornetQException

sendProducerCreditsMessage

void sendProducerCreditsMessage(int credits,
                              SimpleString address)

getCredits

ClientProducerCredits getCredits(SimpleString address,
                               boolean anon)

returnCredits

void returnCredits(SimpleString address)

handleReceiveProducerCredits

void handleReceiveProducerCredits(SimpleString address,
                                int credits)

getProducerCreditManager

ClientProducerCreditManager getProducerCreditManager()

setAddress

void setAddress(Message message,
              SimpleString address)

setPacketSize

void setPacketSize(int packetSize)

resetIfNeeded

void resetIfNeeded()
                   throws HornetQException

Throws:

HornetQException