Suspending/Pausing a MDB's Consumption Programmatically

[Claudio Martins]

Hey guys

I have come across a lot of forums saying that there are new methods available from Weblogic 9 that enable the suspension of a MDB's consumption but I can not find any examples of it in. Does anyone by any chance have an example of this?
I am using Weblogic 10.3.

Thanks for any help

[Deepak Bala]

This is a late reply but might help. The JMX beans that control the destination queue (if I remember correctly or was it the connection factory ?) expose some methods that allow this. I remember writing a batch program that connected to the JMX and did the same but I threw it away sometime back

But hey atleast you know it is possible

[Claudio Martins]

That's what you call a sad story!

Thanks for letting me know though

I don't know what to use but this is what I have so far, seems to be getting somewhere...

@MessageDriven(ejbName = "SuspendBean", destinationJndiName = "sorb.orderrequest.jms.q", destinationType = "javax.jms.Queue", maxBeansInFreePool = "10", initialBeansInFreePool = "5", defaultTransaction = MessageDriven.DefaultTransaction.REQUIRED, transTimeoutSeconds = "3", transactionType = MessageDriven.MessageDrivenTransactionType.CONTAINER, acknowledgeMode = MessageDriven.AcknowledgeMode.AUTO_ACKNOWLEDGE)
public class SuspendBean extends GenericMessageDrivenBean implements MessageDrivenBean, MessageListener {
	private static final long serialVersionUID = 1L;

	/* (non-Javadoc)
	 * @see javax.jms.MessageListener#onMessage(javax.jms.Message)
	 */
		public void onMessage(Message msg) {
		try {
			InitialContext ctx = new InitialContext();
			MBeanServer server = (MBeanServer)ctx.lookup("java:comp/env/jmx/runtime");
			ObjectName[] bob = (ObjectName[])server.getAttribute(new ObjectName("com.bea:Name=RuntimeService,Type=weblogic.management.mbeanservers.runtime.RuntimeServiceMBean"), "Services");
			for (ObjectName objectName : bob) {
				ObjectName serverrt = (ObjectName)server.getAttribute(objectName,"ServerRuntime");
				ObjectName[] apprt =(ObjectName[]) server.getAttribute(serverrt, "ApplicationRuntimes");
				for (ObjectName appName : apprt) {
					if (appName.toString().contains("SuspendMDBEAR")) {
						ObjectName[] comprt =(ObjectName[]) server.getAttribute(appName, "ComponentRuntimes");
						ObjectName[] ejbrt =(ObjectName[]) server.getAttribute(comprt[0], "EJBRuntimes");
						for (ObjectName ejbName : ejbrt) {
							System.out.println(server.getObjectInstance(ejbName));
							MessageDrivenEJBRuntimeMBean mdb = (MessageDrivenEJBRuntimeMBean)server.getObjectInstance(ejbName);
						}
						
					}
				}
				
			}
		} catch(Exception e) {
			System.out.println(e.toString());
		}
	}
}

The problem I have is I don't know what to cast that object as. I know I must somehow use this "weblogic.management.runtime.MessageDrivenEJBRuntimeMBean"

Does it ring any bells?

With the above code I get this compilation error:
"Multiple markers at this line
- The type weblogic.health.HealthFeedback cannot be resolved. It is indirectly
referenced from required .class files
- The type weblogic.management.runtime.RuntimeMBean cannot be resolved. It
is indirectly referenced from required .class files"

It has to do with the line "MessageDrivenEJBRuntimeMBean mdb = (MessageDrivenEJBRuntimeMBean)server.getObjectInstance(ejbName);"

I will carry on updating if I find any solutions, but if anyone can help please do

Thanks again

[Deepak Bala]

RuntimeMBean

The missing classes can be found in the module directory. I think, I vaguely remember having to import some related JAR files from there (after painstakingly identifying which class belong in which JAR).

Searched for the related operation a little and found this

MDB

The end of the page shows the suspend and resume operations that can be invoked on the bean. I think this is what I executed. I could be wrong though since I did this quite a while back

[Claudio Martins]

Thanks Deepak

That's exactly how I got to what I have using those pages. I will carry on trying to tinker with the code

Thanks for all the help

[Claudio Martins]

I have found a solution

Here is an example of the code I think is the best option:

import java.util.Hashtable;

import javax.management.MBeanServerConnection;
import javax.management.ObjectName;
import javax.management.remote.JMXConnector;
import javax.management.remote.JMXConnectorFactory;
import javax.management.remote.JMXServiceURL;
import javax.naming.Context;

public class StopTheBean implements Runnable{
	
	public void stopTheBean() {
		Thread runner = new Thread(this);
		runner.start();
	}
	
	public void run() {
		try {
			String hostname = "127.0.0.1";
			String portString = "7001";
			String username = "weblogic";
			String password = "weblogic";

			String protocol = "t3";
			Integer portInteger = Integer.valueOf(portString);
			int port = portInteger.intValue();
			String jndiroot = "/jndi/";
			String mserver = "weblogic.management.mbeanservers.runtime";
			JMXServiceURL serviceURL = new JMXServiceURL(protocol, hostname, port, jndiroot + mserver);
			Hashtable<String, Object> h = new Hashtable<String, Object>();
			h.put(Context.SECURITY_PRINCIPAL, username);
			h.put(Context.SECURITY_CREDENTIALS, password);
			h.put(JMXConnectorFactory.PROTOCOL_PROVIDER_PACKAGES, "weblogic.management.remote");
			h.put("jmx.remote.x.request.waiting.timeout", new Long(10000));
			JMXConnector connector = JMXConnectorFactory.connect(serviceURL, h);
			MBeanServerConnection connection = connector.getMBeanServerConnection();

			Hashtable<String, String> prop = new Hashtable<String, String>();
			prop.put("Name", "SuspendBean_SORBModule!SORBOrderRequest_Q");
			prop.put("Type", "MessageDrivenEJBRuntime");
			prop.put("ServerRuntime", "Local_Admin");
			prop.put("ApplicationRuntime", "SuspendMDBEAR");
			prop.put("EJBComponentRuntime", "SuspendMDB.jar");
			ObjectName beanName = new ObjectName("com.bea", prop);

			connection.invoke(beanName, "suspend", null, null);

			System.out.println("MDB Stopped");
			connector.close();

		} catch (Exception e) {
			System.out.println(e.toString());
		}
	}

}

Here is another example using a web service instead of a new thread:

import java.util.Hashtable;

import javax.jws.*;
import javax.management.MBeanServerConnection;
import javax.management.ObjectName;
import javax.management.remote.JMXConnector;
import javax.management.remote.JMXConnectorFactory;
import javax.management.remote.JMXServiceURL;
import javax.naming.Context;

@WebService
public class StopTheBean {

	@WebMethod
	public void beginTheSuspend() {
		try {
			String hostname = "127.0.0.1";
			String portString = "7001";
			String username = "weblogic";
			String password = "weblogic";

			String protocol = "t3";
			Integer portInteger = Integer.valueOf(portString);
			int port = portInteger.intValue();
			String jndiroot = "/jndi/";
			String mserver = "weblogic.management.mbeanservers.runtime";
			JMXServiceURL serviceURL = new JMXServiceURL(protocol, hostname, port, jndiroot + mserver);
			Hashtable<String, Object> h = new Hashtable<String, Object>();
			h.put(Context.SECURITY_PRINCIPAL, username);
			h.put(Context.SECURITY_CREDENTIALS, password);
			h.put(JMXConnectorFactory.PROTOCOL_PROVIDER_PACKAGES, "weblogic.management.remote");
			h.put("jmx.remote.x.request.waiting.timeout", new Long(10000));
			JMXConnector connector = JMXConnectorFactory.connect(serviceURL, h);
			MBeanServerConnection connection = connector.getMBeanServerConnection();

			Hashtable<String, String> prop = new Hashtable<String, String>();
			prop.put("Name", "SuspendBean_SORBModule!SORBOrderRequest_Q");
			prop.put("Type", "MessageDrivenEJBRuntime");
			prop.put("ServerRuntime", "Local_Admin");
			prop.put("ApplicationRuntime", "SuspendMDBEAR");
			prop.put("EJBComponentRuntime", "SuspendMDB.jar");
			ObjectName beanName = new ObjectName("com.bea", prop);

			connection.invoke(beanName, "suspend", null, null);

			System.out.println("MDB Suspended");
			connector.close();

		} catch (Exception e) {
			System.out.println(e.toString());
		}
	}
}

First of all, it has to be on its own thread separate from the MDB otherwise the thread will just hang... Secondly I know the context can be used to get the MBeanServer but it gives errors on authorization. That's why it has to be done this way, so that you can set the username and password to be used. The alternative way looks like this for anyone that is interested:

InitialContext ctx = new InitialContext();
MBeanServer server = (MBeanServer) ctx.lookup("java:comp/env/jmx/runtime");

And to further this post, these two sections of code return the exact same thing. So if you are struggling with getting the object name of the message bean you can find out what that is with the first of the next two sections of code:

			ObjectName[] bob = (ObjectName[]) server.getAttribute(new ObjectName("com.bea:Name=RuntimeService,Type=weblogic.management.mbeanservers.runtime.RuntimeServiceMBean"), "Services");
			for (ObjectName objectName : bob) {
				ObjectName serverrt = (ObjectName) server.getAttribute(objectName, "ServerRuntime");
				ObjectName[] apprt = (ObjectName[]) server.getAttribute(serverrt, "ApplicationRuntimes");
				for (ObjectName appName : apprt) {
					if (appName.toString().contains("SuspendMDBEAR")) {
						ObjectName[] comprt = (ObjectName[]) server.getAttribute(appName, "ComponentRuntimes");
						ObjectName[] ejbrt = (ObjectName[]) server.getAttribute(comprt[0], "EJBRuntimes");
						for (ObjectName ejbName : ejbrt) {
							server.invoke(ejbName, "suspend", null, null);
						}

					}
				}

			}

			Hashtable<String, String> prop = new Hashtable<String, String>();
			prop.put("Name", "SuspendBean_SORBModule!SORBOrderRequest_Q");
			prop.put("Type", "MessageDrivenEJBRuntime");
			prop.put("ServerRuntime", "Local_Admin");
			prop.put("ApplicationRuntime", "SuspendMDBEAR");
			prop.put("EJBComponentRuntime", "SuspendMDB.jar");
			ObjectName beanName = new ObjectName("com.bea", prop);

			server.invoke(beanName, "suspend", null, null);

I will REPEAT, the immediate above two sections do the exact same thing. Please note, the variable "server" in these two sections of code refers to the MBeanServer.

Here are some useful attributes that can be retrieved from the MDB:

			connection.getAttribute(beanName, "ConnectionStatus");
			connection.getAttribute(beanName, "Destination");
			connection.getAttribute(beanName, "EJBName");
			connection.getAttribute(beanName, "HealthState");
			connection.getAttribute(beanName, "JmsClientID");
			connection.getAttribute(beanName, "JMSConnectionAlive");
			connection.getAttribute(beanName, "LastException");
			connection.getAttribute(beanName, "LastExceptionAsString");
			connection.getAttribute(beanName, "MDBStatus");
			connection.getAttribute(beanName, "Name");
			connection.getAttribute(beanName, "Parent");
			connection.getAttribute(beanName, "ProcessedMessageCount");
			connection.getAttribute(beanName, "SuspendCount");
			connection.getAttribute(beanName, "Type");

I think they all return as Strings. Just check it before you use it

I hope this helps anyone that was in my position!

ENJOY