9:49 a.m.
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();
| }
| }
| }
View the original post :
http://www.jboss.com/index.html?module=bb&op=viewtopic&p=4079650#...
Reply to the post :
http://www.jboss.com/index.html?module=bb&op=posting&mode=reply&a...