/*
* JBoss, Home of Professional Open Source.
* Copyright 2006, Red Hat Middleware LLC, and individual contributors
* as indicated by the @author tags. See the copyright.txt file in the
* distribution for a full listing of individual contributors.
*
* This is free software; you can redistribute it and/or modify it
* under the terms of the GNU Lesser General Public License as
* published by the Free Software Foundation; either version 2.1 of
* the License, or (at your option) any later version.
*
* This software is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
* Lesser General Public License for more details.
*
* You should have received a copy of the GNU Lesser General Public
* License along with this software; if not, write to the Free
* Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
* 02110-1301 USA, or see the FSF site: http://www.fsf.org.
*/
package org.jboss.ejb3;
import javassist.bytecode.AnnotationsAttribute;
import javassist.bytecode.ClassFile;
import javassist.bytecode.annotation.Annotation;
import javassist.bytecode.annotation.StringMemberValue;
import org.jboss.annotation.ejb.ResourceAdapter;
import org.jboss.aop.AspectManager;
import org.jboss.aop.DomainDefinition;
import org.jboss.ejb3.metamodel.EnterpriseBean;
import org.jboss.ejb3.metamodel.MessageDrivenBean;
import org.jboss.ejb3.mdb.ConsumerContainer;
import org.jboss.ejb3.mdb.MDB;
import org.jboss.ejb3.mdb.inflow.JBossMessageEndpointFactory;
import org.jboss.ejb3.service.ServiceContainer;
import org.jboss.ejb3.stateful.StatefulContainer;
import org.jboss.ejb3.stateless.StatelessContainer;
import org.jboss.logging.Logger;
import javax.ejb.TransactionAttribute;
import javax.ejb.TransactionAttributeType;
import java.util.ArrayList;
import java.util.Hashtable;
import java.util.List;
/**
* @author <a href="mailto:bdecoste@jboss.com">William DeCoste</a>
* @author <a href="mailto:bill@jboss.com">Bill Burke</a>
* @version <tt>$Revision: 61346 $</tt>
*/
public class Ejb3AnnotationHandler implements Ejb3Handler
{
private static final Logger log = Logger.getLogger(Ejb3AnnotationHandler.class);
protected static enum EJB_TYPE
{
STATELESS, STATEFUL, MESSAGE_DRIVEN, ENTITY, SERVICE, CONSUMER
}
protected DeploymentUnit di;
protected ClassFile cf;
protected List<String> ejbNames = new ArrayList<String>();
protected Class ejbClass;
protected String className;
protected EJB_TYPE ejbType;
protected Annotation annotation;
protected AnnotationsAttribute visible;
protected Hashtable ctxProperties;
protected String defaultSLSBDomain;
protected String defaultSFSBDomain;
protected String defaultMDBDomain;
protected String defaultServiceDomain;
protected String defaultConsumerDomain;
protected Ejb3Deployment deployment;
public Ejb3AnnotationHandler(Ejb3Deployment deployment)
{
this.deployment = deployment;
this.di = deployment.getDeploymentUnit();
defaultSLSBDomain = deployment.getDefaultSLSBDomain();
defaultSFSBDomain = deployment.getDefaultSFSBDomain();
defaultMDBDomain = deployment.getDefaultMDBDomain();
defaultServiceDomain = deployment.getDefaultServiceDomain();
defaultConsumerDomain = deployment.getDefaultConsumerDomain();
}
public Ejb3AnnotationHandler(Ejb3Deployment deployment, ClassFile cf)
{
this.deployment = deployment;
this.di = deployment.getDeploymentUnit();
defaultSLSBDomain = deployment.getDefaultSLSBDomain();
defaultSFSBDomain = deployment.getDefaultSFSBDomain();
defaultMDBDomain = deployment.getDefaultMDBDomain();
defaultServiceDomain = deployment.getDefaultServiceDomain();
defaultConsumerDomain = deployment.getDefaultConsumerDomain();
this.cf = cf;
className = cf.getName();
visible = (AnnotationsAttribute) cf.getAttribute(AnnotationsAttribute.visibleTag);
}
public void setCtxProperties(Hashtable ctxProperties)
{
this.ctxProperties = ctxProperties;
}
protected String getJaccContextId()
{
return di.getShortName();
}
public boolean isEjb()
{
if (visible == null) return false;
if (EJB3Util.isStateless(visible)) return true;
if (EJB3Util.isMessageDriven(visible)) return true;
if (EJB3Util.isStatefulSession(visible)) return true;
return false;
}
public boolean isJBossBeanType()
{
if (visible == null) return false;
if (EJB3Util.isService(visible)) return true;
if (EJB3Util.isConsumer(visible)) return true;
return false;
}
public List getContainers(Ejb3Deployment deployment) throws Exception
{
List containers = new ArrayList();
populateBaseInfo();
for (int ejbIndex = 0; ejbIndex < ejbNames.size(); ++ejbIndex)
{
String ejbName = ejbNames.get(ejbIndex);
if (ejbType == EJB_TYPE.STATELESS)
{
EJBContainer container = getStatelessContainer(ejbIndex);
container.setJaccContextId(getJaccContextId());
containers.add(container);
}
else if (ejbType == EJB_TYPE.STATEFUL)
{
StatefulContainer container = getStatefulContainer(ejbIndex);
container.setJaccContextId(getJaccContextId());
containers.add(container);
}
else if (ejbType == EJB_TYPE.MESSAGE_DRIVEN)
{
MDB container = getMDB(ejbIndex);
validateMDBTransactionAttribute(container);
container.setJaccContextId(getJaccContextId());
containers.add(container);
}
else if (ejbType == EJB_TYPE.SERVICE)
{
ServiceContainer container = getServiceContainer(ejbIndex);
container.setJaccContextId(getJaccContextId());
containers.add(container);
}
else if (ejbType == EJB_TYPE.CONSUMER)
{
ConsumerContainer container = getConsumerContainer(ejbIndex);
container.setJaccContextId(getJaccContextId());
containers.add(container);
}
log.debug("found EJB3: ejbName=" + ejbName + ", class=" + className + ", type=" + ejbType);
}
return containers;
}
protected void validateMDBTransactionAttribute(MDB mdb)
{
TransactionAttribute tx = (TransactionAttribute)mdb.resolveAnnotation(TransactionAttribute.class);
if (tx != null)
{
TransactionAttributeType type = tx.value();
if (type != TransactionAttributeType.REQUIRED && type != TransactionAttributeType.NOT_SUPPORTED)
throw new RuntimeException("MDB " + mdb.getEjbName() + " has an invalid TransactionAttribute: " + type +
". Only REQUIRED and NOT_SUPPORTED are valid");
}
}
protected String getAspectDomain(int ejbIndex, String defaultDomain)
{
return EJB3Util.getAspectDomain(visible, defaultDomain);
}
protected ServiceContainer getServiceContainer(int ejbIndex) throws Exception
{
String containerName = getAspectDomain(ejbIndex, defaultServiceDomain);
DomainDefinition domain = AspectManager.instance().getContainer(containerName);
if (domain == null)
throw new RuntimeException("No container configured with name '"
+ containerName + "''");
return new ServiceContainer(deployment.getMbeanServer(), di.getClassLoader(), className,
ejbNames.get(ejbIndex), (AspectManager) domain.getManager(), ctxProperties,
di.getInterceptorInfoRepository(), deployment);
}
protected ConsumerContainer getConsumerContainer(int ejbIndex) throws Exception
{
String containerName = getAspectDomain(ejbIndex, defaultConsumerDomain);
DomainDefinition domain = AspectManager.instance().getContainer(containerName);
if (domain == null)
throw new RuntimeException("No container configured with name '"
+ containerName + "''");
return new ConsumerContainer(ejbNames.get(ejbIndex), (AspectManager) domain.getManager(),
di.getClassLoader(), className, ctxProperties,
di.getInterceptorInfoRepository(), deployment);
}
protected StatefulContainer getStatefulContainer(int ejbIndex) throws Exception
{
String containerName = getAspectDomain(ejbIndex, defaultSFSBDomain);
DomainDefinition domain = AspectManager.instance().getContainer(containerName);
if (domain == null)
throw new RuntimeException("No container configured with name '"
+ containerName + "''");
return new StatefulContainer(di.getClassLoader(), className,
ejbNames.get(ejbIndex), (AspectManager) domain.getManager(), ctxProperties,
di.getInterceptorInfoRepository(), deployment);
}
protected EJBContainer getStatelessContainer(int ejbIndex) throws Exception
{
String containerName = getAspectDomain(ejbIndex, defaultSLSBDomain);
DomainDefinition domain = AspectManager.instance().getContainer(containerName);
if (domain == null)
throw new RuntimeException("No container configured with name '"
+ containerName + "''");
return new StatelessContainer(di.getClassLoader(), className,
ejbNames.get(ejbIndex), (AspectManager) domain.getManager(),
ctxProperties, di.getInterceptorInfoRepository(),
deployment);
}
protected String getMDBDomainName(int ejbIndex)
{
return defaultMDBDomain;
}
protected void createProxyFactories()
{
}
protected MDB getMDB(int ejbIndex) throws Exception
{
return getMDB(ejbIndex, null);
}
protected MDB getMDB(int ejbIndex, EnterpriseBean xml) throws Exception
{
String domainName = getMDBDomainName(ejbIndex);
String containerName = getAspectDomain(ejbIndex, domainName);
DomainDefinition domain = AspectManager.instance().getContainer(containerName);
if (domain == null)
throw new RuntimeException("No container configured with name '"
+ containerName + "''");
MDB container = new MDB(ejbNames.get(ejbIndex), (AspectManager) domain.getManager(), di.getClassLoader(), className,
ctxProperties, di.getInterceptorInfoRepository(), deployment);
return container;
}
protected void populateBaseInfo() throws Exception
{
String ejbName = null;
ejbClass = di.getClassLoader().loadClass(className);
visible = (AnnotationsAttribute) cf.getAttribute(AnnotationsAttribute.visibleTag);
if (visible != null)
{
annotation = visible.getAnnotation(javax.ejb.Stateless.class.getName());
if (annotation != null)
{
ejbType = EJB_TYPE.STATELESS;
}
else
{
annotation = visible.getAnnotation(javax.ejb.Stateful.class.getName());
if (annotation != null)
{
ejbType = EJB_TYPE.STATEFUL;
}
else
{
annotation = visible.getAnnotation(javax.persistence.Entity.class.getName());
if (annotation != null)
{
ejbType = EJB_TYPE.ENTITY;
}
else
{
annotation = visible.getAnnotation(javax.ejb.MessageDriven.class.getName());
if (annotation != null)
{
ejbType = EJB_TYPE.MESSAGE_DRIVEN;
}
else
{
annotation = visible.getAnnotation(org.jboss.annotation.ejb.Service.class.getName());
if (annotation != null)
{
ejbType = EJB_TYPE.SERVICE;
}
else
{
annotation = visible.getAnnotation(org.jboss.annotation.ejb.Consumer.class.getName());
if (annotation != null)
{
ejbType = EJB_TYPE.CONSUMER;
}
}
}
}
}
}
if (annotation != null)
{
StringMemberValue mv = (StringMemberValue) annotation.getMemberValue("name");
if (mv != null)
ejbName = mv.getValue();
else
ejbName = ejbClass.getSimpleName();
}
}
if (ejbName != null)
{
ejbNames.add(ejbName);
}
}
}
|
