org.jboss.messaging.core.client.impl
Class ClientConnectionImpl

java.lang.Object
  extended by 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)
           
 
Method Summary
 void close()
           
 ClientSession createClientSession(boolean xa, boolean autoCommitSends, boolean autoCommitAcks, int ackBatchSize)
           
 ClientSession createClientSession(boolean xa, boolean autoCommitSends, boolean autoCommitAcks, int ackBatchSize, boolean blockOnAcknowledge, boolean cacheProducers)
           
 RemotingConnection getRemotingConnection()
           
 Version getServerVersion()
           
 boolean isClosed()
           
 void removeSession(ClientSession session)
           
 void setRemotingSessionListener(RemotingSessionListener listener)
           
 void start()
           
 void stop()
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

ClientConnectionImpl

public ClientConnectionImpl(long serverTargetID,
                            RemotingConnection connection,
                            int defaultConsumerWindowSize,
                            int defaultConsumerMaxRate,
                            int defaultProducerWindowSize,
                            int defaultProducerMaxRate,
                            boolean defaultBlockOnAcknowledge,
                            boolean defaultSendNonPersistentMessagesBlocking,
                            boolean defaultSendPersistentMessagesBlocking,
                            Version serverVersion)
Method Detail

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.