incubator-kalumet-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jbono...@apache.org
Subject svn commit: r1194852 [3/3] - in /incubator/kalumet/trunk: ./ agent/ agent/src/main/java/org/apache/kalumet/agent/updater/
Date Sat, 29 Oct 2011 09:37:45 GMT
Added: incubator/kalumet/trunk/agent/src/main/java/org/apache/kalumet/agent/updater/JDBCDataSourceUpdater.java
URL: http://svn.apache.org/viewvc/incubator/kalumet/trunk/agent/src/main/java/org/apache/kalumet/agent/updater/JDBCDataSourceUpdater.java?rev=1194852&view=auto
==============================================================================
--- incubator/kalumet/trunk/agent/src/main/java/org/apache/kalumet/agent/updater/JDBCDataSourceUpdater.java
(added)
+++ incubator/kalumet/trunk/agent/src/main/java/org/apache/kalumet/agent/updater/JDBCDataSourceUpdater.java
Sat Oct 29 09:37:44 2011
@@ -0,0 +1,235 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ *
+ *   http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied.  See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+package org.apache.kalumet.agent.updater;
+
+import org.apache.kalumet.KalumetException;
+import org.apache.kalumet.agent.Configuration;
+import org.apache.kalumet.agent.utils.EventUtils;
+import org.apache.kalumet.controller.core.J2EEApplicationServerController;
+import org.apache.kalumet.controller.core.J2EEApplicationServerControllerFactory;
+import org.apache.kalumet.model.*;
+import org.apache.kalumet.model.update.UpdateLog;
+import org.apache.kalumet.model.update.UpdateMessage;
+import org.apache.kalumet.utils.NotifierUtils;
+import org.apache.kalumet.utils.PublisherUtils;
+import org.apache.kalumet.utils.VariableUtils;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+/**
+ * JDBC data source updater.
+ */
+public class JDBCDataSourceUpdater {
+
+    private static final transient Logger LOGGER = LoggerFactory.getLogger(JDBCDataSourceUpdater.class);
+
+    /**
+     * Update a JDBC dataSource.
+     *
+     * @param environment the target <code>Environment</code>.
+     * @param server      the target <code>J2EEApplicationServer</code>.
+     * @param dataSource  the target <code>JDBCDataSource</code>.
+     * @param updateLog   the <code>UpdateLog</code> to use.
+     */
+    public static void update(Environment environment, J2EEApplicationServer server, JDBCDataSource
dataSource, UpdateLog updateLog) throws UpdateException {
+        LOGGER.info("Updating JDBC data source {}", dataSource.getName());
+        updateLog.addUpdateMessage(new UpdateMessage("info", "Updating JDBC data source "
+ dataSource.getName()));
+        EventUtils.post(environment, "UPDATE", "Updating JDBC data source " + dataSource.getName());
+
+        if (!dataSource.isActive()) {
+            // the data source is not active
+            LOGGER.info("JDBC data source {} is inactive, so not updated", dataSource.getName());
+            updateLog.addUpdateMessage(new UpdateMessage("info", "JDBC data source " + dataSource.getName()
+ " is inactive, so not updated"));
+            EventUtils.post(environment, "UPDATE", "JDBC Data Source " + dataSource.getName()
+ " is inactive, so not updated");
+            return;
+        }
+
+        LOGGER.debug("Getting the JDBC connection pool {}", dataSource.getPool());
+        JDBCConnectionPool connectionPool = server.getJDBCConnectionPool(dataSource.getPool());
+        if (connectionPool == null) {
+            LOGGER.error("JDBC connection pool {} is not found in the configuration", dataSource.getPool());
+            throw new UpdateException("JDBC connection pool " + dataSource.getPool() + "
is not found in the configuration");
+        }
+        J2EEApplicationServerController controller = null;
+        try {
+            LOGGER.debug("Connecting to J2EE application server controller");
+            controller = J2EEApplicationServerControllerFactory.getController(environment,
server);
+        } catch (KalumetException e) {
+            LOGGER.error("Can't connect to J2EE application server {} controller", server.getName(),
e);
+            throw new UpdateException("Can't connect to J2EE application server " + server.getName()
+ " controller", e);
+        }
+        // replace variables in the JDBC URL and helper class name
+        LOGGER.debug("Replacing variables in JDBC URL and helper class");
+        String jdbcUrl = VariableUtils.replace(connectionPool.getUrl(), environment.getVariables());
+        String helperClass = VariableUtils.replace(connectionPool.getHelperclass(), environment.getVariables());
+        try {
+            if (controller.isJDBCDataSourceDeployed(dataSource.getName())) {
+                // JDBC data source already deployed in the JEE application server
+                LOGGER.info("JDBC data source " + dataSource.getName() + " already deployed,
checking for update");
+                if (controller.updateJDBCDataSource(dataSource.getName(), connectionPool.getName(),
jdbcUrl, helperClass)) {
+                    // JDBC data source has been updated
+                    LOGGER.info("JDBC data source {} updated", dataSource.getName());
+                    updateLog.setStatus("Update performed");
+                    updateLog.setUpdated(true);
+                    updateLog.addUpdateMessage(new UpdateMessage("info", "JDBC data source
" + dataSource.getName() + " updated"));
+                    EventUtils.post(environment, "UPDATE", "JDBC data source " + dataSource.getName()
+ " updated");
+                }
+            } else {
+                // JDBC data source is not deployed, deploy it
+                LOGGER.debug("JDBC data source {} is not deployed, deploying it", dataSource.getName());
+                controller.deployJDBCDataSource(dataSource.getName(), connectionPool.getName(),
jdbcUrl, helperClass);
+                updateLog.setStatus("Update performed");
+                updateLog.setUpdated(true);
+                updateLog.addUpdateMessage(new UpdateMessage("info", "JDBC data source "
+ dataSource.getName() + " deployed"));
+                EventUtils.post(environment, "UPDATE", "JDBC data source " + dataSource.getName()
+ " deployed");
+                LOGGER.info("JDBC data source {} deployed", dataSource.getName());
+            }
+        } catch (Exception e) {
+            LOGGER.error("JDBC data source {} update failed", dataSource.getName(), e);
+            throw new UpdateException("JDBC data source " + dataSource.getName() + " update
failed", e);
+        }
+    }
+
+    /**
+     * Wrapper method to update a JDBC data source via WS.
+     *
+     * @param environmentName the target environment name.
+     * @param serverName      the target J2EE application server name.
+     * @param dataSourceName  the target JDBC data source name.
+     * @throws KalumetException in case of update failure.
+     */
+    public static void update(String environmentName, String serverName, String dataSourceName)
throws KalumetException {
+        LOGGER.info("JDBC data source {} update requested by WS", dataSourceName);
+
+        // load configuration
+        LOGGER.debug("Loading configuration");
+        Kalumet kalumet = Kalumet.digeste(Configuration.CONFIG_LOCATION);
+
+        // looking for component objects
+        Environment environment = kalumet.getEnvironment(environmentName);
+        if (environment == null) {
+            LOGGER.error("Environment {} is not found in the configuration", environmentName);
+            throw new KalumetException("Environment " + environmentName + " is not found
in the configuration");
+        }
+        J2EEApplicationServer applicationServer = environment.getJ2EEApplicationServers().getJ2EEApplicationServer(serverName);
+        if (applicationServer == null) {
+            LOGGER.error("J2EE application server {} is not found in environment {}", serverName,
environment.getName());
+            throw new KalumetException("J2EE application server " + serverName + " is not
found in environment " + environment.getName());
+        }
+        JDBCDataSource dataSource = applicationServer.getJDBCDataSource(dataSourceName);
+        if (dataSource == null) {
+            LOGGER.error("JDBC data source {} is not found in J2EE application server {}",
dataSourceName, applicationServer.getName());
+            throw new KalumetException("JDBC data source " + dataSourceName + " is not found
in J2EE application server " + applicationServer.getName());
+        }
+
+        // post event and create update log
+        EventUtils.post(environment, "UPDATE", "JDBC data source " + dataSource.getName()
+ " update requested by WS");
+        UpdateLog updateLog = new UpdateLog("JDBC data source " + dataSource.getName() +
" update in progress ...", environment.getName(), environment);
+
+        // send a notification and waiting for the count down
+        EventUtils.post(environment, "UPDATE", "Send a notification and waiting for the count
down");
+        NotifierUtils.waitAndNotify(environment);
+
+        try {
+            // call the updater
+            LOGGER.debug("Call JDBC data source updater");
+            JDBCDataSourceUpdater.update(environment, applicationServer, dataSource, updateLog);
+        } catch (Exception e) {
+            LOGGER.error("JDBC data source {} update failed", dataSource.getName(), e);
+            EventUtils.post(environment, "ERROR", "JDBC data source " + dataSource.getName()
+ " update failed: " + e.getMessage());
+            updateLog.setStatus("JDBC data source " + dataSource.getName() + " update failed");
+            updateLog.addUpdateMessage(new UpdateMessage("error", "JDBC data source " + dataSource.getName()
+ " update failed: " + e.getMessage()));
+            PublisherUtils.publish(environment);
+            throw new KalumetException("JDBC data source " + dataSource.getName() + " update
failed", e);
+        }
+
+        // update completed
+        LOGGER.info("JDBC data source {} updated", dataSource.getName());
+        EventUtils.post(environment, "UPDATE", "JDBC data source " + dataSource.getName()
+ " updated");
+        if (updateLog.isUpdated()) {
+            updateLog.setStatus("JDBC data source " + dataSource.getName() + " updated");
+        } else {
+            updateLog.setStatus("JDBC data source " + dataSource.getName() + " already up
to date");
+        }
+        updateLog.addUpdateMessage(new UpdateMessage("info", "JMS data source " + dataSource.getName()
+ " updated"));
+        LOGGER.info("Publishing update report");
+        PublisherUtils.publish(environment);
+    }
+
+    /**
+     * Wrapper method to check JDBC data source via WS.
+     *
+     * @param environmentName the target environment name.
+     * @param serverName      the target J2EE application server name.
+     * @param dataSourceName  the target JDBC data source name.
+     * @return true if the JDBC data source is up to date, false else.
+     * @throws KalumetException in case of check failure.
+     */
+    public static boolean check(String environmentName, String serverName, String dataSourceName)
throws KalumetException {
+        LOGGER.info("JDBC data source {} status check requested by WS", dataSourceName);
+
+        // load configuration.
+        LOGGER.debug("Loading configuration");
+        Kalumet kalumet = Kalumet.digeste(Configuration.CONFIG_LOCATION);
+
+        // looking for component objects
+        Environment environment = kalumet.getEnvironment(environmentName);
+        if (environment == null) {
+            LOGGER.error("Environment {} is not found in the configuration", environmentName);
+            throw new KalumetException("Environment " + environmentName + " is not found
in the configuration");
+        }
+        J2EEApplicationServer applicationServer = environment.getJ2EEApplicationServers().getJ2EEApplicationServer(serverName);
+        if (applicationServer == null) {
+            LOGGER.error("J2EE application server {} is not found in environment {}", serverName,
environment.getName());
+            throw new KalumetException("J2EE application server " + serverName + " is not
found in environment " + environment.getName());
+        }
+        JDBCDataSource dataSource = applicationServer.getJDBCDataSource(dataSourceName);
+        if (dataSource == null) {
+            LOGGER.error("JDBC data source {} is not found in J2EE application server {}",
dataSourceName, applicationServer.getName());
+            throw new KalumetException("JDBC data source " + dataSourceName + " is not found
in J2EE application server " + applicationServer.getName());
+        }
+
+        // post an event
+        EventUtils.post(environment, "INFO", "JDBC data source " + dataSource.getName() +
" status check requested by WS");
+
+        // Get JDBC data source connection pool.
+        LOGGER.debug("Getting JDBC data source connection pool");
+        JDBCConnectionPool connectionPool = applicationServer.getJDBCConnectionPool(dataSource.getPool());
+        if (connectionPool == null) {
+            LOGGER.error("JDBC connection pool {} is not found in J2EE application server
{}", dataSource.getPool(), applicationServer.getName());
+            throw new KalumetException("JDBC connection pool " + dataSource.getPool() + "
is not found in J2EE application server " + applicationServer.getName());
+        }
+
+        try {
+            // connecting to J2EE application server controller
+            LOGGER.debug("Connecting to J2EE application server controller");
+            J2EEApplicationServerController controller = J2EEApplicationServerControllerFactory.getController(environment,
applicationServer);
+            // replace variables in the JDBC URL and helper class name
+            LOGGER.debug("Replacing variables in JDBC URL and helper class");
+            String jdbcUrl = VariableUtils.replace(connectionPool.getUrl(), environment.getVariables());
+            String helperClass = VariableUtils.replace(connectionPool.getHelperclass(), environment.getVariables());
+            // check the data source
+            return controller.isJDBCDataSourceUpToDate(dataSource.getName(), dataSource.getPool(),
jdbcUrl, helperClass);
+        } catch (Exception e) {
+            LOGGER.error("JDBC data source {} check failed", dataSource.getName(), e);
+            throw new KalumetException("JDBC data source " + dataSource.getName() + " check
failed", e);
+        }
+    }
+
+}

Added: incubator/kalumet/trunk/agent/src/main/java/org/apache/kalumet/agent/updater/JMSConnectionFactoryUpdater.java
URL: http://svn.apache.org/viewvc/incubator/kalumet/trunk/agent/src/main/java/org/apache/kalumet/agent/updater/JMSConnectionFactoryUpdater.java?rev=1194852&view=auto
==============================================================================
--- incubator/kalumet/trunk/agent/src/main/java/org/apache/kalumet/agent/updater/JMSConnectionFactoryUpdater.java
(added)
+++ incubator/kalumet/trunk/agent/src/main/java/org/apache/kalumet/agent/updater/JMSConnectionFactoryUpdater.java
Sat Oct 29 09:37:44 2011
@@ -0,0 +1,211 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ *
+ *   http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied.  See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+package org.apache.kalumet.agent.updater;
+
+import org.apache.kalumet.KalumetException;
+import org.apache.kalumet.agent.Configuration;
+import org.apache.kalumet.agent.utils.EventUtils;
+import org.apache.kalumet.controller.core.ControllerException;
+import org.apache.kalumet.controller.core.J2EEApplicationServerController;
+import org.apache.kalumet.controller.core.J2EEApplicationServerControllerFactory;
+import org.apache.kalumet.model.Environment;
+import org.apache.kalumet.model.J2EEApplicationServer;
+import org.apache.kalumet.model.JMSConnectionFactory;
+import org.apache.kalumet.model.Kalumet;
+import org.apache.kalumet.model.update.UpdateLog;
+import org.apache.kalumet.model.update.UpdateMessage;
+import org.apache.kalumet.utils.NotifierUtils;
+import org.apache.kalumet.utils.PublisherUtils;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+/**
+ * JMS connection factory updater.
+ */
+public class JMSConnectionFactoryUpdater {
+
+    private static final transient Logger LOGGER = LoggerFactory.getLogger(JMSConnectionFactoryUpdater.class);
+
+    /**
+     * Updates a JMS connection factory.
+     *
+     * @param environment          the target <code>Environment</code>.
+     * @param server               the target <code>J2EEApplicationServer</code>.
+     * @param jmsConnectionFactory the target <code>JMSConnectionFactory</code>.
+     * @param updateLog            the <code>UpdateLog</code> to use.
+     */
+    public static void update(Environment environment, J2EEApplicationServer server, JMSConnectionFactory
jmsConnectionFactory, UpdateLog updateLog) throws UpdateException {
+        LOGGER.info("Updating JMS connection factory {}", jmsConnectionFactory.getName());
+        updateLog.addUpdateMessage(new UpdateMessage("info", "Updating JMS connection factory
" + jmsConnectionFactory.getName()));
+        EventUtils.post(environment, "UPDATE", "Updating JMS connection factory " + jmsConnectionFactory.getName());
+        if (!jmsConnectionFactory.isActive()) {
+            // the JMS connection factory is not active
+            LOGGER.info("JMS connection factory {} is inactive, so not updated", jmsConnectionFactory.getName());
+            updateLog.addUpdateMessage(new UpdateMessage("info", "JMS connection factory
" + jmsConnectionFactory.getName() + " is inactive, so not updated"));
+            EventUtils.post(environment, "UPDATE", "JMS Connection Factory " + jmsConnectionFactory.getName()
+ " is inactive, so not updated");
+            return;
+        }
+        J2EEApplicationServerController controller = null;
+        try {
+            // connect controller to J2EE application server
+            LOGGER.debug("Connecting to J2EE application server controller");
+            controller = J2EEApplicationServerControllerFactory.getController(environment,
server);
+        } catch (KalumetException e) {
+            LOGGER.error("Can't connect to J2EE application server {} controller", server.getName(),
e);
+            throw new UpdateException("Can't connect to J2EE application server " + server.getName()
+ " controller", e);
+        }
+        try {
+            if (controller.isJMSConnectionFactoryDeployed(jmsConnectionFactory.getName()))
{
+                // JMS connection factory already deployed in the J2EE application server
+                LOGGER.info("JMS connection factory {} already deployed", jmsConnectionFactory.getName());
+                updateLog.addUpdateMessage(new UpdateMessage("info", "JMS connection factory
" + jmsConnectionFactory.getName() + " already deployed"));
+                EventUtils.post(environment, "UPDATE", "JMS connection factory " + jmsConnectionFactory.getName()
+ " already deployed");
+            } else {
+                // deploy the JMS connection factory
+                controller.deployJMSConnectionFactory(jmsConnectionFactory.getName());
+                updateLog.setStatus("Update performed");
+                updateLog.setUpdated(true);
+                updateLog.addUpdateMessage(new UpdateMessage("info", "JMS connection factory
" + jmsConnectionFactory.getName() + " deployed"));
+                EventUtils.post(environment, "UPDATE", "JMS connection factory " + jmsConnectionFactory.getName()
+ " deployed");
+                LOGGER.info("JMS connection factory {} deployed", jmsConnectionFactory.getName());
+            }
+        } catch (ControllerException e) {
+            LOGGER.error("JMS connection factory {} update failed", jmsConnectionFactory.getName(),
e);
+            throw new UpdateException("JMS connection factory " + jmsConnectionFactory.getName()
+ " update failed", e);
+        }
+    }
+
+    /**
+     * Wrapper method to update a JMS connection factory via WS.
+     *
+     * @param environmentName          the target environment name.
+     * @param serverName               the target J2EE application server name.
+     * @param jmsConnectionFactoryName the target JMS connection factory name.
+     * @throws KalumetException in case of update failure.
+     */
+    public static void update(String environmentName, String serverName, String jmsConnectionFactoryName)
throws KalumetException {
+        LOGGER.info("JMS connection factory {} update requested by WS", jmsConnectionFactoryName);
+
+        // load configuration.
+        LOGGER.debug("Loading configuration");
+        Kalumet kalumet = Kalumet.digeste(Configuration.CONFIG_LOCATION);
+
+        // looking for component objects
+        Environment environment = kalumet.getEnvironment(environmentName);
+        if (environment == null) {
+            LOGGER.error("Environment {} is not found in the configuration", environmentName);
+            throw new KalumetException("Environment " + environmentName + " is not found
in the configuration");
+        }
+        J2EEApplicationServer server = environment.getJ2EEApplicationServers().getJ2EEApplicationServer(serverName);
+        if (server == null) {
+            LOGGER.error("J2EE application server {} is not found in environment {}", serverName,
environment.getName());
+            throw new KalumetException("J2EE application server " + serverName + " is not
found in environment " + environment.getName());
+        }
+        JMSConnectionFactory jmsConnectionFactory = server.getJMSConnectionFactory(jmsConnectionFactoryName);
+        if (jmsConnectionFactory == null) {
+            LOGGER.error("JMS connection factory {} is not found in J2EE application server
{}", jmsConnectionFactoryName, server.getName());
+            throw new KalumetException("JMS connection factory " + jmsConnectionFactoryName
+ " is not found in J2EE application server " + server.getName());
+        }
+
+        // post event and create update log
+        LOGGER.debug("Posting event and creating update log");
+        EventUtils.post(environment, "UPDATE", "JMS connection factory " + jmsConnectionFactory.getName()
+ " update requested by WS");
+        UpdateLog updateLog = new UpdateLog("JMS connection factory " + jmsConnectionFactory.getName()
+ " update in progress ...", environment.getName(), environment);
+
+        // send a notification and waiting for the count down
+        LOGGER.debug("Send a notification and waiting for the count down");
+        EventUtils.post(environment, "UPDATE", "Send a notification and waiting for the count
down");
+        NotifierUtils.waitAndNotify(environment);
+
+        try {
+            // call update
+            LOGGER.debug("Call JMS connection factory updater");
+            JMSConnectionFactoryUpdater.update(environment, server, jmsConnectionFactory,
updateLog);
+        } catch (Exception e) {
+            LOGGER.error("JMS connection factory {} update failed", jmsConnectionFactory.getName(),
e);
+            EventUtils.post(environment, "ERROR", "JMS connection factory " + jmsConnectionFactory.getName()
+ " update failed: " + e.getMessage());
+            updateLog.setStatus("JMS connection factory " + jmsConnectionFactory.getName()
+ " update failed");
+            updateLog.addUpdateMessage(new UpdateMessage("error", "JMS connection factory
" + jmsConnectionFactory.getName() + " update failed: " + e.getMessage()));
+            PublisherUtils.publish(environment);
+            throw new UpdateException("JMS connection factory " + jmsConnectionFactory.getName()
+ " update failed", e);
+        }
+
+        // update completed.
+        LOGGER.info("JMS connection factory {} updated", jmsConnectionFactory.getName());
+        EventUtils.post(environment, "UPDATE", "JMS connection factory " + jmsConnectionFactory.getName()
+ " updated");
+        if (updateLog.isUpdated()) {
+            updateLog.setStatus("JMS connection factory " + jmsConnectionFactory.getName()
+ " updated");
+        } else {
+            updateLog.setStatus("JMS connection factory " + jmsConnectionFactory.getName()
+ " is already up to date");
+        }
+        updateLog.addUpdateMessage(new UpdateMessage("info", "JMS connection factory " +
jmsConnectionFactory.getName() + " updated"));
+        LOGGER.info("Publishing update report");
+        PublisherUtils.publish(environment);
+    }
+
+    /**
+     * Check a JMS connection factory via WS.
+     *
+     * @param environmentName          the target environment name.
+     * @param applicationServerName    the target J2EE application server name.
+     * @param jmsConnectionFactoryName the target JMS connection factory name.
+     * @return true if the JMS connection factory is up to date, false else.
+     * @throws KalumetException in case of check failure.
+     */
+    public static boolean check(String environmentName, String applicationServerName, String
jmsConnectionFactoryName) throws KalumetException {
+        LOGGER.info("JMS connection factory {} status check requested by WS", jmsConnectionFactoryName);
+
+        // load configuration.
+        LOGGER.debug("Loading configuration");
+        Kalumet kalumet = Kalumet.digeste(Configuration.CONFIG_LOCATION);
+
+        // looking for component objects
+        Environment environment = kalumet.getEnvironment(environmentName);
+        if (environment == null) {
+            LOGGER.error("Environment {} is not found in the configuration", environmentName);
+            throw new KalumetException("Environment " + environmentName + " is not found
in the configuration");
+        }
+        J2EEApplicationServer server = environment.getJ2EEApplicationServers().getJ2EEApplicationServer(applicationServerName);
+        if (server == null) {
+            LOGGER.error("J2EE application server {} is not found in environment {}", applicationServerName,
environment.getName());
+            throw new KalumetException("J2EE application server " + applicationServerName
+ " is not found in environment " + environment.getName());
+        }
+        JMSConnectionFactory jmsConnectionFactory = server.getJMSConnectionFactory(jmsConnectionFactoryName);
+        if (jmsConnectionFactory == null) {
+            LOGGER.error("JMS connection factory {} is not found in the J2EE application
server {}", jmsConnectionFactoryName, server.getName());
+            throw new KalumetException("JMS connection factory " + jmsConnectionFactoryName
+ " is not found in the J2EE application server " + server.getName());
+        }
+
+        // post an event
+        EventUtils.post(environment, "INFO", "JMS connection factory " + jmsConnectionFactory.getName()
+ " status check requested by WS");
+
+        try {
+            // get J2EE application server controller.
+            LOGGER.debug("Getting J2EE application server controller");
+            J2EEApplicationServerController controller = J2EEApplicationServerControllerFactory.getController(environment,
server);
+            // check if the JMS connection factory is deployed
+            LOGGER.debug("Check the status of the JMS connection factory " + jmsConnectionFactory.getName());
+            return controller.isJMSConnectionFactoryDeployed(jmsConnectionFactory.getName());
+        } catch (Exception e) {
+            LOGGER.error("JMS connection factory {} status check failed", jmsConnectionFactory.getName(),
e);
+            throw new KalumetException("JMS connection factory " + jmsConnectionFactory.getName()
+ " status check failed", e);
+        }
+    }
+
+}

Modified: incubator/kalumet/trunk/agent/src/main/java/org/apache/kalumet/agent/updater/SoftwareUpdater.java
URL: http://svn.apache.org/viewvc/incubator/kalumet/trunk/agent/src/main/java/org/apache/kalumet/agent/updater/SoftwareUpdater.java?rev=1194852&r1=1194851&r2=1194852&view=diff
==============================================================================
--- incubator/kalumet/trunk/agent/src/main/java/org/apache/kalumet/agent/updater/SoftwareUpdater.java
(original)
+++ incubator/kalumet/trunk/agent/src/main/java/org/apache/kalumet/agent/updater/SoftwareUpdater.java
Sat Oct 29 09:37:44 2011
@@ -371,7 +371,7 @@ public class SoftwareUpdater {
     public static void updateLocation(String environmentName, String softwareName, String
locationName, boolean delegation) throws KalumetException {
         LOGGER.info("Software {} location {} update requested by WS", softwareName, locationName);
 
-        // loading AutoDeploy configuration
+        // loading configuration
         LOGGER.debug("Loading configuration");
         Kalumet kalumet = Kalumet.digeste(Configuration.CONFIG_LOCATION);
         Environment environment = kalumet.getEnvironment(environmentName);

Modified: incubator/kalumet/trunk/pom.xml
URL: http://svn.apache.org/viewvc/incubator/kalumet/trunk/pom.xml?rev=1194852&r1=1194851&r2=1194852&view=diff
==============================================================================
--- incubator/kalumet/trunk/pom.xml (original)
+++ incubator/kalumet/trunk/pom.xml Sat Oct 29 09:37:44 2011
@@ -252,6 +252,11 @@
                 <version>${project.version}</version>
             </dependency>
             <dependency>
+                <groupId>org.apache.kalumet.controller</groupId>
+                <artifactId>org.apache.kalumet.controller.core</artifactId>
+                <version>${project.version}</version>
+            </dependency>
+            <dependency>
                 <groupId>org.apache.kalumet</groupId>
                 <artifactId>org.apache.kalumet.utils</artifactId>
                 <version>${project.version}</version>



Mime
View raw message