@@ -0,0 +1,2689 @@
+/*%0A *  eXist Open Source Native XML Database%0A *  Copyright (C) 2012 The eXist Project%0A *  http://exist-db.org%0A *%0A *  This program is free software; you can redistribute it and/or%0A *  modify it under the terms of the GNU Lesser General Public License%0A *  as published by the Free Software Foundation; either version 2%0A *  of the License, or (at your option) any later version.%0A *%0A *  This program is distributed in the hope that it will be useful,%0A *  but WITHOUT ANY WARRANTY; without even the implied warranty of%0A *  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the%0A *  GNU Lesser General Public License for more details.%0A *%0A *  You should have received a copy of the GNU Lesser General Public%0A *  License along with this library; if not, write to the Free Software%0A *  Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA  02110-1301  USA%0A */%0Apackage org.exist.jms.replication.subscribe;%0A%0Aimport java.util.List;%0Aimport java.util.Map;%0Aimport org.apache.log4j.Logger;%0Aimport org.exist.jms.shared.JmsConfiguration;%0Aimport org.exist.jms.shared.Receiver;%0Aimport org.exist.jms.shared.ReceiversManager;%0Aimport org.exist.storage.DBBroker;%0A%0A/**%0A * Startup Trigger to fire-up a message receiver. Typically this trigger is started by%0A * configuration in conf.xml%0A *%0A * @author Dannes Wessels%0A */%0Apublic class ReceiverStartupTrigger implements org.exist.storage.StartupTrigger %7B%0A%0A    private final static Logger LOG = Logger.getLogger(ReceiverStartupTrigger.class);%0A   %0A%0A    /*%0A     * Entry point for starting the trigger.%0A     */%0A    @Override%0A    public void execute(final DBBroker broker, final Map%3CString, List%3C? extends Object%3E%3E params) %7B%0A%0A        ReceiversManager manager = ReceiversManager.getInstance();%0A        %0A        // Get from .xconf file, fill defaults when needed%0A        SubscriberParameters parameters = new SubscriberParameters();%0A        parameters.setSingleValueParameters(params);%0A        %0A        try %7B%0A            // Get parameters, fill defaults when needed%0A            parameters.processParameters();%0A%0A            JmsConfiguration jmsConfig = new JmsConfiguration();%0A            jmsConfig.loadSubscriberParameters(parameters);%0A%0A            // Setup listeners%0A            ReplicationJmsListener jmsListener = new ReplicationJmsListener(broker.getBrokerPool());%0A%0A            Receiver receiver = new Receiver(jmsConfig, jmsListener);%0A            manager.register(receiver);%0A%0A            receiver.initialize();%0A            receiver.start();%0A%0A            LOG.info(%22Subscription was successful.%22);%0A%0A        %7D catch (final Throwable t) %7B            %0A            LOG.error(String.format(%22Unable to start subscription: %25s%22, t.getMessage()), t);%0A        %7D%0A    %7D%0A%0A%7D%0A

Rename Class, hinted by check style