class MqResource implements IMqResource {

	public ConsumerGroupRegisterResponse registerConsumerGroup(ConsumerGroupRegisterRequest request) {
		if (request == null) {
			return null;
		}
		String url = MqConstanst.CONSUMERPRE + "/registerConsumerGroup";
		try {
			ConsumerGroupRegisterResponse response = post(request, url, 2, ConsumerGroupRegisterResponse.class, true);
			boolean flag = response != null && response.isSuc();
			if (!flag && response != null) {
				logger.error("registerConsumerGroup_error," + response.getMsg());
			}
			return response;
		} catch (Exception e) {
			CatRequest request2 = new CatRequest();
			request2.setMethod("registerConsumerGroup");
			request2.setJson(JsonUtil.toJson(request));
			request2.setMsg(e.getMessage());
			addCat(request2);
			logger.error("registerConsumerGroup_error", e);
			throw e;
		}

	}

	public  MqResource(String url, long connectionTimeOut, long readTimeOut);
	public  MqResource(IHttpClient httpClient, String url);

}