Start line:  
End line:  

Snippet Preview

Snippet HTML Code

Stack Overflow Questions
  /*
   * 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.mdb;
 
 import java.util.List;
 import java.util.Map;
 import java.util.Set;
 
 
Comment

Author(s):
Bill Burke
Version:
$Revision: 76006 $
 
 public class MDB extends MessagingContainer 
 {
   
Default destination type. Used when no message-driven-destination is given in ejb-jar, and a lookup of destinationJNDI from jboss.xml is not successful. Default value: javax.jms.Topic.
 
    protected final static String DEFAULT_DESTINATION_TYPE = "javax.jms.Topic";
    
    protected Class<?> messagingType = null;
    
    public MDB(String ejbNameDomain domainClassLoader clString beanClassNameHashtable ctxProperties,
               Ejb3Deployment deploymentJBossMessageDrivenBeanMetaData beanMetaDatathrows ClassNotFoundException
    {
       super(ejbNamedomainclbeanClassNamectxPropertiesdeploymentbeanMetaData);
    }
    
    public Class<?> getMessagingType()
    {
       if ( == null)
       {
          MessageDriven annotation = (MessageDrivenresolveAnnotation(MessageDriven.class);
           = annotation.messageListenerInterface();
          if (.getName().equals(Object.class.getName()))
          {
             Set<Class<?>> businessInterfaces = ProxyFactoryHelper.getBusinessInterfaces(getBeanClass(), false);
             if (businessInterfaces.size() > 1 || businessInterfaces.size() == 0) 
                throw new RuntimeException("Unable to choose messagingType interface for MDB " + getEjbName() + " from " + businessInterfaces);
              = businessInterfaces.iterator().next();
          }
       }
 
       return ;
    }
    
    /*
    public MethodInfo getMethodInfo(Method method)
    {
       long hash = MethodHashing.calculateHash(method);
       MethodInfo info = super.getMethodInfo(hash);
       return info;
    }
    */
 
    {
       HashMap result = new HashMap();
       MessageDriven mdAnnotation = (MessageDrivenresolveAnnotation(MessageDriven.class);
       for (ActivationConfigProperty property : mdAnnotation.activationConfig())
       {
          addActivationSpecProperty(resultproperty);
      }
      
      if (defaultSpecsAnnotation != null)
      {
         for (ActivationConfigProperty property : defaultSpecsAnnotation.value())
         {
            addActivationSpecProperty(resultproperty);
         }
      }
      
      return result;
   }
   
   {
      // TODO: use generics
      return (JBossMessageDrivenBeanMetaDatasuper.getMetaData();
   }
   
   {
      JBossMessageDrivenBeanMetaData metaData = getMetaData();
      if(metaData != null)
         return metaData.getTimeoutMethod();
      return null;
   }
   
   protected List<Class<?>> resolveBusinessInterfaces()
   {
      List<Class<?>> list = new ArrayList<Class<?>>();
      list.add(getMessagingType());
      return list;
   }
   public ObjectName getJmxName()
   {
      ObjectName jmxName = null;
      String jndiName = ProxyFactoryHelper.getLocalJndiName(this);
      // The name must be escaped since the jndiName may be arbitrary
      String name = .... + ",jndiName=" + jndiName;
      try
      {
         jmxName = org.jboss.mx.util.ObjectNameConverter.convert(name);
      }
      catch (MalformedObjectNameException e)
      {
         e.printStackTrace();
         throw new RuntimeException("Failed to create ObjectName, msg=" + e.getMessage());
      }
      return jmxName;
   }
   
   protected void populateActivationSpec()
   {
      if (defaultSpecs != null)
      {
         .merge(defaultSpecs.value());
      }
   }
New to GrepCode? Check out our FAQ X