MCPcopy Create free account
hub / github.com/e2wugui/zeze / sendMessage

Method sendMessage

ZezeJava/ZezeJava/src/main/java/Zeze/MQ/MQSingle.java:70–84  ·  view source on GitHub ↗
(BSendMessage.Data message)

Source from the content-addressed store, hash-verified

68 }
69
70 public void sendMessage(BSendMessage.Data message) {
71 lock();
72 try {
73 fileWithIndex.appendMessage(message.getMessage());
74 if (highLoad == 0 && messageQueue.size() < maxFillMessageCount) {
75 // 低负载,缓冲足够大,直接进入缓冲,保持highLoad为0.
76 messageQueue.offer(message.getMessage());
77 } else {
78 highLoad++;
79 }
80 tryPushMessage();
81 } finally {
82 unlock();
83 }
84 }
85
86 private void tryStartBackgroundFill() {
87 lock();

Callers

nothing calls this directly

Calls 6

tryPushMessageMethod · 0.95
appendMessageMethod · 0.80
lockMethod · 0.65
sizeMethod · 0.65
unlockMethod · 0.65
getMessageMethod · 0.45

Tested by

no test coverage detected