From: <jbo...@li...> - 2006-06-30 18:40:13
|
Author: estebanschifman Date: 2006-06-30 14:40:04 -0400 (Fri, 30 Jun 2006) New Revision: 4888 Modified: labs/jbossesb/trunk/ESBCore/EsbListeners/src/org/jboss/soa/esb/listeners/DirListener.java Log: This listener is deprecated (although it still works because the parameter tree hasn't changed) Please see new example: BetterDirListener and AbstractPoller class. Modified: labs/jbossesb/trunk/ESBCore/EsbListeners/src/org/jboss/soa/esb/listeners/DirListener.java =================================================================== --- labs/jbossesb/trunk/ESBCore/EsbListeners/src/org/jboss/soa/esb/listeners/DirListener.java 2006-06-30 13:53:54 UTC (rev 4887) +++ labs/jbossesb/trunk/ESBCore/EsbListeners/src/org/jboss/soa/esb/listeners/DirListener.java 2006-06-30 18:40:04 UTC (rev 4888) @@ -45,14 +45,14 @@ new DirListener(args[0]); } //________________________________ - public static final String PARM_POLL_LTCY = "pollLatency"; - public static final String PARM_RELOAD_LTCY = "reloadLatency"; + public static final String PARM_POLL_LTCY = "pollLatency"; + public static final String PARM_RELOAD_LTCY = "reloadLatency"; - public static final String PARM_MAX_THREADS = "maxThreads"; + public static final String PARM_MAX_THREADS = "maxThreads"; public static final String PARM_FILE_PROCESSOR_CLASS = "fileProcessorClass"; - public static final String PARM_INPUT_DIR = "inputDirURI"; - public static final String PARM_SUFFIX = "inputSuffix"; + public static final String PARM_INPUT_DIR = "inputDirURI"; + public static final String PARM_SUFFIX = "inputSuffix"; private Map<String,GroupOfChilds> m_omChildPrc = new HashMap<String,GroupOfChilds>(); @@ -161,8 +161,9 @@ String sStopTopic = "topic/quiesce"; StringBuilder sb = new StringBuilder("processor='DirListener'"); - String sJndiServer = EsbSysProps.getDefaultJndiServer(); - Context oJndiCtx = AppServerContext.getServerContext(sJndiServer); + String sJndiType = EsbSysProps.getJndiServerType(); + String sJndiServer = EsbSysProps.getJndiServerURL(); + Context oJndiCtx = AppServerContext.getServerContext(sJndiType,sJndiServer); Object tmp = oJndiCtx.lookup("UIL2ConnectionFactory"); TopicConnectionFactory tcf = (TopicConnectionFactory) tmp; @@ -315,7 +316,7 @@ } } //________________________________ - private void checkParms(DomElement p_oP) throws Exception + protected void checkParms(DomElement p_oP) throws Exception { String sAtt = p_oP.getAttr(PARM_MAX_THREADS); m_iMaxThr = (null == sAtt) ? 1 : Integer.parseInt(sAtt); |