package com.walker.queue;

import com.walker.async.Consumer;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import java.util.List;

public abstract class AbstractQueueManager implements QueueManager {

	protected final transient Logger logger = LoggerFactory.getLogger(getClass());

	private int id = 0;
	private String name = "未命名队列管理器";

	protected int maxWorkerThread = 8;

	public int getMaxWorkerThread() {
		return maxWorkerThread;
	}

	/**
	 * 设置工作线程最大数量，默认：8个
	 * @param maxWorkerThread
	 */
	public void setMaxWorkerThread(int maxWorkerThread) {
		this.maxWorkerThread = maxWorkerThread;
	}


	public void setName(String name) {
		this.name = name;
	}

	public void setId(int id) {
		this.id = id;
	}

	@Override
	public int getId() {
		return id;
	}

	@Override
	public String getName() {
		return this.name;
	}

//	@Override
//	public void push(String key, Object data, Object option) throws QueueException {
//
//	}

	@Override
	public void setConsumers(List<Consumer> consumerList) {

	}

}