Modified: cocoon/branches/BRANCH_2_1_X/src/blocks/jms/java/org/apache/cocoon/components/jms/AbstractMessagePublisher.java URL: http://svn.apache.org/viewcvs/cocoon/branches/BRANCH_2_1_X/src/blocks/jms/java/org/apache/cocoon/components/jms/AbstractMessagePublisher.java?view=diff&r1=158724&r2=158725 ============================================================================== --- cocoon/branches/BRANCH_2_1_X/src/blocks/jms/java/org/apache/cocoon/components/jms/AbstractMessagePublisher.java (original) +++ cocoon/branches/BRANCH_2_1_X/src/blocks/jms/java/org/apache/cocoon/components/jms/AbstractMessagePublisher.java Tue Mar 22 20:01:09 2005 @@ -1,194 +1,194 @@ -/* - * Copyright 1999-2004 The Apache Software Foundation. - * - * Licensed 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.cocoon.components.jms; - -import javax.jms.DeliveryMode; -import javax.jms.JMSException; -import javax.jms.Message; -import javax.jms.Session; -import javax.jms.Topic; -import javax.jms.TopicConnection; -import javax.jms.TopicPublisher; -import javax.jms.TopicSession; - -import org.apache.avalon.framework.activity.Disposable; -import org.apache.avalon.framework.activity.Initializable; -import org.apache.avalon.framework.logger.AbstractLogEnabled; -import org.apache.avalon.framework.parameters.ParameterException; -import org.apache.avalon.framework.parameters.Parameterizable; -import org.apache.avalon.framework.parameters.Parameters; -import org.apache.avalon.framework.service.ServiceException; -import org.apache.avalon.framework.service.ServiceManager; -import org.apache.avalon.framework.service.Serviceable; - -/** - * Abstract JMS message publisher. Use this as a basis for components - * that want to publish JMS messages. - * - * <p>Parameters:</p> - * <table border="1"> - * <tbody> - * <tr> - * <th align="left">parameter</th> - * <th align="left">required</th> - * <th align="left">default</th> - * <th align="left">description</th> - * </tr> - * <tr> - * <td valign="top">connection</td> - * <td valign="top">yes</td> - * <td> </td> - * <td valign="top"> - * Name of the connection registered with - * [EMAIL PROTECTED] org.apache.cocoon.components.jms.JMSConnectionManager}. - * This must be a topic connection. - * </td> - * </tr> - * <tr> - * <td valign="top">topic</td> - * <td valign="top">yes</td> - * <td> </td> - * <td valign="top">The name of the topic to publish messages to.</td> - * </tr> - * <tr> - * <td valign="top">priority</td> - * <td valign="top">no</td> - * <td>4</td> - * <td valign="top">the priority of the published messages</td> - * </tr> - * <tr> - * <td valign="top">time-to-live</td> - * <td valign="top">no</td> - * <td>10000</td> - * <td valign="top">the message's lifetime in milliseconds</td> - * </tr> - * <tr> - * <td valign="top">persistent-delivery</td> - * <td valign="top">no</td> - * <td>false</td> - * <td valign="top">whether to use persistent delivery mode when publishing messages</td> - * </tr> - * </tbody> - * </table> - * - * @version CVS $Id: AbstractMessagePublisher.java 30941 2004-07-29 19:56:58Z vgritsenko $ - */ -public abstract class AbstractMessagePublisher extends AbstractLogEnabled -implements Serviceable, Parameterizable, Initializable, Disposable { - - // ---------------------------------------------------- Constants - - private static final String CONNECTION_PARAM = "connection"; - private static final String TOPIC_PARAM = "topic"; - private static final String PRIORITY_PARAM = "priority"; - private static final String TIME_TO_LIVE_PARAM = "time-to-live"; - private static final String PERSISTENT_DELIVERY_PARAM = "persistent-delivery"; - - private static final int DEFAULT_PRIORITY = 4; - private static final int DEFAULT_TIME_TO_LIVE = 10000; - - // ---------------------------------------------------- Instance variables - - private ServiceManager m_manager; - private JMSConnectionManager m_connectionManager; - - protected TopicSession m_session; - protected TopicPublisher m_publisher; - - private int m_mode; - private int m_priority; - private int m_timeToLive; - private String m_topicName; - private int m_acknowledgeMode; - - private String m_connectionName; - - // ---------------------------------------------------- Lifecycle - - public AbstractMessagePublisher() { - } - - public void service(ServiceManager manager) throws ServiceException { - m_manager = manager; - m_connectionManager = (JMSConnectionManager) m_manager.lookup(JMSConnectionManager.ROLE); - } - - public void parameterize(Parameters parameters) throws ParameterException { - m_connectionName = parameters.getParameter(CONNECTION_PARAM); - m_topicName = parameters.getParameter(TOPIC_PARAM); - m_priority = parameters.getParameterAsInteger(PRIORITY_PARAM, DEFAULT_PRIORITY); - boolean persistent = parameters.getParameterAsBoolean(PERSISTENT_DELIVERY_PARAM, false); - m_mode = (persistent ? DeliveryMode.PERSISTENT : DeliveryMode.NON_PERSISTENT); - m_timeToLive = parameters.getParameterAsInteger(TIME_TO_LIVE_PARAM, DEFAULT_TIME_TO_LIVE); - } - - public void initialize() throws Exception { - - // set the default acknowledge mode - // concrete implementations may override this - m_acknowledgeMode = Session.DUPS_OK_ACKNOWLEDGE; - - // create the message publisher - final TopicConnection connection = (TopicConnection) m_connectionManager.getConnection(m_connectionName); - if (connection != null) { - m_session = connection.createTopicSession(false, m_acknowledgeMode); - final Topic topic = m_session.createTopic(m_topicName); - m_publisher = m_session.createPublisher(topic); - } - else { - if (getLogger().isWarnEnabled()) { - getLogger().warn("Could not obtain JMS connection '" + m_connectionName + "'"); - } - } - - } - - public void dispose() { - if (m_publisher != null) { - try { - m_publisher.close(); - } catch (JMSException e) { - getLogger().error("Error closing publisher.", e); - } - } - if (m_session != null) { - try { - m_session.close(); - } - catch (JMSException e) { - getLogger().warn("Error closing session.", e); - } - } - if (m_manager != null) { - if (m_connectionManager != null) { - m_manager.release(m_connectionManager); - } - } - } - - // ---------------------------------------------------- Implementation - - /** - * Concrete classes call this method to publish messages. - */ - protected synchronized void publishMessage(Message message) throws JMSException { - if (getLogger().isDebugEnabled()) { - getLogger().debug("Publishing message '" + message + "'"); - } - m_publisher.publish(message, m_mode, m_priority, m_timeToLive); - } - -} +/* + * Copyright 1999-2004 The Apache Software Foundation. + * + * Licensed 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.cocoon.components.jms; + +import javax.jms.DeliveryMode; +import javax.jms.JMSException; +import javax.jms.Message; +import javax.jms.Session; +import javax.jms.Topic; +import javax.jms.TopicConnection; +import javax.jms.TopicPublisher; +import javax.jms.TopicSession; + +import org.apache.avalon.framework.activity.Disposable; +import org.apache.avalon.framework.activity.Initializable; +import org.apache.avalon.framework.logger.AbstractLogEnabled; +import org.apache.avalon.framework.parameters.ParameterException; +import org.apache.avalon.framework.parameters.Parameterizable; +import org.apache.avalon.framework.parameters.Parameters; +import org.apache.avalon.framework.service.ServiceException; +import org.apache.avalon.framework.service.ServiceManager; +import org.apache.avalon.framework.service.Serviceable; + +/** + * Abstract JMS message publisher. Use this as a basis for components + * that want to publish JMS messages. + * + * <p>Parameters:</p> + * <table border="1"> + * <tbody> + * <tr> + * <th align="left">parameter</th> + * <th align="left">required</th> + * <th align="left">default</th> + * <th align="left">description</th> + * </tr> + * <tr> + * <td valign="top">connection</td> + * <td valign="top">yes</td> + * <td> </td> + * <td valign="top"> + * Name of the connection registered with + * [EMAIL PROTECTED] org.apache.cocoon.components.jms.JMSConnectionManager}. + * This must be a topic connection. + * </td> + * </tr> + * <tr> + * <td valign="top">topic</td> + * <td valign="top">yes</td> + * <td> </td> + * <td valign="top">The name of the topic to publish messages to.</td> + * </tr> + * <tr> + * <td valign="top">priority</td> + * <td valign="top">no</td> + * <td>4</td> + * <td valign="top">the priority of the published messages</td> + * </tr> + * <tr> + * <td valign="top">time-to-live</td> + * <td valign="top">no</td> + * <td>10000</td> + * <td valign="top">the message's lifetime in milliseconds</td> + * </tr> + * <tr> + * <td valign="top">persistent-delivery</td> + * <td valign="top">no</td> + * <td>false</td> + * <td valign="top">whether to use persistent delivery mode when publishing messages</td> + * </tr> + * </tbody> + * </table> + * + * @version CVS $Id: AbstractMessagePublisher.java 30941 2004-07-29 19:56:58Z vgritsenko $ + */ +public abstract class AbstractMessagePublisher extends AbstractLogEnabled +implements Serviceable, Parameterizable, Initializable, Disposable { + + // ---------------------------------------------------- Constants + + private static final String CONNECTION_PARAM = "connection"; + private static final String TOPIC_PARAM = "topic"; + private static final String PRIORITY_PARAM = "priority"; + private static final String TIME_TO_LIVE_PARAM = "time-to-live"; + private static final String PERSISTENT_DELIVERY_PARAM = "persistent-delivery"; + + private static final int DEFAULT_PRIORITY = 4; + private static final int DEFAULT_TIME_TO_LIVE = 10000; + + // ---------------------------------------------------- Instance variables + + private ServiceManager m_manager; + private JMSConnectionManager m_connectionManager; + + protected TopicSession m_session; + protected TopicPublisher m_publisher; + + private int m_mode; + private int m_priority; + private int m_timeToLive; + private String m_topicName; + private int m_acknowledgeMode; + + private String m_connectionName; + + // ---------------------------------------------------- Lifecycle + + public AbstractMessagePublisher() { + } + + public void service(ServiceManager manager) throws ServiceException { + m_manager = manager; + m_connectionManager = (JMSConnectionManager) m_manager.lookup(JMSConnectionManager.ROLE); + } + + public void parameterize(Parameters parameters) throws ParameterException { + m_connectionName = parameters.getParameter(CONNECTION_PARAM); + m_topicName = parameters.getParameter(TOPIC_PARAM); + m_priority = parameters.getParameterAsInteger(PRIORITY_PARAM, DEFAULT_PRIORITY); + boolean persistent = parameters.getParameterAsBoolean(PERSISTENT_DELIVERY_PARAM, false); + m_mode = (persistent ? DeliveryMode.PERSISTENT : DeliveryMode.NON_PERSISTENT); + m_timeToLive = parameters.getParameterAsInteger(TIME_TO_LIVE_PARAM, DEFAULT_TIME_TO_LIVE); + } + + public void initialize() throws Exception { + + // set the default acknowledge mode + // concrete implementations may override this + m_acknowledgeMode = Session.DUPS_OK_ACKNOWLEDGE; + + // create the message publisher + final TopicConnection connection = (TopicConnection) m_connectionManager.getConnection(m_connectionName); + if (connection != null) { + m_session = connection.createTopicSession(false, m_acknowledgeMode); + final Topic topic = m_session.createTopic(m_topicName); + m_publisher = m_session.createPublisher(topic); + } + else { + if (getLogger().isWarnEnabled()) { + getLogger().warn("Could not obtain JMS connection '" + m_connectionName + "'"); + } + } + + } + + public void dispose() { + if (m_publisher != null) { + try { + m_publisher.close(); + } catch (JMSException e) { + getLogger().error("Error closing publisher.", e); + } + } + if (m_session != null) { + try { + m_session.close(); + } + catch (JMSException e) { + getLogger().warn("Error closing session.", e); + } + } + if (m_manager != null) { + if (m_connectionManager != null) { + m_manager.release(m_connectionManager); + } + } + } + + // ---------------------------------------------------- Implementation + + /** + * Concrete classes call this method to publish messages. + */ + protected synchronized void publishMessage(Message message) throws JMSException { + if (getLogger().isDebugEnabled()) { + getLogger().debug("Publishing message '" + message + "'"); + } + m_publisher.publish(message, m_mode, m_priority, m_timeToLive); + } + +}
Modified: cocoon/branches/BRANCH_2_1_X/src/blocks/jms/java/org/apache/cocoon/components/jms/JMSConnectionManager.java URL: http://svn.apache.org/viewcvs/cocoon/branches/BRANCH_2_1_X/src/blocks/jms/java/org/apache/cocoon/components/jms/JMSConnectionManager.java?view=diff&r1=158724&r2=158725 ============================================================================== --- cocoon/branches/BRANCH_2_1_X/src/blocks/jms/java/org/apache/cocoon/components/jms/JMSConnectionManager.java (original) +++ cocoon/branches/BRANCH_2_1_X/src/blocks/jms/java/org/apache/cocoon/components/jms/JMSConnectionManager.java Tue Mar 22 20:01:09 2005 @@ -1,29 +1,29 @@ -/* - * Copyright 1999-2004 The Apache Software Foundation. - * - * Licensed 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.cocoon.components.jms; - -import javax.jms.Connection; - -/** - * Manages a set of JMS Connections. - */ -public interface JMSConnectionManager { - - public static final String ROLE = JMSConnectionManager.class.getName(); - - public Connection getConnection(String name); - -} +/* + * Copyright 1999-2004 The Apache Software Foundation. + * + * Licensed 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.cocoon.components.jms; + +import javax.jms.Connection; + +/** + * Manages a set of JMS Connections. + */ +public interface JMSConnectionManager { + + public static final String ROLE = JMSConnectionManager.class.getName(); + + public Connection getConnection(String name); + +} Modified: cocoon/branches/BRANCH_2_1_X/src/blocks/jms/java/org/apache/cocoon/components/jms/JMSConnectionManagerImpl.java URL: http://svn.apache.org/viewcvs/cocoon/branches/BRANCH_2_1_X/src/blocks/jms/java/org/apache/cocoon/components/jms/JMSConnectionManagerImpl.java?view=diff&r1=158724&r2=158725 ============================================================================== --- cocoon/branches/BRANCH_2_1_X/src/blocks/jms/java/org/apache/cocoon/components/jms/JMSConnectionManagerImpl.java (original) +++ cocoon/branches/BRANCH_2_1_X/src/blocks/jms/java/org/apache/cocoon/components/jms/JMSConnectionManagerImpl.java Tue Mar 22 20:01:09 2005 @@ -1,308 +1,308 @@ -/* - * Copyright 1999-2004 The Apache Software Foundation. - * - * Licensed 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.cocoon.components.jms; - -import java.util.HashMap; -import java.util.Iterator; -import java.util.Map; -import java.util.Properties; - -import javax.jms.Connection; -import javax.jms.ConnectionFactory; -import javax.jms.JMSException; -import javax.jms.QueueConnection; -import javax.jms.QueueConnectionFactory; -import javax.jms.TopicConnection; -import javax.jms.TopicConnectionFactory; -import javax.naming.InitialContext; -import javax.naming.NamingException; - -import org.apache.cocoon.components.jms.JMSConnectionManager; - -import org.apache.avalon.framework.activity.Disposable; -import org.apache.avalon.framework.activity.Initializable; -import org.apache.avalon.framework.activity.Startable; -import org.apache.avalon.framework.configuration.Configurable; -import org.apache.avalon.framework.configuration.Configuration; -import org.apache.avalon.framework.configuration.ConfigurationException; -import org.apache.avalon.framework.logger.AbstractLogEnabled; -import org.apache.avalon.framework.parameters.ParameterException; -import org.apache.avalon.framework.parameters.Parameters; -import org.apache.avalon.framework.thread.ThreadSafe; - -/** - * [EMAIL PROTECTED] org.apache.cocoon.components.jms.JMSConnectionManager} implementation. - */ -public class JMSConnectionManagerImpl extends AbstractLogEnabled -implements JMSConnectionManager, Configurable, Initializable, Startable, Disposable, ThreadSafe { - - // ---------------------------------------------------- Constants - - private static final int TOPIC_CONNECTION_TYPE = 1; - private static final int QUEUE_CONNECTION_TYPE = 2; - private static final int CONNECTION_TYPE = 3; - - private static final String CONNECTION_CONFIG = "connection"; - private static final String TOPIC_CONNECTION_CONFIG = "topic-connection"; - private static final String QUEUE_CONNECTION_CONFIG = "queue-connection"; - private static final String NAME_ATTR = "name"; - - private static final String CONNECTION_FACTORY_PARAM = "connection-factory"; - private static final String USERNAME_PARAM = "username"; - private static final String PASSWORD_PARAM = "password"; - - private static final String JNDI_PROPERTY_PREFIX = "java.naming."; - - // ---------------------------------------------------- Instance variables - - private Map m_configurations; - private Map m_connections; - - // ---------------------------------------------------- Lifecycle - - public JMSConnectionManagerImpl() { - } - - public void configure(Configuration configuration) throws ConfigurationException { - m_configurations = new HashMap(configuration.getChildren().length); - // <connection>s - Configuration[] configurations = configuration.getChildren(CONNECTION_CONFIG); - configureConnections(configurations, CONNECTION_TYPE); - // <topic-connection>s - configurations = configuration.getChildren(TOPIC_CONNECTION_CONFIG); - configureConnections(configurations, TOPIC_CONNECTION_TYPE); - // <queue-connection>s - configurations = configuration.getChildren(QUEUE_CONNECTION_CONFIG); - configureConnections(configurations, QUEUE_CONNECTION_TYPE); - } - - private void configureConnections(Configuration[] connections, int type) throws ConfigurationException { - for (int i = 0; i < connections.length; i++) { - final String name = connections[i].getAttribute(NAME_ATTR); - if (m_configurations.containsKey(name)) { - throw new ConfigurationException("Duplicate connection name '" + name + "'." + - " Connection names must be unique."); - } - final Parameters parameters = Parameters.fromConfiguration(connections[i]); - ConnectionConfiguration cc = new ConnectionConfiguration(name, parameters, type); - m_configurations.put(name, cc); - } - } - - public void initialize() throws Exception { - m_connections = new HashMap(m_configurations.size()); - final Iterator iter = m_configurations.values().iterator(); - try { - while (iter.hasNext()) { - final ConnectionConfiguration cc = (ConnectionConfiguration) iter.next(); - final InitialContext context = createInitialContext(cc.getJNDIProperties()); - final ConnectionFactory factory = (ConnectionFactory) context.lookup(cc.getConnectionFactory()); - final Connection connection = createConnection(factory, cc); - m_connections.put(cc.getName(), connection); - } - } - catch (NamingException e) { - if (getLogger().isWarnEnabled()) { - Throwable rootCause = e.getRootCause(); - if (rootCause != null) { - String message = e.getRootCause().getMessage(); - if (rootCause instanceof ClassNotFoundException) { - String info = "WARN! *** JMS block is installed but jms client library not found. ***\n" + - "- For the jms block to work you must install and start a JMS server and " + - "place the client jar in WEB-INF/lib."; - if (message.indexOf("exolab") > 0 ) { - info += "\n- The default server, OpenJMS is configured in cocoon.xconf but is not bundled with Cocoon."; - } - System.err.println(info); - getLogger().warn(info,e); - } else { - System.out.println(message); - getLogger().warn("Cannot get Initial Context. Is the JNDI server reachable?",e); - } - } - else { - getLogger().warn("Failed to initialize JMS.",e); - } - } - } - m_configurations = null; - } - - public void start() throws Exception { - final Iterator iter = m_connections.entrySet().iterator(); - while (iter.hasNext()) { - final Map.Entry entry = (Map.Entry) iter.next(); - if (getLogger().isDebugEnabled()) { - getLogger().debug("Starting JMS connection " + entry.getKey()); - } - final Connection connection = (Connection) entry.getValue(); - connection.start(); - } - } - - public void stop() throws Exception { - final Iterator iter = m_connections.entrySet().iterator(); - while (iter.hasNext()) { - final Map.Entry entry = (Map.Entry) iter.next(); - if (getLogger().isDebugEnabled()) { - getLogger().debug("Stopping JMS connection " + entry.getKey()); - } - try { - final Connection connection = (Connection) entry.getValue(); - connection.stop(); - } - catch (JMSException e) { - getLogger().error("Error stopping JMS connection " + entry.getKey(), e); - } - } - } - - public void dispose() { - final Iterator iter = m_connections.entrySet().iterator(); - while (iter.hasNext()) { - final Map.Entry entry = (Map.Entry) iter.next(); - if (getLogger().isDebugEnabled()) { - getLogger().debug("Closing JMS connection " + entry.getKey()); - } - try { - final Connection connection = (Connection) entry.getValue(); - connection.close(); - } - catch (JMSException e) { - getLogger().error("Error closing JMS connection " + entry.getKey(), e); - } - } - } - - // ---------------------------------------------------- ConnectionManager - - public Connection getConnection(String name) { - return (Connection) m_connections.get(name); - } - - public TopicConnection getTopicConnection(String name) { - return (TopicConnection) m_connections.get(name); - } - - public QueueConnection getQueueConnection(String name) { - return (QueueConnection) m_connections.get(name); - } - - // ---------------------------------------------------- Implementation - - private InitialContext createInitialContext(Properties properties) throws NamingException { - if (properties != null) { - return new InitialContext(properties); - } - return new InitialContext(); - } - - private Connection createConnection(ConnectionFactory factory, ConnectionConfiguration cc) throws JMSException { - if (cc.getUserName() != null) { - switch (cc.getType()) { - case CONNECTION_TYPE: { - return factory.createConnection(cc.getUserName(), cc.getPassword()); - } - case TOPIC_CONNECTION_TYPE: { - TopicConnectionFactory topicFactory = (TopicConnectionFactory) factory; - return topicFactory.createTopicConnection(cc.getUserName(), cc.getPassword()); - } - case QUEUE_CONNECTION_TYPE: { - QueueConnectionFactory queueFactory = (QueueConnectionFactory) factory; - return queueFactory.createQueueConnection(cc.getUserName(), cc.getPassword()); - } - } - } - switch (cc.getType()) { - case CONNECTION_TYPE: { - return factory.createConnection(); - } - case TOPIC_CONNECTION_TYPE: { - TopicConnectionFactory topicFactory = (TopicConnectionFactory) factory; - return topicFactory.createTopicConnection(); - } - case QUEUE_CONNECTION_TYPE: { - QueueConnectionFactory queueFactory = (QueueConnectionFactory) factory; - return queueFactory.createQueueConnection(); - } - } - return null; - } - - private static final class ConnectionConfiguration { - - // ------------------------------------------------ Instance variables - - private final String m_name; - private final int m_type; - private final String m_connectionFactory; - private final String m_username; - private final String m_password; - private Properties m_jndiProperties = new Properties(); - - private ConnectionConfiguration(String name, Parameters parameters, int type) - throws ConfigurationException { - m_name = name; - try { - m_connectionFactory = parameters.getParameter(CONNECTION_FACTORY_PARAM); - m_username = parameters.getParameter(USERNAME_PARAM, null); - m_password = parameters.getParameter(PASSWORD_PARAM, null); - - // parse the jndi property parameters - String[] names = parameters.getNames(); - for (int i = 0; i < names.length; i++) { - if (names[i].startsWith(JNDI_PROPERTY_PREFIX)) { - m_jndiProperties.put(names[i], parameters.getParameter(names[i])); - } - } - } - catch (ParameterException e) { - throw new ConfigurationException(e.getLocalizedMessage()); - } - m_type = type; - } - - private String getName() { - return m_name; - } - - private int getType() { - return m_type; - } - - private Properties getJNDIProperties() { - return m_jndiProperties; - } - - private String getConnectionFactory() { - return m_connectionFactory; - } - - private String getUserName() { - return m_username; - } - - private String getPassword() { - return m_password; - } - - public int hashCode() { - return m_name.hashCode(); - } - - } - -} +/* + * Copyright 1999-2004 The Apache Software Foundation. + * + * Licensed 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.cocoon.components.jms; + +import java.util.HashMap; +import java.util.Iterator; +import java.util.Map; +import java.util.Properties; + +import javax.jms.Connection; +import javax.jms.ConnectionFactory; +import javax.jms.JMSException; +import javax.jms.QueueConnection; +import javax.jms.QueueConnectionFactory; +import javax.jms.TopicConnection; +import javax.jms.TopicConnectionFactory; +import javax.naming.InitialContext; +import javax.naming.NamingException; + +import org.apache.cocoon.components.jms.JMSConnectionManager; + +import org.apache.avalon.framework.activity.Disposable; +import org.apache.avalon.framework.activity.Initializable; +import org.apache.avalon.framework.activity.Startable; +import org.apache.avalon.framework.configuration.Configurable; +import org.apache.avalon.framework.configuration.Configuration; +import org.apache.avalon.framework.configuration.ConfigurationException; +import org.apache.avalon.framework.logger.AbstractLogEnabled; +import org.apache.avalon.framework.parameters.ParameterException; +import org.apache.avalon.framework.parameters.Parameters; +import org.apache.avalon.framework.thread.ThreadSafe; + +/** + * [EMAIL PROTECTED] org.apache.cocoon.components.jms.JMSConnectionManager} implementation. + */ +public class JMSConnectionManagerImpl extends AbstractLogEnabled +implements JMSConnectionManager, Configurable, Initializable, Startable, Disposable, ThreadSafe { + + // ---------------------------------------------------- Constants + + private static final int TOPIC_CONNECTION_TYPE = 1; + private static final int QUEUE_CONNECTION_TYPE = 2; + private static final int CONNECTION_TYPE = 3; + + private static final String CONNECTION_CONFIG = "connection"; + private static final String TOPIC_CONNECTION_CONFIG = "topic-connection"; + private static final String QUEUE_CONNECTION_CONFIG = "queue-connection"; + private static final String NAME_ATTR = "name"; + + private static final String CONNECTION_FACTORY_PARAM = "connection-factory"; + private static final String USERNAME_PARAM = "username"; + private static final String PASSWORD_PARAM = "password"; + + private static final String JNDI_PROPERTY_PREFIX = "java.naming."; + + // ---------------------------------------------------- Instance variables + + private Map m_configurations; + private Map m_connections; + + // ---------------------------------------------------- Lifecycle + + public JMSConnectionManagerImpl() { + } + + public void configure(Configuration configuration) throws ConfigurationException { + m_configurations = new HashMap(configuration.getChildren().length); + // <connection>s + Configuration[] configurations = configuration.getChildren(CONNECTION_CONFIG); + configureConnections(configurations, CONNECTION_TYPE); + // <topic-connection>s + configurations = configuration.getChildren(TOPIC_CONNECTION_CONFIG); + configureConnections(configurations, TOPIC_CONNECTION_TYPE); + // <queue-connection>s + configurations = configuration.getChildren(QUEUE_CONNECTION_CONFIG); + configureConnections(configurations, QUEUE_CONNECTION_TYPE); + } + + private void configureConnections(Configuration[] connections, int type) throws ConfigurationException { + for (int i = 0; i < connections.length; i++) { + final String name = connections[i].getAttribute(NAME_ATTR); + if (m_configurations.containsKey(name)) { + throw new ConfigurationException("Duplicate connection name '" + name + "'." + + " Connection names must be unique."); + } + final Parameters parameters = Parameters.fromConfiguration(connections[i]); + ConnectionConfiguration cc = new ConnectionConfiguration(name, parameters, type); + m_configurations.put(name, cc); + } + } + + public void initialize() throws Exception { + m_connections = new HashMap(m_configurations.size()); + final Iterator iter = m_configurations.values().iterator(); + try { + while (iter.hasNext()) { + final ConnectionConfiguration cc = (ConnectionConfiguration) iter.next(); + final InitialContext context = createInitialContext(cc.getJNDIProperties()); + final ConnectionFactory factory = (ConnectionFactory) context.lookup(cc.getConnectionFactory()); + final Connection connection = createConnection(factory, cc); + m_connections.put(cc.getName(), connection); + } + } + catch (NamingException e) { + if (getLogger().isWarnEnabled()) { + Throwable rootCause = e.getRootCause(); + if (rootCause != null) { + String message = e.getRootCause().getMessage(); + if (rootCause instanceof ClassNotFoundException) { + String info = "WARN! *** JMS block is installed but jms client library not found. ***\n" + + "- For the jms block to work you must install and start a JMS server and " + + "place the client jar in WEB-INF/lib."; + if (message.indexOf("exolab") > 0 ) { + info += "\n- The default server, OpenJMS is configured in cocoon.xconf but is not bundled with Cocoon."; + } + System.err.println(info); + getLogger().warn(info,e); + } else { + System.out.println(message); + getLogger().warn("Cannot get Initial Context. Is the JNDI server reachable?",e); + } + } + else { + getLogger().warn("Failed to initialize JMS.",e); + } + } + } + m_configurations = null; + } + + public void start() throws Exception { + final Iterator iter = m_connections.entrySet().iterator(); + while (iter.hasNext()) { + final Map.Entry entry = (Map.Entry) iter.next(); + if (getLogger().isDebugEnabled()) { + getLogger().debug("Starting JMS connection " + entry.getKey()); + } + final Connection connection = (Connection) entry.getValue(); + connection.start(); + } + } + + public void stop() throws Exception { + final Iterator iter = m_connections.entrySet().iterator(); + while (iter.hasNext()) { + final Map.Entry entry = (Map.Entry) iter.next(); + if (getLogger().isDebugEnabled()) { + getLogger().debug("Stopping JMS connection " + entry.getKey()); + } + try { + final Connection connection = (Connection) entry.getValue(); + connection.stop(); + } + catch (JMSException e) { + getLogger().error("Error stopping JMS connection " + entry.getKey(), e); + } + } + } + + public void dispose() { + final Iterator iter = m_connections.entrySet().iterator(); + while (iter.hasNext()) { + final Map.Entry entry = (Map.Entry) iter.next(); + if (getLogger().isDebugEnabled()) { + getLogger().debug("Closing JMS connection " + entry.getKey()); + } + try { + final Connection connection = (Connection) entry.getValue(); + connection.close(); + } + catch (JMSException e) { + getLogger().error("Error closing JMS connection " + entry.getKey(), e); + } + } + } + + // ---------------------------------------------------- ConnectionManager + + public Connection getConnection(String name) { + return (Connection) m_connections.get(name); + } + + public TopicConnection getTopicConnection(String name) { + return (TopicConnection) m_connections.get(name); + } + + public QueueConnection getQueueConnection(String name) { + return (QueueConnection) m_connections.get(name); + } + + // ---------------------------------------------------- Implementation + + private InitialContext createInitialContext(Properties properties) throws NamingException { + if (properties != null) { + return new InitialContext(properties); + } + return new InitialContext(); + } + + private Connection createConnection(ConnectionFactory factory, ConnectionConfiguration cc) throws JMSException { + if (cc.getUserName() != null) { + switch (cc.getType()) { + case CONNECTION_TYPE: { + return factory.createConnection(cc.getUserName(), cc.getPassword()); + } + case TOPIC_CONNECTION_TYPE: { + TopicConnectionFactory topicFactory = (TopicConnectionFactory) factory; + return topicFactory.createTopicConnection(cc.getUserName(), cc.getPassword()); + } + case QUEUE_CONNECTION_TYPE: { + QueueConnectionFactory queueFactory = (QueueConnectionFactory) factory; + return queueFactory.createQueueConnection(cc.getUserName(), cc.getPassword()); + } + } + } + switch (cc.getType()) { + case CONNECTION_TYPE: { + return factory.createConnection(); + } + case TOPIC_CONNECTION_TYPE: { + TopicConnectionFactory topicFactory = (TopicConnectionFactory) factory; + return topicFactory.createTopicConnection(); + } + case QUEUE_CONNECTION_TYPE: { + QueueConnectionFactory queueFactory = (QueueConnectionFactory) factory; + return queueFactory.createQueueConnection(); + } + } + return null; + } + + private static final class ConnectionConfiguration { + + // ------------------------------------------------ Instance variables + + private final String m_name; + private final int m_type; + private final String m_connectionFactory; + private final String m_username; + private final String m_password; + private Properties m_jndiProperties = new Properties(); + + private ConnectionConfiguration(String name, Parameters parameters, int type) + throws ConfigurationException { + m_name = name; + try { + m_connectionFactory = parameters.getParameter(CONNECTION_FACTORY_PARAM); + m_username = parameters.getParameter(USERNAME_PARAM, null); + m_password = parameters.getParameter(PASSWORD_PARAM, null); + + // parse the jndi property parameters + String[] names = parameters.getNames(); + for (int i = 0; i < names.length; i++) { + if (names[i].startsWith(JNDI_PROPERTY_PREFIX)) { + m_jndiProperties.put(names[i], parameters.getParameter(names[i])); + } + } + } + catch (ParameterException e) { + throw new ConfigurationException(e.getLocalizedMessage()); + } + m_type = type; + } + + private String getName() { + return m_name; + } + + private int getType() { + return m_type; + } + + private Properties getJNDIProperties() { + return m_jndiProperties; + } + + private String getConnectionFactory() { + return m_connectionFactory; + } + + private String getUserName() { + return m_username; + } + + private String getPassword() { + return m_password; + } + + public int hashCode() { + return m_name.hashCode(); + } + + } + +}
