org.jboss.messaging.core.impl.clusterconnection
Class ClusterConnectionManager.ConnectionInfo

java.lang.Object
  extended by org.jboss.messaging.core.impl.clusterconnection.ClusterConnectionManager.ConnectionInfo
Enclosing class:
ClusterConnectionManager

public static class ClusterConnectionManager.ConnectionInfo
extends java.lang.Object


Field Summary
protected  JBossConnection connection
           
protected  JBossConnectionFactory connectionFactory
           
protected  boolean isLocal
           
protected  Session session
           
protected  boolean started
           
protected  java.util.Map suckers
           
 
Constructor Summary
ClusterConnectionManager.ConnectionInfo(JBossConnectionFactory connectionFactory, java.lang.String suckerUser, java.lang.String suckerPassword, boolean isLocal, int maxRetry, int retryInterval)
           
 
Method Summary
protected  void addSucker(MessageSucker sucker)
           
protected  void cleanupConnection()
           
protected  void close()
           
protected  boolean hasSucker(java.lang.String queueName)
           
 void onException(JMSException e)
           
protected  int retryConnection()
           
protected  void start()
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

connectionFactory

protected JBossConnectionFactory connectionFactory

connection

protected JBossConnection connection

session

protected Session session

suckers

protected java.util.Map suckers

started

protected boolean started

isLocal

protected boolean isLocal
Constructor Detail

ClusterConnectionManager.ConnectionInfo

public ClusterConnectionManager.ConnectionInfo(JBossConnectionFactory connectionFactory,
                                               java.lang.String suckerUser,
                                               java.lang.String suckerPassword,
                                               boolean isLocal,
                                               int maxRetry,
                                               int retryInterval)
                                        throws java.lang.Exception
Throws:
java.lang.Exception
Method Detail

start

protected void start()
              throws java.lang.Exception
Throws:
java.lang.Exception

close

protected void close()

hasSucker

protected boolean hasSucker(java.lang.String queueName)

addSucker

protected void addSucker(MessageSucker sucker)

onException

public void onException(JMSException e)

cleanupConnection

protected void cleanupConnection()

retryConnection

protected int retryConnection()


Copyright © 2006 JBoss Inc. All Rights Reserved.