/*

  * JBoss, the OpenSource J2EE webOS

  *

  * Distributable under LGPL license.

  * See terms of license at gnu.org.

  *

  */

 package org.jboss.resource.connectionmanager;

 import java.io.Serializable;

 import java.lang.SecurityException;

 import java.security.Principal;

 import java.util.ArrayList;

 import java.util.Collection;

 import java.util.Collections;

 import java.util.HashMap;

 import java.util.HashSet;

 import java.util.Iterator;

 import java.util.LinkedList;

 import java.util.List;

 import java.util.Map;

 import java.util.Set;

 import javax.management.ListenerNotFoundException;

 import javax.management.MBeanNotificationInfo;

 import javax.management.Notification;

 import javax.management.NotificationBroadcaster;

 import javax.management.NotificationBroadcasterSupport;

 import javax.management.NotificationFilter;

 import javax.management.NotificationListener;

 import javax.management.ObjectName;

 import javax.naming.InitialContext;

 import javax.resource.ResourceException;

 import javax.resource.ResourceException;

 import javax.resource.spi.ConnectionEventListener;

 import javax.resource.spi.ConnectionManager;

 import javax.resource.spi.ConnectionManager;

 import javax.resource.spi.ConnectionRequestInfo;

 import javax.resource.spi.ConnectionRequestInfo;

 import javax.resource.spi.ManagedConnection;

 import javax.resource.spi.ManagedConnectionFactory;

 import javax.resource.spi.ManagedConnectionFactory;

 import javax.security.auth.Subject;

 import javax.transaction.SystemException;

 import javax.transaction.Transaction;

 import javax.transaction.TransactionManager;

 import org.jboss.deployment.DeploymentException;

 import org.jboss.logging.Logger;

 import org.jboss.management.j2ee.JCAConnectionFactory;

 import org.jboss.management.j2ee.JCAManagedConnectionFactory;

 import org.jboss.security.SecurityAssociation;

 import org.jboss.security.SecurityDomain;

 import org.jboss.security.SubjectSecurityManager;

 import org.jboss.security.plugins.JaasSecurityManagerServiceMBean;

 import org.jboss.system.Registry;

 import org.jboss.system.ServiceMBean;

 import org.jboss.system.ServiceMBeanSupport;

 import org.jboss.util.jmx.JMXExceptionDecoder;

 import org.jboss.util.jmx.MBeanServerLocator;

 /**

  * The BaseConnectionManager2 is an abstract base class for JBoss ConnectionManager 

  * implementations.  It includes functionality to obtain managed connections from 

  * a ManagedConnectionPool mbean, find the Subject from a SubjectSecurityDomain, 

  * and interact with the CachedConnectionManager for connections held over 

  * transaction and method boundaries.  Important mbean references are to a 

  * ManagedConnectionPool supplier (typically a JBossManagedConnectionPool), and a 

  * RARDeployment representing the ManagedConnectionFactory.

  *

  *

  * Created: Wed Jan  2 12:16:09 2002

  *

  * @author <a href="mailto:d_jencks@users.sourceforge.net">David Jencks</a>

  * @author <a href="mailto:E.Guib@ceyoniq.com">Erwin Guib</a>

  * @version $$

  * @jmx:mbean name="jboss.jca:service=BaseConnectionManager"

  *            extends="org.jboss.system.ServiceMBean"

  */

    extends ServiceMBeanSupport 

    implements BaseConnectionManager2MBean, ConnectionCacheListener

 {

    /** Note that this copy has a trailing / unlike the original in 

     * JaasSecurityManagerService.

     */

    private static final String SECURITY_MGR_PATH = "java:/jaas/";

    public static final String STOPPING_NOTIFICATION = "jboss.jca.connectionmanagerstopping";

    private ObjectName managedConnectionPoolName;

    private ManagedConnectionPool poolingStrategy;

    private ObjectName managedConnectionFactoryName;

    private ManagedConnectionFactory mcf;

    protected String mcfJndiName;

    //private ObjectName securityDomainName; //for the future??

    private String securityDomainJndiName;

    private SubjectSecurityManager securityDomain;

    private ObjectName jaasSecurityManagerService;

    private ObjectName ccmName;

    private CachedConnectionManager ccm;

    // JSR-77 Managed Object

    ObjectName jcaConnectionFactory;

    ObjectName jcaManagedConnectionFactory;

    private final Map managedConnectionToListenerMap = Collections.synchronizedMap(new HashMap());

    protected final Logger log = Logger.getLogger(getClass());

    /**

     * Default BaseConnectionManager2 managed constructor for use by subclass mbeans.

     *

     */

    {

    }

    /**

     * Creates a new <code>BaseConnectionManager2</code> instance.

     * for TESTING ONLY! not a managed operation.

     * @param mcf a <code>ManagedConnectionFactory</code> value

     * @param ccm a <code>CachedConnectionManager</code> value

     * @param poolingStrategy a <code>ManagedConnectionPool</code> value

     */

                                  CachedConnectionManager ccm,

                                  ManagedConnectionPool poolingStrategy)

    {

    }

    /**

     * ManagedConnectionFactoryName holds the ObjectName of the mbean that 

     * represents the ManagedConnectionFactory.  Normally this can be an 

     * embedded mbean in a depends element rather than a separate mbean 

     * reference.

     * @return the ManagedConnectionFactoryName value.

     * @jmx:managed-attribute

     */

    {

    }

    /**

     * Set the ManagedConnectionFactoryName value.

     * @param newManagedConnectionFactoryName The new ManagedConnectionFactoryName value.

     * @jmx:managed-attribute

     */

    {

    }

    /**

     * The ManagedConnectionPool holds the ObjectName of the mbean representing

     * the pool for this connection manager.  Normally it will be an embedded

     * mbean in a depends tag rather than an ObjectName reference to the mbean.

     * @return the ManagedConnectionPool value.

     * @jmx:managed-attribute

     */

    {

    }

    /**

     * Set the ManagedConnectionPool value.

     * @param newManagedConnectionPool The new ManagedConnectionPool value.

     * @jmx:managed-attribute

     */

    {

    }

    /**

     * The CachecConnectionManager holds the ObjectName of the 

     * CachedConnectionManager mbean used by this ConnectionManager.

     * Normally this will be a depends tag with the ObjectName of the 

     * unique CachedConnectionManager for the server.

     *

     * @param ccmName an <code>ObjectName</code> value

     * @jmx:managed-attribute

     */

    {

    }

    /**

     * Describe <code>getCachedConnectionManager</code> method here.

     *

     * @return an <code>ObjectName</code> value

     * @jmx:managed-attribute

     */

    {

    }

    /**

     *  The SecurityDomainJndiName holds the jndi name of the security domain 

     * configured for the ManagedConnectionFactory this ConnectionManager 

     * manages.  It is normally of the form java:/jaas/firebirdRealm,

     * where firebirdRealm is the name found in auth.conf or equivalent file.

     *

     * @param name an <code>String</code> value

     * @jmx:managed-attribute

     */

    {

           && securityDomainJndiName.startsWith(SECURITY_MGR_PATH))

       {

       } // end of if ()

    }

    /**

     * Get the SecurityDomainJndiName value.

     * @return the SecurityDomainJndiName value.

     * @jmx:managed-attribute

     */

    {

    }

    /**

     * Get the JaasSecurityManagerService value.

     * @return the JaasSecurityManagerService value.

     * @jmx:managed-attribute

     */

    {

    }

    /**

     * Set the JaasSecurityManagerService value.

     * @param newJaasSecurityManagerService The new JaasSecurityManagerService value.

     * @jmx:managed-attribute

     */

    {

    }

    /**

     * ManagedConnectionFactory is an internal attribute that holds the 

     * ManagedConnectionFactory instance managed by this ConnectionManager.

     *

     * @return value of managedConnectionFactory

     *

     * @jmx.managed-attribute access="READ"

     */

    {

    }

    /**

     * Describe <code>getInstance</code> method here.

     *

     * @return a <code>BaseConnectionManager2</code> value

     *

     * @jmx.managed-attribute access="READ"

     */

    {

    }

    //ServiceMBeanSupport

    {

    }

    {

       // Create JSR-77 JCAConnectionFactory Managed Object

                                                          getServiceName().getKeyProperty("name") + 

                                                          "-" + 

                                                          getServiceName().getKeyProperty("service"),

                                                          getServiceName());

       // Create JSR-77 JCAManagedConnectionFactory Managed Object

                                                        getServer(),

                                                        managedConnectionFactoryName.getKeyProperty("name") +

                                                        "-" +

                                                        managedConnectionFactoryName.getKeyProperty("service"),

                                                        jcaConnectionFactory);

    }

    {

       {

       }

       catch (Exception e)

       {

       } // end of try-catch

       {

       } // end of if ()

       {

       } // end of if ()

       {

       } // end of if ()

       {

       } // end of if ()

       {

             managedConnectionPoolName, 

             "ManagedConnectionPool");

       }

       catch (Exception e)

       {

       } // end of try-catch

       {

       } // end of if ()

       {

             managedConnectionFactoryName, 

             "startManagedConnectionFactory",

             new Object[] {new ConnectionManagerProxy(this, this.serviceName)},

             new String[] {ConnectionManager.class.getName()});

          // save the JNDI Name for this connector

          // we need it later to check if the connector gets called from a

          // bean with shared or unshared resource-ref

                "JndiName");

       }

       catch (Exception e)

       {

       } // end of try-catch

    }

       throws Exception

    {

       //notify the login modules the mcf is going away, they need to look it up again later.

                                        getServiceName(),