You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@eventmesh.apache.org by my...@apache.org on 2023/02/16 07:59:02 UTC

[incubator-eventmesh] branch master updated: Issue #3100 Updated ProducerManager.java

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 <pr...@gmail.com>
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: commits-unsubscribe@eventmesh.apache.org
For additional commands, e-mail: commits-help@eventmesh.apache.org