1 Reply Latest reply on Sep 17, 2007 9:01 AM by Harini Raghavan

    MDB Not working

    shankha Bhattacharya Newbie

      Hi,
      I am able to control my deployed MDB programatically.

      Basically my code invoke the responsible MBean for that MDB and call the invoker.stopDelivery() method on that MBean.

      It will restrict the MDB to get the message from Queue.

      I can also withdrow the restriction of the MDB to get message from queue by invoking invoker.startDelivery(); on the MBean.

      responsible MBean is

      Code:
      MBean Name: Domain Name: jboss.j2ee
      service: EJB
      plugin: invoker
      binding: message-driven-bean
      jndiName: MessageEJB
      MBean Java Class: org.jboss.ejb.plugins.jms.JMSContainerInvoker


      --------
      But the problem is after invoking invoker.stopDelivery() ,still the MDB reads the 1st queue message.

      That is If I send 4 message after stop It will read the 1st one - other 3 messages are blocked unless I invoke startDelivery();

      If I send 7 messages - MDB consume 1 st one :( other 6 are blocked .
      then when I invoke startDelivery(); I will get the 6 messages with MDB.

      Can any body help me -???


      Stop delivery Code

      package com.test;
      
      import org.jboss.logging.Logger;
      import org.jboss.mx.util.MBeanServerLocator;
      import org.jboss.mx.util.MBeanProxy;
      import org.jboss.ejb.plugins.jms.JMSContainerInvokerMBean;
      
      import javax.ejb.SessionBean;
      import javax.ejb.CreateException;
      import javax.ejb.SessionContext;
      import javax.ejb.EJBException;
      import javax.management.MBeanServer;
      import javax.management.ObjectName;
      import javax.management.MalformedObjectNameException;
      import javax.management.MBeanInfo;
      import javax.naming.Context;
      import javax.naming.InitialContext;
      import javax.naming.NamingException;
      
      /**
       * Created by IntelliJ IDEA.
       * User: 151054
       * Date: Aug 30, 2007
       * Time: 2:29:30 PM
       * To change this template use File | Settings | File Templates.
       */
      
      public class MBeanTestBean implements SessionBean {
      
       //private static Logger log;
       private SessionContext mContext;
       private MBeanServer mbeanServer;
       private ObjectName mManagementService;
      
       private Context jndiCtx=null;
       private JMSContainerInvokerMBean invoker = null;
      
      
       public MBeanTestBean() {
       }
      
       public void ejbCreate() throws CreateException {
      
       if(mbeanServer == null)
       try {
       jndiCtx = new InitialContext();
       String serverName = (String)jndiCtx.lookup("java:comp/env/Server-Name");
       serverName = serverName.trim();
       if(serverName == null || serverName.length() == 0 || serverName.equals("null")) {
       try {
       mbeanServer = MBeanServerLocator.locateJBoss();
       System.out.println("@@@ --------- mbeanServer = "+mbeanServer.getDefaultDomain());
       System.out.println("@@@ --------- mbeanServer No of MBean = "+mbeanServer.getMBeanCount());
      
       }
       catch(IllegalStateException e) {
       throw new CreateException("No local JMX MBeanServer available");
       }
       } else {
       Object lServer = jndiCtx.lookup(serverName);
       if(lServer != null) {
       if(lServer instanceof MBeanServer)
       mbeanServer = (MBeanServer)lServer;
       else
       throw new CreateException("Server: " + lServer + " reference by Server-Name: " + serverName + " is not of type MBeanServer");
       } else {
       throw new CreateException("Server-Name " + serverName + " does not reference an Object in JNDI");
       }
       }
       }
       catch(NamingException ne) {
       throw new EJBException(ne);
       }
       }
      
       public void setSessionContext(SessionContext sessionContext) throws EJBException {
       }
      
       public void ejbRemove() throws EJBException {
       }
      
       public void ejbActivate() throws EJBException {
       }
      
       public void ejbPassivate() throws EJBException {
       }
      
       public void invokeMBeanFeatures(){
      
       try{
      
       //Object name = jndiCtx.lookup("MessageEJB");
      
       ObjectName objName = new ObjectName("jboss.j2ee:service=EJB,plugin=invoker,binding=message-driven-bean,jndiName=MessageEJB");
       //ObjectName objName = new ObjectName((String)name);
       MBeanInfo objMBeanInfo = mbeanServer.getMBeanInfo(objName);
       System.out.println("@@ -- MBeanTestBean :invokeMBeanFeatures : "+objMBeanInfo.getClassName());
      
       invoker = (JMSContainerInvokerMBean) MBeanProxy.get(JMSContainerInvokerMBean.class,objNa
      me,mbeanServer );
       //invoker.stopDelivery();
       System.out.println("@@ Invoker Name = " +invoker.getName());
       System.out.println("@@ Invoker Pllo Size = " +invoker.getMinPoolSize());
       //System.out.println("@@ Invoker Name = " +);
       System.out.println("@@ Invoker Message = " +invoker.getMaxMessages());
      
       invoker.stopDelivery();
      
       System.out.println("@@ Invoker Message = stopDelivery ");
      
       //invoker.getClass().newInstance().stopDelivery();
       //invoker.getClass().newInstance().stop();
      
      
      
       }catch(Exception ex){
      
       ex.printStackTrace();
       }
       }
      }

      Code:



      Start delivary code

      Code:


      package com.test;
      
      import org.jboss.ejb.plugins.jms.JMSContainerInvokerMBean;
      import org.jboss.mx.util.MBeanServerLocator;
      import org.jboss.mx.util.MBeanProxy;
      
      import javax.ejb.SessionBean;
      import javax.ejb.CreateException;
      import javax.ejb.SessionContext;
      import javax.ejb.EJBException;
      import javax.management.MBeanServer;
      import javax.management.ObjectName;
      import javax.management.MBeanInfo;
      import javax.naming.Context;
      import javax.naming.InitialContext;
      import javax.naming.NamingException;
      
      /**
       * Created by IntelliJ IDEA.
       * User: 151054
       * Date: Aug 30, 2007
       * Time: 7:09:22 PM
       * To change this template use File | Settings | File Templates.
       */
      
      public class MBeanStartBean implements SessionBean {
      
       private SessionContext mContext;
       private MBeanServer mbeanServer;
       private ObjectName mManagementService;
      
       private Context jndiCtx=null;
       private JMSContainerInvokerMBean invoker = null;
      
       public MBeanStartBean() {
       }
      
       public void ejbCreate() throws CreateException {
      
       if(mbeanServer == null)
       try {
       jndiCtx = new InitialContext();
       String serverName = (String)jndiCtx.lookup("java:comp/env/Server-Name");
       serverName = serverName.trim();
       if(serverName == null || serverName.length() == 0 || serverName.equals("null")) {
       try {
       mbeanServer = MBeanServerLocator.locateJBoss();
       System.out.println("@@@ --------- mbeanServer = "+mbeanServer.getDefaultDomain());
       System.out.println("@@@ --------- mbeanServer No of MBean = "+mbeanServer.getMBeanCount());
      
       }
       catch(IllegalStateException e) {
       throw new CreateException("No local JMX MBeanServer available");
       }
       } else {
       Object lServer = jndiCtx.lookup(serverName);
       if(lServer != null) {
       if(lServer instanceof MBeanServer)
       mbeanServer = (MBeanServer)lServer;
       else
       throw new CreateException("Server: " + lServer + " reference by Server-Name: " + serverName + " is not of type MBeanServer");
       } else {
       throw new CreateException("Server-Name " + serverName + " does not reference an Object in JNDI");
       }
       }
       }
       catch(NamingException ne) {
       throw new EJBException(ne);
       }
       }
      
       public void setSessionContext(SessionContext sessionContext) throws EJBException {
       }
      
       public void ejbRemove() throws EJBException {
       }
      
       public void ejbActivate() throws EJBException {
       }
      
       public void ejbPassivate() throws EJBException {
       }
      
      
       public void invokeMBeanStart(){
       try{
      
       //Object name = jndiCtx.lookup("MessageEJB");
      
       ObjectName objName = new ObjectName("jboss.j2ee:service=EJB,plugin=invoker,binding=message-driven-bean,jndiName=MessageEJB");
       //ObjectName objName = new ObjectName((String)name);
       MBeanInfo objMBeanInfo = mbeanServer.getMBeanInfo(objName);
       System.out.println("@@ -- MBeanTestBean :invokeMBeanFeatures : "+objMBeanInfo.getClassName());
      
       invoker = (JMSContainerInvokerMBean) MBeanProxy.get(JMSContainerInvokerMBean.class,objNa
      me,mbeanServer );
       //invoker.stopDelivery();
       System.out.println("@@ Invoker Name = " +invoker.getName());
       System.out.println("@@ Invoker Pllo Size = " +invoker.getMinPoolSize());
       //System.out.println("@@ Invoker Name = " +);
       System.out.println("@@ Invoker Message = " +invoker.getMaxMessages());
      
       invoker.startDelivery();
       //invoker.
       System.out.println("@@ Invoker Message = startDelivery ");
      
       //invoker.getClass().newInstance().stopDelivery();
       //invoker.getClass().newInstance().stop();
      
      
      
       }catch(Exception ex){
      
       ex.printStackTrace();
       }
       }
      }






        • 1. Re: MDB Not working
          Harini Raghavan Newbie

          Hi,

          I am trying to do something similar. I want to invoke start and stop delivery on the MBean from a script.

          The method MBeanServerLocator.locateJBoss() works fine only from within the Jboss container and not from the command line script. I am unable to figure out how to get a handle to the MBean server. What should I pass as servername to load the MBeanServer in the below code?

          Object lServer = initialContext.lookup(serverName);

          I tried to give the machine name as the servername, but it does not seem to work. Any help would be appreciated.

          Thanks,
          Harini