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/incubator-eventmesh.git
The following commit(s) were added to refs/heads/master by this push:
new a7475bc02 Issue #3100 Updated ProducerManager.java
new f3c5146d8 Merge pull request #3148 from
PreetAngadSingh/PreetAngadSingh/Issue#3100
a7475bc02 is described below
commit a7475bc02c5afdb8f026556bfec954ed0b886f6f
Author: PreetAngadSingh <[email protected]>
AuthorDate: Wed Feb 15 19:27:44 2023 -0500
Issue #3100 Updated ProducerManager.java
---
.../runtime/core/protocol/grpc/producer/ProducerManager.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git
a/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/grpc/producer/ProducerManager.java
b/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/grpc/producer/ProducerManager.java
index f83319872..46cd5a1fe 100644
---
a/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/grpc/producer/ProducerManager.java
+++
b/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/grpc/producer/ProducerManager.java
@@ -30,9 +30,9 @@ public class ProducerManager {
public Logger logger = LoggerFactory.getLogger(this.getClass());
- private EventMeshGrpcServer eventMeshGrpcServer;
+ private final EventMeshGrpcServer eventMeshGrpcServer;
- private ConcurrentHashMap<String, EventMeshProducer> producerTable = new
ConcurrentHashMap<>();
+ private final ConcurrentHashMap<String, EventMeshProducer> producerTable =
new ConcurrentHashMap<>();
public ProducerManager(EventMeshGrpcServer eventMeshGrpcServer) {
this.eventMeshGrpcServer = eventMeshGrpcServer;
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
