package com.yanzuoguang.mq;

import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Component;

/**
 * ＭＱ配置
 *
 * @author 颜佐光
 */
@Component
public class MqConfig {

    @Value("${spring.rabbitmq.listener.simple.concurrency:1}")
    private int concurrency;

    @Value("${spring.rabbitmq.listener.simple.max-concurrency:10}")
    private int maxConcurrency;

    @Value("${spring.rabbitmq.listener.simple.prefetch:100}")
    private int prefetch;

    @Value("${spring.rabbitmq.listener.simple.transaction-size:100}")
    private int txSize;

    @Value("${yzg.mq.retry.size:100}")
    private int retrySize = 100;

    @Value("${yzg.mq.retry.time:60000}")
    private int retryTime = 1000;

    @Value("${yzg.mq.unit.min:1000}")
    private long unitMin;

    public int getConcurrency() {
        return concurrency;
    }

    public int getMaxConcurrency() {
        return maxConcurrency;
    }

    public int getPrefetch() {
        return prefetch;
    }

    public int getTxSize() {
        return txSize;
    }

    public int getRetrySize() {
        return retrySize;
    }

    public int getRetryTime() {
        return retryTime;
    }

    public long getUnitMin() {
        return unitMin;
    }
}