/*
 * Copyright (c) 2000, 2017 Oracle and/or its affiliates. All rights reserved.
 *
 * This program and the accompanying materials are made available under the
 * terms of the Eclipse Public License v. 2.0, which is available at
 * http://www.eclipse.org/legal/epl-2.0.
 *
 * This Source Code may also be made available under the following Secondary
 * Licenses when the conditions for such availability set forth in the
 * Eclipse Public License v. 2.0 are satisfied: GNU General Public License,
 * version 2 with the GNU Classpath Exception, which is available at
 * https://www.gnu.org/software/classpath/license.html.
 *
 * SPDX-License-Identifier: EPL-2.0 OR GPL-2.0 WITH Classpath-exception-2.0
 */

/*
 * @(#)ResumeHandler.java	1.23 06/28/07
 */

package com.sun.messaging.jmq.jmsserver.data.handlers.admin;

import java.util.Hashtable;
import java.util.Iterator;

import com.sun.messaging.jmq.io.Packet;
import com.sun.messaging.jmq.io.PacketType;
import com.sun.messaging.jmq.io.Status;
import com.sun.messaging.jmq.util.admin.MessageType;
import com.sun.messaging.jmq.util.log.Logger;
import com.sun.messaging.jmq.util.DestType;
import com.sun.messaging.jmq.jmsserver.core.Destination;

import com.sun.messaging.jmq.jmsserver.Globals;
import com.sun.messaging.jmq.jmsserver.service.imq.IMQConnection;
import com.sun.messaging.jmq.jmsserver.resources.*;

public class ResumeHandler extends AdminCmdHandler {
    private static boolean DEBUG = getDEBUG();

    public ResumeHandler(AdminDataHandler parent) {
        super(parent);
    }

    /**
     * Handle the incomming administration message.
     *
     * @param con The Connection the message came in on.
     * @param cmd_msg The administration message
     * @param cmd_props The properties from the administration message
     */
    @Override
    public boolean handle(IMQConnection con, Packet cmd_msg, Hashtable cmd_props) {

        if (DEBUG) {
            logger.log(Logger.DEBUG, this.getClass().getName() + ": " + "Resuming: " + cmd_props);
        }

        String pauseTarget = (String) cmd_props.get(MessageType.JMQ_PAUSE_TARGET);
        String service = (String) cmd_props.get(MessageType.JMQ_SERVICE_NAME);
        String destination = (String) cmd_props.get(MessageType.JMQ_DESTINATION);
        Integer type = (Integer) cmd_props.get(MessageType.JMQ_DEST_TYPE);

        int status = Status.OK;
        String errMsg = null;

        assert service == null || destination == null;

        /*
         * Compatibility with MQ 3.0.1 If pause target not set, assume that the service is being paused/resumed.
         */
        if (pauseTarget == null) {
            pauseTarget = MessageType.JMQ_SERVICE_NAME;
        }

        try {
            if (MessageType.JMQ_SERVICE_NAME.equals(pauseTarget)) {
                if (service == null) {
                    logger.log(Logger.INFO, BrokerResources.I_RESUMING_ALL_SVCS);
                } else {
                    logger.log(Logger.INFO, BrokerResources.I_RESUMING_SVC, service);
                }
                PauseHandler.pauseService(false, service);
            } else if (MessageType.JMQ_DESTINATION.equals(pauseTarget)) {
                logger.log(Logger.INFO, BrokerResources.I_RESUMING_DST, destination);
                PauseHandler.pauseService(false, service);
                if (destination == null) {
                    Iterator[] itrs = DL.getAllDestinations(null);
                    Iterator itr = itrs[0];
                    while (itr.hasNext()) {
                        Destination d = (Destination) itr.next();
                        if (d.isPaused()) {
                            d.resumeDestination();
                        }
                    }
                } else {
                    Destination[] ds = DL.getDestination(null, destination, DestType.isQueue(type.intValue()));
                    Destination d = ds[0]; // PART
                    if (d != null) {
                        d.resumeDestination();
                    } else {
                        String msg = Globals.getBrokerResources().getString(BrokerResources.I_RESUMED_DST_NOT_EXIST,
                                (DestType.isQueue(type.intValue()) ? " queue:" : " topic:") + destination);

                        errMsg = msg;
                        status = Status.NOT_FOUND;
                        logger.log(Logger.ERROR, msg);
                    }
                }
            }
        } catch (Exception e) {
            status = Status.ERROR;
            errMsg = rb.getString(rb.X_RESUME_SERVICE_EXCEPTION, service, e.toString());
            logger.log(Logger.ERROR, errMsg, e);
        }

        // Send reply
        Packet reply = new Packet(con.useDirectBuffers());
        reply.setPacketType(PacketType.OBJECT_MESSAGE);

        setProperties(reply, MessageType.RESUME_REPLY, status, errMsg);

        parent.sendReply(con, cmd_msg, reply);
        return true;

    }
}
