Oracle® Fusion Middleware Developing Manageable Applications With JMX for Oracle WebLogic Server 11g Release 1 (10.3.5) Part Number E13729-04 |
|
|
View PDF |
The following sections describe how to use the WebLogic Server JMX timer service:
If you need your JMX client to carry out a task at a specified time or a regular time interval, you can configure a JMX timer service to emit notifications, and a listener that responds to the notifications with a specified action.
For example, you want a JMX monitor to run between 9am and 9pm each day. You configure the JMX timer service to emit a notification daily at 9am, which triggers a JMX listener to start your monitor. The timer service emits another notification at 9pm, which triggers the listener to stop the monitor MBean.
The JDK includes an implementation of the JMX timer service (see javax.management.timer.Timer
in the J2SE 6.0 API Specification at http://download.oracle.com/javase/6/docs/api/javax/management/timer/Timer.html
); however, listeners for this timer service run in their own thread in a server's JVM.
WebLogic Server includes an extension of the standard timer service that causes timer listeners to run in a thread that WebLogic Server manages and within the security context of a WebLogic Server user account.
You construct and manage instances of the timer service for each JMX client. WebLogic Server does not provide a centralized timer service that all JMX clients use. Each time you restart a server instance, each JMX client must re-instantiate any timer service configurations it needs.
To create the WebLogic Server timer service:
Create a JMX listener class in your application.
For general instructions on creating a JMX listener, see "Creating a Notification Listener" in Developing Custom Management Utilities With JMX for Oracle WebLogic Server.
Create a class that does the following:
Configures an instance of weblogic.management.timer.TimerMBean
to emit javax.management.timer.TimerNotification
notifications at a specific time or at a recurring interval. See TimerNotification
in the J2SE 6.0 API Specification at http://download.oracle.com/javase/6/docs/api/javax/management/timer/TimerNotification.html
.
For each notification that you configure, include a String
in the notification's Type
attribute that identifies the event that caused the timer to emit the notification.
Registers your listener and an optional filter with the timer MBean that you configured.
Starts the timer in the timer MBean that you configured.
For general instructions, see "Configuring a Notification Filter" and "Registering a Notification Listener and Filter" in Developing Custom Management Utilities With JMX for Oracle WebLogic Server.
Unregisters the timer MBean and closes its connection to the MBean server when it finishes using the timer service.
Package and deploy the listener and other JMX classes to WebLogic Server. See "Packaging and Deploying Listeners on WebLogic Server" in Developing Custom Management Utilities With JMX for Oracle WebLogic Server.
To configure a Timer
MBean instance to emit a notification:
Initialize a connection to the Domain Runtime MBean Server.
See "Make Remote Connections to an MBean Server" in Developing Custom Management Utilities With JMX for Oracle WebLogic Server.
Create an ObjectName
for your timer MBean instance.
See javax.management.ObjectName
in the J2SE 6.0 API Specification at http://download.oracle.com/javase/6/docs/api/javax/management/ObjectName.html
.
Oracle recommends that your object name start with the name of your organization and include key properties that clearly identify the purpose of the timer MBean instance.
For example, "mycompany:Name=myDailyTimer,Type=weblogicTimer"
Create and register the timer MBean.
Use javax.management.MBeanServerConnection.createMBean(String
classname
ObjectName name)
method where:
classname
is weblogic.management.timer.Timer
name
is the object name that you created for the timer MBean instance.
Note:
The timer MBean that you create runs in the JMX agent on WebLogic Server (it does not run in a client JVM even if you create the timer MBean from a remote JMX client).Configure the timer MBean to emit a notification.
Invoke the MBean's addNotification
operation. Table 5-1 describes each parameter of the addNotification
operation. For more information, see weblogic.management.timer.Timer in the WebLogic Server API Reference.
The addNotification
operation creates a TimerNotification
object and returns a handback object of type Integer
, which contains an integer that uniquely identifies the TimerNotification
object.
Repeat step 4 for each timer notification that your JMX client needs to receive.
Start the timers in your timer MBean by invoking the timer MBean's start()
operation.
When the time that you specify arrives, the timer service emits the TimerNotification
object along with a reference to the handback object.
Table 5-1 Parameters of the addNotification Operation
Parameter | Description |
---|---|
java.lang.String type |
A string that you use to identify the event that triggers this notification to be broadcast. For example, you can specify |
java.lang.String message |
Specifies the value of the |
java.lang.Object userData |
Specifies the name of an object that contains whatever data you want to send to your listeners. Usually, you specify a reference to the class that registered the notification, which functions as a callback. |
java.util.Date startTime |
Specifies a |
long period |
(Optional) Specifies the interval in milliseconds between notification occurrences. Repeating notifications are not enabled if this parameter is zero or is not defined ( |
long nbOccurences |
(Optional) Specifies the total number of times that the notification will occur. If the value of this parameter is zero or is not defined ( If you specify this parameter, each time the Timer MBean emits the associated notification, it decrements the number of occurrences by one. You can use the timer MBean's |
The constructor for the java.util.Date
object initializes the object to represent the time at which you created the Date
object measured to the nearest millisecond. To specify a different time or date:
Create an instance of java.util.Calendar
.
Configure the fields in the Calendar
object to represent the time or date.
Invoke the Calendar
object's getTime()
method, which returns a Date
object that represents the time in the Calendar
object.
For example, the following code configures a Date
object that represents midnight:
java.util.Calendar cal = java.util.Calendar.getInstance(); cal.set(java.util.Calendar.HOUR_OF_DAY, 24); java.util.Date morning = cal.getTime();
See java.util.Calendar
in the J2SE 6.0 API Specification.at http://download.oracle.com/javase/6/docs/api/java/util/Calendar.html
.
The code in Example 5-1 creates an instance of weblogic.management.timer.Timer
that emits a notification every 5 minutes after 9am.
Note the following about the code:
It creates and registers the timer MBean in the WebLogic Server Runtime MBean Server, under the assumption that the JMX client runs alongside applications that are deployed on multiple server instances. In this case, your JMX client would register a timer MBean in each Runtime MBean Server in the domain.
Even though it creates an instance of the WebLogic Server timer MBean, the class does not import WebLogic Server classes. Only the MBean server needs access to the WebLogic Server Timer
class, not the JMX client.
Any generic JMX listener can be used to listen for timer notifications, because all timer notifications extend javax.management.Notification
.
Example 5-1 Create, Register, and Configure a Timer MBean
import java.util.Hashtable; import java.io.IOException; import java.net.MalformedURLException; import javax.management.MBeanServerConnection; import javax.management.ObjectName; import javax.management.MalformedObjectNameException; import javax.management.remote.JMXConnector; import javax.management.remote.JMXConnectorFactory; import javax.management.remote.JMXServiceURL; import javax.naming.Context; import javax.management.NotificationFilterSupport; public class RegisterTimer { private static MBeanServerConnection connection; private static JMXConnector connector; private static final ObjectName service; // Initialize the object name for RuntimeServiceMBean // so it can be used throughout the class. static { try { service = new ObjectName( "com.bea:Name=RuntimeService,Type=weblogic.management.mbeanservers.ru ntime.RuntimeServiceMBean"); }catch (MalformedObjectNameException e) { throw new AssertionError(e.getMessage()); } } /* * Initialize connection to the Runtime MBean Server. * This MBean is the root of the runtime MBean hierarchy, and * each server in the domain hosts its own instance. */ public static void initConnection(String hostname, String portString, String username, String password) throws IOException, MalformedURLException { 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 h = new Hashtable(); h.put(Context.SECURITY_PRINCIPAL, username); h.put(Context.SECURITY_CREDENTIALS, password); h.put(JMXConnectorFactory.PROTOCOL_PROVIDER_PACKAGES, "weblogic.management.remote"); connector = JMXConnectorFactory.connect(serviceURL, h); connection = connector.getMBeanServerConnection(); } public static void main(String[] args) throws Exception { String hostname = args[0]; String portString = args[1]; String username = args[2]; String password = args[3]; try { /* Invokes a custom method that establishes a connection to the * Runtime MBean Server and uses an instance of * MBeanServerConnection to represents the connection. The custom * method assigns the MBeanServerConnection to a class-wide, static * variable named "connection". */ initConnection(hostname, portString, username, password); //Creates and registers the timer MBean. ObjectName timerON = new ObjectName("mycompany:Name=myDailyTimer,Type=weblogicTimer"); String classname = "weblogic.management.timer.Timer"; connection.createMBean(classname, timerON); System.out.println("===> created timer mbean "+timerON); // Configures the timer MBean to emit a morning notification. // Assigns the return value of addNotification to a variable so that // it will be possible to invoke other operations for this specific // notification. java.util.Calendar cal = java.util.Calendar.getInstance(); cal.set(java.util.Calendar.HOUR_OF_DAY, 9); java.util.Date morning = cal.getTime(); String myData = "Timer notification"; Integer morningTimerID = (Integer) connection.invoke(timerON, "addNotification", new Object[] { "mycompany.timer.notification.after9am" , "After 9am!", myData, morning, new Long(300000) }, new String[] {"java.lang.String", "java.lang.String", "java.lang.Object", "java.util.Date", "long" }); //Instantiates your listener class and configures a filter to // forward only timer messages. MyListener listener = new MyListener(); NotificationFilterSupport filter = new NotificationFilterSupport(); filter.enableType("mycompany.timer"); //Uses the MBean server's addNotificationListener method to //register the listener and filter with the timer MBean. System.out.println("===> ADD NOTIFICATION LISTENER TO "+ timerON); connection.addNotificationListener(timerON, listener, filter, null); System.out.println("\n[myListener]: Listener registered ..."); //Starts the timer. connection.invoke(timerON, "start", new Object[] { }, new String[] {}); //Keeps the remote client active. System.out.println("Pausing. Press Return to end..........."); System.in.read(); } catch(Exception e) { System.out.println("Exception: " + e); e.printStackTrace(); } } }
The timer MBean removes notifications from its list when either of the following occurs:
A non-repeating notification is emitted.
A repeating notification exhausts its number of occurrences.
The timer MBean also provides the following operations to remove notifications:
removeAllNotifications()
, which removes all notifications that are registered with the timer MBean instance.
removeNotification(java.lang.Integer id)
, which removes the notification whose handback object contains the integer value that you specify. The addNotification
method returns this handback object when you invoke it (see Step 4 in Configuring a Timer MBean to Emit Notifications.
removeNotifications(java.lang.String type)
, which removes all notifications whose type corresponds to the type that you specify. You define a notification's type value when you create the notification object. See Table 5-1.
For more information, see weblogic.management.timer.Timer in the WebLogic Server API Reference.