This is an automated email from the ASF dual-hosted git repository.
mikexue 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 aa6e358a4 [ISSUE #2738] Method calls equals on an enum instance
[ConsumerGroupTopicConfig]. Change it to ==
new a449bee4e Merge pull request #2762 from
KingChampion36/enhancement/#2738
aa6e358a4 is described below
commit aa6e358a4ff017cbce9f1cbfb60f41ff6cd5b646
Author: Rahul <[email protected]>
AuthorDate: Sat Dec 31 15:27:29 2022 +0530
[ISSUE #2738] Method calls equals on an enum instance
[ConsumerGroupTopicConfig]. Change it to ==
---
.../protocol/grpc/consumer/consumergroup/ConsumerGroupTopicConfig.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git
a/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/grpc/consumer/consumergroup/ConsumerGroupTopicConfig.java
b/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/grpc/consumer/consumergroup/ConsumerGroupTopicConfig.java
index 33139bf0b..6ad42bdb8 100644
---
a/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/grpc/consumer/consumergroup/ConsumerGroupTopicConfig.java
+++
b/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/grpc/consumer/consumergroup/ConsumerGroupTopicConfig.java
@@ -41,7 +41,7 @@ public abstract class ConsumerGroupTopicConfig {
public static ConsumerGroupTopicConfig buildTopicConfig(String
consumerGroup, String topic, SubscriptionMode subscriptionMode,
GrpcType grpcType)
{
- if (GrpcType.STREAM.equals(grpcType)) {
+ if (GrpcType.STREAM == grpcType) {
return new StreamTopicConfig(consumerGroup, topic,
subscriptionMode);
} else {
return new WebhookTopicConfig(consumerGroup, topic,
subscriptionMode);
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
