org.jboss.messaging.core.client.impl
Interface ClientSessionInternal
- All Superinterfaces:
- ClientSession, javax.transaction.xa.XAResource
- All Known Implementing Classes:
- ClientSessionImpl
public interface ClientSessionInternal
- extends ClientSession
A ClientSessionInternal
- Author:
- Tim Fox
Fields inherited from interface javax.transaction.xa.XAResource |
TMENDRSCAN, TMFAIL, TMJOIN, TMNOFLAGS, TMONEPHASE, TMRESUME, TMSTARTRSCAN, TMSUCCESS, TMSUSPEND, XA_OK, XA_RDONLY |
Methods inherited from interface org.jboss.messaging.core.client.ClientSession |
addFailureListener, bindingQuery, close, commit, createClientMessage, createClientMessage, createClientMessage, createConsumer, createConsumer, createConsumer, createConsumer, createConsumer, createConsumer, createConsumer, createConsumer, createProducer, createProducer, createProducer, createProducer, createProducer, createProducer, createProducer, createQueue, createQueue, createQueue, createQueue, createTemporaryQueue, createTemporaryQueue, createTemporaryQueue, createTemporaryQueue, deleteQueue, deleteQueue, getVersion, getXAResource, isAutoCommitAcks, isAutoCommitSends, isBlockOnAcknowledge, isClosed, 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 |
getName
java.lang.String getName()
acknowledge
void acknowledge(long consumerID,
long messageID)
throws MessagingException
- Throws:
MessagingException
createBuffer
MessagingBuffer createBuffer(int size)
expire
void expire(long consumerID,
long messageID)
throws MessagingException
- Throws:
MessagingException
addConsumer
void addConsumer(ClientConsumerInternal consumer)
addProducer
void addProducer(ClientProducerInternal producer)
removeConsumer
void removeConsumer(ClientConsumerInternal consumer)
throws MessagingException
- Throws:
MessagingException
removeProducer
void removeProducer(ClientProducerInternal producer)
handleReceiveMessage
void handleReceiveMessage(long consumerID,
SessionReceiveMessage message)
throws java.lang.Exception
- Throws:
java.lang.Exception
handleReceiveLargeMessage
void handleReceiveLargeMessage(long consumerID,
SessionReceiveMessage message)
throws java.lang.Exception
- Throws:
java.lang.Exception
handleReceiveContinuation
void handleReceiveContinuation(long consumerID,
SessionReceiveContinuationMessage continuation)
throws java.lang.Exception
- Throws:
java.lang.Exception
handleFailover
boolean handleFailover(RemotingConnection backupConnection)
getConnection
RemotingConnection getConnection()
cleanUp
void cleanUp()
throws java.lang.Exception
- Throws:
java.lang.Exception
returnBlocking
void returnBlocking()
Copyright © 2006 JBoss Inc. All Rights Reserved.