This is an automated email from the ASF dual-hosted git repository.
qingshanpeng pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/eventmesh.git
The following commit(s) were added to refs/heads/master by this push:
new 7c50766a8 Specify the initial size of Map
new c65a86076 Merge pull request #3871 from pandaapo/master-issue3870
7c50766a8 is described below
commit 7c50766a8297d27c8594a3baf6085abe0a58364e
Author: pandaapo <[email protected]>
AuthorDate: Fri May 5 14:08:54 2023 +0800
Specify the initial size of Map
---
.../test/java/org/apache/eventmesh/storage/standalone/TestUtils.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git
a/eventmesh-storage-plugin/eventmesh-storage-standalone/src/test/java/org/apache/eventmesh/storage/standalone/TestUtils.java
b/eventmesh-storage-plugin/eventmesh-storage-standalone/src/test/java/org/apache/eventmesh/storage/standalone/TestUtils.java
index d3bd5e888..955e91381 100644
---
a/eventmesh-storage-plugin/eventmesh-storage-standalone/src/test/java/org/apache/eventmesh/storage/standalone/TestUtils.java
+++
b/eventmesh-storage-plugin/eventmesh-storage-standalone/src/test/java/org/apache/eventmesh/storage/standalone/TestUtils.java
@@ -39,14 +39,14 @@ public class TestUtils {
public static final boolean TOPIC_DO_NOT_EXISTS = false;
public static ConcurrentHashMap<TopicMetadata, MessageQueue>
createDefaultMessageContainer() {
- ConcurrentHashMap<TopicMetadata, MessageQueue> messageContainer = new
ConcurrentHashMap<>();
+ ConcurrentHashMap<TopicMetadata, MessageQueue> messageContainer = new
ConcurrentHashMap<>(1);
messageContainer.put(new TopicMetadata(TEST_TOPIC), new
MessageQueue());
return messageContainer;
}
public static ConcurrentHashMap<TopicMetadata, MessageQueue>
createMessageContainer(TopicMetadata topicMetadata, MessageEntity messageEntity)
throws InterruptedException {
- ConcurrentHashMap<TopicMetadata, MessageQueue> messageContainer = new
ConcurrentHashMap<>();
+ ConcurrentHashMap<TopicMetadata, MessageQueue> messageContainer = new
ConcurrentHashMap<>(1);
MessageQueue messageQueue = new MessageQueue();
messageQueue.put(messageEntity);
messageContainer.put(topicMetadata, messageQueue);
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
