package com.matrix.component.rabbitmq;

import com.rabbitmq.client.DeliverCallback;

/**
 * MQ队列任务类
 */
public class MqTask {


    /**
     * 交换机
     */
    private String exchange;

    /**
     * 队列名称
     */
    private String queue;

    /**
     * 路由名称
     */
    private String routingKey;

    /**
     * 处理类在spring中的bean名称
     */
    private DeliverCallbackAdapter handerAdapter;

    /**
     * 自动确认 默认为true
     */
    private Boolean autoAck=true;


    public MqTask(String exchange, String queue, String routingKey, DeliverCallback hander) {
        this.exchange = exchange;
        this.queue = queue;
        this.routingKey = routingKey;
        if(hander!=null){
            this.handerAdapter = new DeliverCallbackAdapter(hander,routingKey);
        }

    }
    public MqTask(String exchange, String queue, String routingKey, DeliverCallback hander, Boolean autoAck) {
        this.exchange = exchange;
        this.queue = queue;
        this.routingKey = routingKey;
        if(hander!=null){
            this.handerAdapter = new DeliverCallbackAdapter(hander,routingKey);
        }
        this.autoAck=autoAck;

    }






    public String getExchange() {
        return exchange;
    }

    public Boolean getAutoAck() {
        return autoAck;
    }

    public void setAutoAck(Boolean autoAck) {
        this.autoAck = autoAck;
    }

    public void setExchange(String exchange) {
        this.exchange = exchange;
    }

    public String getQueue() {
        return queue;
    }

    public void setQueue(String queue) {
        this.queue = queue;
    }

    public String getRoutingKey() {
        return routingKey;
    }

    public void setRoutingKey(String routingKey) {
        this.routingKey = routingKey;
    }

    public DeliverCallback getHander() {
        return handerAdapter;
    }

    public void setHander(DeliverCallbackAdapter hander) {
        this.handerAdapter = hander;
    }
}