This is an automated email from the ASF dual-hosted git repository.
mytang0 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 72e67c3ef Refactor CloudEventCodec singleton instantiation
new ab2406585 Merge pull request #3601 from HattoriHenzo/eventmesh-3586
72e67c3ef is described below
commit 72e67c3ef8eedce175e61ce064c350beddc6f736
Author: HattoriHenzo <[email protected]>
AuthorDate: Sat Apr 1 19:08:12 2023 -0400
Refactor CloudEventCodec singleton instantiation
---
.../apache/eventmesh/storage/redis/client/RedissonClient.java | 2 +-
.../eventmesh/storage/redis/cloudevent/CloudEventCodec.java | 10 +++++++++-
2 files changed, 10 insertions(+), 2 deletions(-)
diff --git
a/eventmesh-storage-plugin/eventmesh-storage-redis/src/main/java/org/apache/eventmesh/storage/redis/client/RedissonClient.java
b/eventmesh-storage-plugin/eventmesh-storage-redis/src/main/java/org/apache/eventmesh/storage/redis/client/RedissonClient.java
index 68b661a19..50fabd966 100644
---
a/eventmesh-storage-plugin/eventmesh-storage-redis/src/main/java/org/apache/eventmesh/storage/redis/client/RedissonClient.java
+++
b/eventmesh-storage-plugin/eventmesh-storage-redis/src/main/java/org/apache/eventmesh/storage/redis/client/RedissonClient.java
@@ -83,7 +83,7 @@ public final class RedissonClient {
config = new Config();
}
- config.setCodec(CloudEventCodec.INSTANCE);
+ config.setCodec(CloudEventCodec.getInstance());
switch (serverType) {
case SINGLE:
diff --git
a/eventmesh-storage-plugin/eventmesh-storage-redis/src/main/java/org/apache/eventmesh/storage/redis/cloudevent/CloudEventCodec.java
b/eventmesh-storage-plugin/eventmesh-storage-redis/src/main/java/org/apache/eventmesh/storage/redis/cloudevent/CloudEventCodec.java
index 932488d8c..1b452b6a4 100644
---
a/eventmesh-storage-plugin/eventmesh-storage-redis/src/main/java/org/apache/eventmesh/storage/redis/cloudevent/CloudEventCodec.java
+++
b/eventmesh-storage-plugin/eventmesh-storage-redis/src/main/java/org/apache/eventmesh/storage/redis/cloudevent/CloudEventCodec.java
@@ -29,10 +29,18 @@ import io.netty.buffer.ByteBufAllocator;
public class CloudEventCodec extends BaseCodec {
- public static final CloudEventCodec INSTANCE = new CloudEventCodec();
+ private static final CloudEventCodec INSTANCE = new CloudEventCodec();
private static final JsonFormat jsonFormat = new JsonFormat(false, true);
+ private CloudEventCodec() {
+ // To prevent class instantiation
+ }
+
+ public static CloudEventCodec getInstance() {
+ return INSTANCE;
+ }
+
private static final Encoder encoder = in -> {
ByteBuf out = ByteBufAllocator.DEFAULT.buffer();
if (in instanceof CloudEvent) {
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
