This is an automated email from the ASF dual-hosted git repository.
jonyang 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 ff6708e89 use == instead of equals in enum compares in
EventMeshGrpcConsumer (#2475)
ff6708e89 is described below
commit ff6708e8936908d36f09850e6d1caa2cff5c93a8
Author: MajorHe1 <[email protected]>
AuthorDate: Tue Dec 6 22:12:07 2022 +0800
use == instead of equals in enum compares in EventMeshGrpcConsumer (#2475)
---
.../eventmesh/client/grpc/consumer/EventMeshGrpcConsumer.java | 8 ++++----
1 file changed, 4 insertions(+), 4 deletions(-)
diff --git
a/eventmesh-sdk-java/src/main/java/org/apache/eventmesh/client/grpc/consumer/EventMeshGrpcConsumer.java
b/eventmesh-sdk-java/src/main/java/org/apache/eventmesh/client/grpc/consumer/EventMeshGrpcConsumer.java
index 54e3738ec..5f8de39b7 100644
---
a/eventmesh-sdk-java/src/main/java/org/apache/eventmesh/client/grpc/consumer/EventMeshGrpcConsumer.java
+++
b/eventmesh-sdk-java/src/main/java/org/apache/eventmesh/client/grpc/consumer/EventMeshGrpcConsumer.java
@@ -193,18 +193,18 @@ public class EventMeshGrpcConsumer implements
AutoCloseable {
for (SubscriptionItem subscriptionItem : subscriptionItems) {
Subscription.SubscriptionItem.SubscriptionMode mode;
- if
(SubscriptionMode.CLUSTERING.equals(subscriptionItem.getMode())) {
+ if (SubscriptionMode.CLUSTERING == subscriptionItem.getMode()) {
mode =
Subscription.SubscriptionItem.SubscriptionMode.CLUSTERING;
- } else if
(SubscriptionMode.BROADCASTING.equals(subscriptionItem.getMode())) {
+ } else if (SubscriptionMode.BROADCASTING ==
subscriptionItem.getMode()) {
mode =
Subscription.SubscriptionItem.SubscriptionMode.BROADCASTING;
} else {
mode =
Subscription.SubscriptionItem.SubscriptionMode.UNRECOGNIZED;
}
Subscription.SubscriptionItem.SubscriptionType type;
- if (SubscriptionType.ASYNC.equals(subscriptionItem.getType())) {
+ if (SubscriptionType.ASYNC == subscriptionItem.getType()) {
type = Subscription.SubscriptionItem.SubscriptionType.ASYNC;
- } else if
(SubscriptionType.SYNC.equals(subscriptionItem.getType())) {
+ } else if (SubscriptionType.SYNC == subscriptionItem.getType()) {
type = Subscription.SubscriptionItem.SubscriptionType.SYNC;
} else {
type =
Subscription.SubscriptionItem.SubscriptionType.UNRECOGNIZED;
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
