001    /**
002     * Licensed to the Apache Software Foundation (ASF) under one
003     * or more contributor license agreements.  See the NOTICE file
004     * distributed with this work for additional information
005     * regarding copyright ownership.  The ASF licenses this file
006     * to you under the Apache License, Version 2.0 (the
007     * "License"); you may not use this file except in compliance
008     * with the License.  You may obtain a copy of the License at
009     *
010     *      http://www.apache.org/licenses/LICENSE-2.0
011     *
012     * Unless required by applicable law or agreed to in writing, software
013     * distributed under the License is distributed on an "AS IS" BASIS,
014     * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
015     * See the License for the specific language governing permissions and
016     * limitations under the License.
017     */
018    package org.apache.oozie.jms;
019    
020    import javax.jms.ExceptionListener;
021    import javax.jms.JMSException;
022    
023    import org.apache.oozie.service.JMSAccessorService;
024    import org.apache.oozie.service.Services;
025    import org.apache.oozie.util.XLog;
026    
027    public class JMSExceptionListener implements ExceptionListener {
028    
029        private static XLog LOG = XLog.getLog(JMSExceptionListener.class);
030        private JMSConnectionInfo connInfo;
031        private ConnectionContext connCtxt;
032        private boolean retry;
033    
034        /**
035         * Create ExceptionLister for a JMS Connection
036         *
037         * @param connInfo Information to connect to the JMS compliant messaging service
038         * @param connCtxt The actual connection on which this listener will be registered
039         */
040        public JMSExceptionListener(JMSConnectionInfo connInfo, ConnectionContext connCtxt, boolean retry) {
041            this.connInfo = connInfo;
042            this.connCtxt = connCtxt;
043            this.retry = retry;
044        }
045    
046        @Override
047        public void onException(JMSException exception) {
048            LOG.warn("Received JMSException for [{0}]", connInfo, exception);
049            connCtxt.close();
050            if (retry) {
051                JMSAccessorService jmsService = Services.get().get(JMSAccessorService.class);
052                jmsService.reestablishConnection(connInfo);
053            }
054        }
055    
056    }