[jboss-svn-commits] JBL Code SVN: r7975 - in labs/jbossesb/trunk/product/core/listeners/src/org/jboss/soa/esb/listeners: gateway message old

[jboss-svn-commits at lists.jboss.org]

Author: kurt.stam at jboss.com
Date: 2006-11-30 01:52:07 -0500 (Thu, 30 Nov 2006)
New Revision: 7975

Added:
   labs/jbossesb/trunk/product/core/listeners/src/org/jboss/soa/esb/listeners/gateway/GatewayListenerControllerService.java
   labs/jbossesb/trunk/product/core/listeners/src/org/jboss/soa/esb/listeners/gateway/GatewayListenerControllerServiceMBean.java
   labs/jbossesb/trunk/product/core/listeners/src/org/jboss/soa/esb/listeners/message/EsbListenerControllerService.java
   labs/jbossesb/trunk/product/core/listeners/src/org/jboss/soa/esb/listeners/message/EsbListenerControllerServiceMBean.java
Modified:
   labs/jbossesb/trunk/product/core/listeners/src/org/jboss/soa/esb/listeners/old/GpListener.java
Log:
adding mbeans for the esb and gateway listeners

Added: labs/jbossesb/trunk/product/core/listeners/src/org/jboss/soa/esb/listeners/gateway/GatewayListenerControllerService.java
===================================================================
--- labs/jbossesb/trunk/product/core/listeners/src/org/jboss/soa/esb/listeners/gateway/GatewayListenerControllerService.java	2006-11-30 04:48:30 UTC (rev 7974)
+++ labs/jbossesb/trunk/product/core/listeners/src/org/jboss/soa/esb/listeners/gateway/GatewayListenerControllerService.java	2006-11-30 06:52:07 UTC (rev 7975)
@@ -0,0 +1,38 @@
+package org.jboss.soa.esb.listeners.gateway;
+
+import org.apache.log4j.Logger;
+import org.jboss.system.ServiceMBeanSupport;
+
+public class GatewayListenerControllerService extends ServiceMBeanSupport implements GatewayListenerControllerServiceMBean
+{
+	private GatewayListenerController	gatewayListController;
+	private Logger logger = Logger.getLogger(this.getClass());
+	private String gatewayConfigFile="jbossesb-deployment.xml";
+	
+	protected void startService() throws Exception 
+	{
+		logger.info("starting message aware listener with config file " + gatewayConfigFile);
+		String confDir = System.getProperty("jboss.server.config.url");
+		confDir = confDir.substring(6, confDir.length());
+		String configFile = confDir + gatewayConfigFile;
+		System.setProperty("juddi.propertiesFile", confDir + "juddi.properties");
+		gatewayListController = new GatewayListenerController(configFile);
+		new Thread(gatewayListController).start();
+	}
+
+	protected void stopService() throws Exception 
+	{
+		logger.info("shutting down message aware listener...");
+		gatewayListController.requestEnd();
+	}
+
+	public String getGatewayConfigFile() {
+		return gatewayConfigFile;
+	}
+
+	public void setGatewayConfigFile(String gatewayConfigFile) {
+		this.gatewayConfigFile = gatewayConfigFile;
+	}
+
+	
+}

Added: labs/jbossesb/trunk/product/core/listeners/src/org/jboss/soa/esb/listeners/gateway/GatewayListenerControllerServiceMBean.java
===================================================================
--- labs/jbossesb/trunk/product/core/listeners/src/org/jboss/soa/esb/listeners/gateway/GatewayListenerControllerServiceMBean.java	2006-11-30 04:48:30 UTC (rev 7974)
+++ labs/jbossesb/trunk/product/core/listeners/src/org/jboss/soa/esb/listeners/gateway/GatewayListenerControllerServiceMBean.java	2006-11-30 06:52:07 UTC (rev 7975)
@@ -0,0 +1,10 @@
+package org.jboss.soa.esb.listeners.gateway;
+
+import org.jboss.system.ServiceMBean;
+
+public interface GatewayListenerControllerServiceMBean extends ServiceMBean
+{
+   // Configure getters and setters for the configFile attribute
+   String getGatewayConfigFile();
+   void setGatewayConfigFile(String messageAwareConfigFile);
+}

Added: labs/jbossesb/trunk/product/core/listeners/src/org/jboss/soa/esb/listeners/message/EsbListenerControllerService.java
===================================================================
--- labs/jbossesb/trunk/product/core/listeners/src/org/jboss/soa/esb/listeners/message/EsbListenerControllerService.java	2006-11-30 04:48:30 UTC (rev 7974)
+++ labs/jbossesb/trunk/product/core/listeners/src/org/jboss/soa/esb/listeners/message/EsbListenerControllerService.java	2006-11-30 06:52:07 UTC (rev 7975)
@@ -0,0 +1,36 @@
+package org.jboss.soa.esb.listeners.message;
+
+import org.apache.log4j.Logger;
+import org.jboss.system.ServiceMBeanSupport;
+
+public class EsbListenerControllerService extends ServiceMBeanSupport implements EsbListenerControllerServiceMBean
+{
+	private EsbListenerController	_esbListController;
+	private Logger _logger = Logger.getLogger(this.getClass());
+	private String messageAwareConfigFile="jbossesb-deployment.xml";
+	
+	protected void startService() throws Exception 
+	{
+		_logger.info("starting message aware listener with config file " + messageAwareConfigFile);
+		String confDir = System.getProperty("jboss.server.config.url");
+		confDir = confDir.substring(6, confDir.length());
+		String configFile = confDir + messageAwareConfigFile;
+		System.setProperty("juddi.propertiesFile", confDir + "juddi.properties");
+		_esbListController = new EsbListenerController(configFile);
+		new Thread(_esbListController).start();
+	}
+
+	protected void stopService() throws Exception 
+	{
+		_logger.info("shutting down message aware listener...");
+		_esbListController.requestEnd();
+	}
+
+	public String getMessageAwareConfigFile() {
+		return messageAwareConfigFile;
+	}
+
+	public void setMessageAwareConfigFile(String messageAwareConfigFile) {
+		this.messageAwareConfigFile = messageAwareConfigFile;
+	}
+}

Added: labs/jbossesb/trunk/product/core/listeners/src/org/jboss/soa/esb/listeners/message/EsbListenerControllerServiceMBean.java
===================================================================
--- labs/jbossesb/trunk/product/core/listeners/src/org/jboss/soa/esb/listeners/message/EsbListenerControllerServiceMBean.java	2006-11-30 04:48:30 UTC (rev 7974)
+++ labs/jbossesb/trunk/product/core/listeners/src/org/jboss/soa/esb/listeners/message/EsbListenerControllerServiceMBean.java	2006-11-30 06:52:07 UTC (rev 7975)
@@ -0,0 +1,10 @@
+package org.jboss.soa.esb.listeners.message;
+
+import org.jboss.system.ServiceMBean;
+
+public interface EsbListenerControllerServiceMBean extends ServiceMBean
+{
+//	 Configure getters and setters for the configFile attribute
+	String getMessageAwareConfigFile();
+	void setMessageAwareConfigFile(String messageAwareConfigFile);
+}

Modified: labs/jbossesb/trunk/product/core/listeners/src/org/jboss/soa/esb/listeners/old/GpListener.java
===================================================================
--- labs/jbossesb/trunk/product/core/listeners/src/org/jboss/soa/esb/listeners/old/GpListener.java	2006-11-30 04:48:30 UTC (rev 7974)
+++ labs/jbossesb/trunk/product/core/listeners/src/org/jboss/soa/esb/listeners/old/GpListener.java	2006-11-30 06:52:07 UTC (rev 7975)
@@ -37,14 +37,12 @@
 import org.jboss.internal.soa.esb.command.CommandQueueException;
 import org.jboss.soa.esb.ConfigurationException;
 import org.jboss.soa.esb.actions.ActionDefinitionFactory;
-import org.jboss.soa.esb.common.Configuration;
 import org.jboss.soa.esb.common.Environment;
 import org.jboss.soa.esb.common.ModulePropertyManager;
 import org.jboss.soa.esb.helpers.ConfigTree;
 import org.jboss.soa.esb.notification.NotificationList;
 import org.jboss.soa.esb.parameters.ParamRepositoryException;
 import org.jboss.soa.esb.parameters.ParamRepositoryFactory;
-import org.jboss.soa.esb.services.NotificationManager;
 import org.jboss.soa.esb.util.Util;
 import org.xml.sax.SAXException;
 
@@ -631,8 +629,8 @@
 		}
 	} // ________________________________
 
-	private static NotificationManager s_oNH;
+	//private static NotificationManager s_oNH;
 
-	private static final Object s_oSync = new Integer(0);
+	//private static final Object s_oSync = new Integer(0);
 
 } // ____________________________________________________________________________