org.jboss.messaging.core.client.impl
Class ClientConnectionImpl
java.lang.Object
org.jboss.messaging.core.client.impl.ClientConnectionImpl
- All Implemented Interfaces:
- ClientConnection, ClientConnectionInternal
public class ClientConnectionImpl
- extends java.lang.Object
- implements ClientConnectionInternal
The client-side Connection connectionFactory class.
- Version:
- $Revision: 3602 $
$Id: ClientConnectionImpl.java 3602 2008-01-21 17:48:32Z timfox $
- Author:
- Tim Fox, Ovidiu Feodorov, Clebert Suconic, Jeff Mesnil
Constructor Summary |
ClientConnectionImpl(long serverTargetID,
RemotingConnection connection,
int defaultConsumerWindowSize,
int defaultConsumerMaxRate,
int defaultProducerWindowSize,
int defaultProducerMaxRate,
boolean defaultBlockOnAcknowledge,
boolean defaultSendNonPersistentMessagesBlocking,
boolean defaultSendPersistentMessagesBlocking,
Version serverVersion)
|
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
ClientConnectionImpl
public ClientConnectionImpl(long serverTargetID,
RemotingConnection connection,
int defaultConsumerWindowSize,
int defaultConsumerMaxRate,
int defaultProducerWindowSize,
int defaultProducerMaxRate,
boolean defaultBlockOnAcknowledge,
boolean defaultSendNonPersistentMessagesBlocking,
boolean defaultSendPersistentMessagesBlocking,
Version serverVersion)
createClientSession
public ClientSession createClientSession(boolean xa,
boolean autoCommitSends,
boolean autoCommitAcks,
int ackBatchSize,
boolean blockOnAcknowledge,
boolean cacheProducers)
throws MessagingException
- Specified by:
createClientSession
in interface ClientConnection
- Throws:
MessagingException
createClientSession
public ClientSession createClientSession(boolean xa,
boolean autoCommitSends,
boolean autoCommitAcks,
int ackBatchSize)
throws MessagingException
- Specified by:
createClientSession
in interface ClientConnection
- Throws:
MessagingException
start
public void start()
throws MessagingException
- Specified by:
start
in interface ClientConnection
- Throws:
MessagingException
stop
public void stop()
throws MessagingException
- Specified by:
stop
in interface ClientConnection
- Throws:
MessagingException
setRemotingSessionListener
public void setRemotingSessionListener(RemotingSessionListener listener)
throws MessagingException
- Specified by:
setRemotingSessionListener
in interface ClientConnection
- Throws:
MessagingException
close
public void close()
throws MessagingException
- Specified by:
close
in interface ClientConnection
- Throws:
MessagingException
isClosed
public boolean isClosed()
- Specified by:
isClosed
in interface ClientConnection
getRemotingConnection
public RemotingConnection getRemotingConnection()
- Specified by:
getRemotingConnection
in interface ClientConnectionInternal
removeSession
public void removeSession(ClientSession session)
- Specified by:
removeSession
in interface ClientConnectionInternal
getServerVersion
public Version getServerVersion()
- Specified by:
getServerVersion
in interface ClientConnection
Copyright © 2006 JBoss Inc. All Rights Reserved.