manageddirectorypollerservice.java

一个简易的轮训小程序 哈哈哈哈哈哈后 嘿嘿嘿嘿黑诶

package org.sadun.util.polling.jboss;

import java.io.File;
import java.io.FilenameFilter;

import javax.management.InstanceNotFoundException;
import javax.management.ListenerNotFoundException;
import javax.management.MBeanException;
import javax.management.MBeanRegistration;
import javax.management.MBeanServer;
import javax.management.Notification;
import javax.management.NotificationListener;
import javax.management.ObjectName;

import org.sadun.util.polling.ManagedDirectoryPoller;

/**
 * An extension to the {@link org.sadun.util.polling.ManagedDirectoryPoller 
 * ManagedDirectoryPoller} mbean implementation which exposes JBoss' service
 * interface.
 * 
 * @author cris
 */
public class ManagedDirectoryPollerService
	implements ManagedDirectoryPollerServiceMBean, MBeanRegistration, NotificationListener {
		
	ManagedDirectoryPoller mPoller;

	/**
	 * Constructor for ManagedDirectoryPollerService.
	 * @param dirs
	 * @param filter
	 */
	public ManagedDirectoryPollerService(File[] dirs, FilenameFilter filter) {
		mPoller=new ManagedDirectoryPoller(dirs, filter);
		mPoller.setJMXTimerObjectName("DefaultDomain:service=timer");
	}

	/**
	 * Constructor for ManagedDirectoryPollerService.
	 * @param dirs
	 */
	public ManagedDirectoryPollerService(File[] dirs) {
		mPoller=new ManagedDirectoryPoller(dirs);
		mPoller.setJMXTimerObjectName("DefaultDomain:service=timer");
	}

	/**
	 * Constructor for ManagedDirectoryPollerService.
	 * @param directory
	 * @param filter
	 */
	public ManagedDirectoryPollerService(
		File directory,
		FilenameFilter filter) {
		mPoller=new ManagedDirectoryPoller(directory, filter);
		mPoller.setJMXTimerObjectName("DefaultDomain:service=timer");
	}

	/**
	 * Constructor for ManagedDirectoryPollerService.
	 * @param directory
	 */
	public ManagedDirectoryPollerService(File directory) {
		mPoller=new ManagedDirectoryPoller(directory);
		mPoller.setJMXTimerObjectName("DefaultDomain:service=timer");
	}

	/**
	 * Constructor for ManagedDirectoryPollerService.
	 * @param filter
	 */
	public ManagedDirectoryPollerService(FilenameFilter filter) {
		mPoller=new ManagedDirectoryPoller(filter);
		mPoller.setJMXTimerObjectName("DefaultDomain:service=timer");
	}

	/**
	 * Constructor for ManagedDirectoryPollerService.
	 */
	public ManagedDirectoryPollerService() {
		mPoller=new ManagedDirectoryPoller();
		mPoller.setJMXTimerObjectName("DefaultDomain:service=timer");
	}

	/**
	 * Constructor for ManagedDirectoryPollerService.
	 * @param dirs
	 * @param filter
	 * @param timeBased
	 */
	public ManagedDirectoryPollerService(
		File[] dirs,
		FilenameFilter filter,
		boolean timeBased) {
		mPoller=new ManagedDirectoryPoller(dirs, filter, timeBased);
		mPoller.setJMXTimerObjectName("DefaultDomain:service=timer");
	}

	/**
	 * Constructor for ManagedDirectoryPollerService.
	 * @param directory
	 * @param filter
	 * @param timeBased
	 */
	public ManagedDirectoryPollerService(
		File directory,
		FilenameFilter filter,
		boolean timeBased) {
		mPoller=new ManagedDirectoryPoller(directory, filter, timeBased);
		mPoller.setJMXTimerObjectName("DefaultDomain:service=timer");
	}

	/**
	 * Constructor for ManagedDirectoryPollerService.
	 * @param filter
	 * @param timeBased
	 */
	public ManagedDirectoryPollerService(
		FilenameFilter filter,
		boolean timeBased) {
		mPoller=new ManagedDirectoryPoller(filter, timeBased);
		mPoller.setJMXTimerObjectName("DefaultDomain:service=timer");
	}
	
	public void start() {
		mPoller.startUp();
	}
	/**
	 * @see org.sadun.util.polling.jboss.ManagedDirectoryPollerServiceMBean#stop()
	 */
	public void stop() {
		mPoller.shutdown();
	}

	/**
	 * @see org.sadun.util.polling.ManagedDirectoryPollerMBean#addControlledDirectory(java.lang.String)
	 */
	public void addControlledDirectory(String dir) throws MBeanException {
		mPoller.addControlledDirectory(dir);
	}

	/**
	 * @see org.sadun.util.polling.ManagedDirectoryPollerMBean#countControlledDirectories()
	 */
	public int countControlledDirectories() throws MBeanException {
		return mPoller.countControlledDirectories();
	}

	/**
	 * @see org.sadun.util.polling.ManagedDirectoryPollerMBean#getAutoMove()
	 */
	public boolean getAutoMove() {
		return mPoller.getAutoMove();
	}

	/**
	 * @see org.sadun.util.polling.ManagedDirectoryPollerMBean#getAutoMoveDirectoryPath(java.lang.String)
	 */
	public String getAutoMoveDirectoryPath(String directory)
		throws MBeanException {
		return mPoller.getAutoMoveDirectoryPath(directory);
	}

	/**
	 * @see org.sadun.util.polling.ManagedDirectoryPollerMBean#getBaseTime(java.lang.String)
	 */
	public long getBaseTime(String directory) {
		return mPoller.getBaseTime(directory);
	}

	/**
	 * @see org.sadun.util.polling.ManagedDirectoryPollerMBean#getControlledDirectories()
	 */
	public String getControlledDirectories() {
		return mPoller.getControlledDirectories();
	}

	/**
	 * @see org.sadun.util.polling.ManagedDirectoryPollerMBean#getControlledDirectory(int)
	 */
	public String getControlledDirectory(int i) throws MBeanException {
		return mPoller.getControlledDirectory(i);
	}

	/**
	 * @see org.sadun.util.polling.ManagedDirectoryPollerMBean#getPollInterval()
	 */
	public long getPollInterval() {
		return mPoller.getPollInterval();
	}

	/**
	 * @see org.sadun.util.polling.ManagedDirectoryPollerMBean#isPollingTimeBased()
	 */
	public boolean isPollingTimeBased() {
		return mPoller.isPollingTimeBased();
	}

	/**
	 * @see org.sadun.util.polling.ManagedDirectoryPollerMBean#isRunning()
	 */
	public boolean isRunning() throws MBeanException {
		return mPoller.isRunning();
	}

	/**
	 * @see org.sadun.util.polling.ManagedDirectoryPollerMBean#isSendSingleFileEvent()
	 */
	public boolean isSendSingleFileEvent() {
		return mPoller.isSendSingleFileEvent();
	}

	/**
	 * @see org.sadun.util.polling.ManagedDirectoryPollerMBean#isStartBySleeping()
	 */
	public boolean isStartBySleeping() {
		return mPoller.isStartBySleeping();
	}

	/**
	 * @see org.sadun.util.polling.ManagedDirectoryPollerMBean#isTimeBased()
	 */
	public boolean isTimeBased() {
		return mPoller.isTimeBased();
	}

	/**
	 * @see org.sadun.util.polling.ManagedDirectoryPollerMBean#isVerbose()
	 */
	public boolean isVerbose() {
		return mPoller.isVerbose();
	}

	/**
	 * @see org.sadun.util.polling.ManagedDirectoryPollerMBean#listControlledDirectories()
	 */
	public String listControlledDirectories() {
		return mPoller.listControlledDirectories();
	}

	/**
	 * @see org.sadun.util.polling.ManagedDirectoryPollerMBean#listInstalledPollManagers()
	 */
	public String listInstalledPollManagers() {
		return mPoller.listInstalledPollManagers();
	}

	/**
	 * @see org.sadun.util.polling.ManagedDirectoryPollerMBean#removeControlledDirectory(java.lang.String)
	 */
	public void removeControlledDirectory(String dir) throws MBeanException {
		mPoller.removeControlledDirectory(dir);
	}

	/**
	 * @see org.sadun.util.polling.ManagedDirectoryPollerMBean#setAutoMove(boolean)
	 */
	public void setAutoMove(boolean v) {
		mPoller.setAutoMove(v);
	}

	/**
	 * @see org.sadun.util.polling.ManagedDirectoryPollerMBean#setBaseTime(java.lang.String, long)
	 */
	public void setBaseTime(String directory, long time) {
		mPoller.setBaseTime(directory, time);
	}

	/**
	 * @see org.sadun.util.polling.ManagedDirectoryPollerMBean#setControlledDirectories(java.lang.String)
	 */
	public void setControlledDirectories(String commaSeparatedList) {
		mPoller.setControlledDirectories(commaSeparatedList);