1 Reply Latest reply on Aug 30, 2007 11:09 AM by shankha Bhattacharya

    invoker.stopDelivery(); - could not stop Mbean for MDB 1st t

    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

      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,objName,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();
       }
       }
      }


      Start delivary 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,objName,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();
       }
       }
      }