?? 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);
?? 快捷鍵說明
復制代碼
Ctrl + C
搜索代碼
Ctrl + F
全屏模式
F11
切換主題
Ctrl + Shift + D
顯示快捷鍵
?
增大字號
Ctrl + =
減小字號
Ctrl + -