package com.cmos.msgframe.admin.service;

import com.cmos.msgframe.common.util.OutPutParameter;

public interface IConsumerService {
	OutPutParameter getConsumerList(String consumerGroup, String topic, int start,
			int end) throws Exception;

	OutPutParameter addSubgroup(String brokerAddr, String clusterName,
			String groupName, String consumeEnable,
			String consumeFromMinEnable, String consumeBroadcastEnable,
			String retryQueueNums, String retryMaxTimes, String brokerId)
			throws Exception;

	OutPutParameter updateSubgroup(String brokerAddr, String clusterName,
			String groupName, String consumeEnable,
			String consumeFromMinEnable, String consumeBroadcastEnable,
			String retryQueueNums, String retryMaxTimes, String brokerId)
			throws Exception;

	OutPutParameter deleteSubgroup(String clusterName, String groupName)
			throws Exception;

	OutPutParameter getConsumerStats(String consumerGrou, int start,
			int end) throws Exception;
}