本文整理了Java中qunar.tc.qmq.metrics.QmqCounter.inc
方法的一些代码示例,展示了QmqCounter.inc
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。QmqCounter.inc
方法的具体详情如下:
包路径:qunar.tc.qmq.metrics.QmqCounter
类名称:QmqCounter
方法名:inc
暂无
代码示例来源:origin: qunarcorp/qmq
public static void clientRefreshMetaInfoCountInc(String subject) {
Metrics.counter("clientRefreshMetaInfoCount", SUBJECT_ARRAY, new String[]{subject}).inc();
}
代码示例来源:origin: qunarcorp/qmq
public static void sendMessageTaskInvokeFailCountInc() {
Metrics.counter("sendMessageTaskInvokeFailCount").inc();
}
代码示例来源:origin: qunarcorp/qmq
private static void countInc(String name, String[] tags, String[] values, long num) {
Metrics.counter(name, tags, values).inc(num);
}
代码示例来源:origin: qunarcorp/qmq
public static void scheduleDispatch() {
Metrics.counter("scheduleDispatch", EMPTY, EMPTY).inc();
}
代码示例来源:origin: qunarcorp/qmq
public static void brokerDisconnectedCountInc(String groupName) {
Metrics.counter("brokerDisconnectedCount", new String[]{"groupName"}, new String[]{groupName}).inc();
}
代码示例来源:origin: qunarcorp/qmq
public static void initSendMessageTasksCountInc() {
Metrics.counter("initSendMessageTasksCount").inc();
}
代码示例来源:origin: qunarcorp/qmq
public static void noSendMsgCountInc(String jdbcUrl, int n) {
Metrics.counter("noSendMsgCount", new String[]{"jdbcUrl"}, new String[]{jdbcUrl}).inc(n);
}
代码示例来源:origin: qunarcorp/qmq
private void pause(String log, long timeMillis) {
final String subject = pushConsumer.subject();
final String group = pushConsumer.group();
this.pauseCounter.inc();
LOGGER.debug(logType, "pull pause {} ms, {}. subject={}, group={}", timeMillis, log, subject, group);
try {
Thread.sleep(timeMillis);
} catch (Exception e) {
LOGGER.info("PullEntry pause exception. log={}", log, e);
}
}
代码示例来源:origin: qunarcorp/qmq
private void resend() {
resendCount.inc();
traceSpan = null;
traceScope = null;
state.set(INIT);
TraceUtil.recordEvent("retry", tracer);
doSend();
}
代码示例来源:origin: qunarcorp/qmq
private HashMap<String, Object> deserializeMapWrapper(String subject, String messageId, ByteBuf body) {
try {
return deserializeMap(body);
} catch (Exception e) {
LOGGER.error("deserialize message failed subject:{} messageId: {}", subject, messageId);
Metrics.counter("qmq_pull_deserialize_fail_count", SUBJECT_ARRAY, new String[]{subject}).inc();
HashMap<String, Object> result = new HashMap<>();
result.put(BaseMessage.keys.qmq_corruptData.name(), "true");
result.put(BaseMessage.keys.qmq_createTime.name(), new Date().getTime());
return result;
}
}
代码示例来源:origin: qunarcorp/qmq
public void requestWrapper(MetaInfoRequestParam param) {
try {
Metrics.counter("qmq_pull_metainfo_request_count", SUBJECT_GROUP_ARRAY, new String[]{param.subject, param.group}).inc();
request(param);
} catch (Exception e) {
LOGGER.debug("request meta info exception. {} {} {}", param.clientType.name(), param.subject, param.group, e);
Metrics.counter("qmq_pull_metainfo_request_fail", SUBJECT_GROUP_ARRAY, new String[]{param.subject, param.group}).inc();
}
}
代码示例来源:origin: qunarcorp/qmq
@Override
public void fail(Exception ex) {
if (ackSendFailLogLimit.tryAcquire()) {
LOGGER.warn("send ack fail, will retry next", ex);
}
LOGGER.debug("AckSendRet fail [{}, {}]", sendEntry.getPullOffsetBegin(), sendEntry.getPullOffsetLast());
sendFailCount.inc();
inSending.set(false);
}
});
代码示例来源:origin: qunarcorp/qmq
@Override
public void send() {
sendCount.inc();
attachTraceData();
doSend();
}
代码示例来源:origin: qunarcorp/qmq
private void onFailed() {
TraceUtil.recordEvent("send_failed", tracer);
sendFailCount.inc();
if (sendStateListener == null) return;
sendStateListener.onFailed(base);
}
代码示例来源:origin: qunarcorp/qmq
private void markFailed(BrokerGroupInfo group) {
pullFailCounter.inc();
group.markFailed();
loadBalance.timeout(group);
}
代码示例来源:origin: qunarcorp/qmq
private void onSuccess() {
sendOkCount.inc();
sendOkQps.mark();
if (sendStateListener == null) return;
sendStateListener.onSuccess(base);
}
代码示例来源:origin: qunarcorp/qmq
void sendBackAndCompleteNack(final int nextRetryCount, final BaseMessage message, final AckEntry ackEntry) {
final String sendSubject = nextRetryCount > message.getMaxRetryNum() ? deadRetrySubject : retrySubject;
if (deadRetrySubject.equals(sendSubject)) {
deadQueueCount.inc();
LOGGER.warn("process message retry num {} >= {}, and dead retry. subject={}, group={}, msgId={}",
nextRetryCount - 1, message.getMaxRetryNum(), subject, group, message.getMessageId());
}
message.setSubject(sendSubject);
sendMessageBack.sendBackAndCompleteNack(nextRetryCount, message, ackEntry);
}
代码示例来源:origin: qunarcorp/qmq
private static void monitorMessageCount(final PullParam pullParam, final PullResult pullResult) {
try {
Metrics.counter("qmq_pull_message_count", new String[]{"subject", "group", "broker"},
new String[]{pullParam.getSubject(), pullParam.getGroup(), pullParam.getBrokerGroup().getGroupName()})
.inc(pullResult.getMessages().size());
} catch (Exception e) {
LOGGER.error("AbstractPullEntry monitor exception", e);
}
}
代码示例来源:origin: qunarcorp/qmq
private boolean preparePull() {
pullRunCounter.inc();
if (!pushConsumer.cleanLocalBuffer()) {
pause("wait consumer", PAUSETIME_OF_CLEAN_LAST_MESSAGE);
return false;
}
if (!pullStrategy.needPull()) {
pause("wait consumer", PAUSETIME_OF_NOMESSAGE);
return false;
}
return true;
}
代码示例来源:origin: qunarcorp/qmq
private void doSendNack(final int nextRetryCount, final BaseMessage message) {
while (true) {
try {
ackSendQueue.sendBackAndCompleteNack(nextRetryCount, message, this);
return;
} catch (Exception e) {
LOGGER.warn("nack exception. subject={}, group={}", ackSendQueue.getSubject(), ackSendQueue.getGroup(), e);
Metrics.counter("qmq_pull_sendNack_error", SUBJECT_GROUP_ARRAY, new String[]{message.getSubject(), ackSendQueue.getGroup()}).inc();
}
}
}
内容来源于网络,如有侵权,请联系作者删除!