class MqResource implements IMqResource {

	public void commitOffset(CommitOffsetRequest request) {
		if (request == null) {
			return;
		}
		String url = MqConstanst.CONSUMERPRE + "/commitOffset";
		try {
			post(request, url, 10, CommitOffsetResponse.class, false);
		} catch (Exception e) {
			CatRequest request2 = new CatRequest();
			request2.setMethod("commitOffset");
			request2.setJson(JsonUtil.toJson(request));
			request2.setMsg(e.getMessage());
			addCat(request2);
		}
	}

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

}