/*******************************************************************************
 * Copyright 2016-2017 ZTE, Inc. and others.
 * 
 * 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.onap.msb.apiroute.wrapper.queue;

import java.util.List;
import java.util.concurrent.BlockingQueue;

import org.onap.msb.apiroute.wrapper.consulextend.model.health.ServiceHealth;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;


public class ServiceQueue extends BaseQueue<List<ServiceHealth>> {

    private static final Logger LOGGER = LoggerFactory.getLogger(ServiceQueue.class);

    private int queneNum;

    public ServiceQueue(final int queneNum, final int queueCapacity) {
        super(queneNum, queueCapacity);
        this.queneNum = queneNum;
    }


    @Override
    public void put(final ServiceData<List<ServiceHealth>> data) throws InterruptedException {
        if (data.getData() == null || data.getData().size() == 0)
            return;

        String serviceName = data.getData().get(0).getService().getService();
        long serviceNameHashCode = serviceName.hashCode() & 0x7FFFFFFF;
        int queneIndex = (int) (serviceNameHashCode % queneNum);

        // LOGGER.info("put ServiceQueue
        // [serviceName.hashCode():"+serviceNameHashCode+",queneIndex:"+queneIndex+",queneNum:"+queneNum+"]
        // :[serviceName]"+serviceName);

        BlockingQueue<ServiceData<List<ServiceHealth>>> queue = getQueue(queneIndex);
        queue.put(data);

        LOGGER.info("put ServiceQueue[index:" + queneIndex + ",size:" + queue.size() + "] success :[serviceName]"
                        + serviceName);
    }

    @Override
    public ServiceData<List<ServiceHealth>> take(final int queueIndex) throws InterruptedException {
        return getQueue(queueIndex).take();
    }


}