You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@eventmesh.apache.org by jo...@apache.org on 2023/02/04 01:49:31 UTC
[incubator-eventmesh] branch master updated: fix check style issue to unblock CI (#3043)
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 16ef0bb6b fix check style issue to unblock CI (#3043)
16ef0bb6b is described below
commit 16ef0bb6b291e88812648af0f8dc296769e4ae9e
Author: Han Gao <dh...@hotmail.com>
AuthorDate: Sat Feb 4 09:49:25 2023 +0800
fix check style issue to unblock CI (#3043)
---
.../runtime/core/protocol/http/consumer/EventMeshConsumer.java | 6 +++---
1 file changed, 3 insertions(+), 3 deletions(-)
diff --git a/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/http/consumer/EventMeshConsumer.java b/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/http/consumer/EventMeshConsumer.java
index 8375cd7b8..4e060e3a4 100644
--- a/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/http/consumer/EventMeshConsumer.java
+++ b/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/http/consumer/EventMeshConsumer.java
@@ -266,7 +266,7 @@ public class EventMeshConsumer {
}
public void subscribe(String topic, SubscriptionItem subscriptionItem) throws Exception {
- if (SubscriptionMode.BROADCASTING!=subscriptionItem.getMode()) {
+ if (SubscriptionMode.BROADCASTING != subscriptionItem.getMode()) {
persistentMqConsumer.subscribe(topic);
} else {
broadcastMqConsumer.subscribe(topic);
@@ -274,7 +274,7 @@ public class EventMeshConsumer {
}
public void unsubscribe(String topic, SubscriptionMode subscriptionMode) throws Exception {
- if (SubscriptionMode.BROADCASTING==subscriptionMode) {
+ if (SubscriptionMode.BROADCASTING == subscriptionMode) {
broadcastMqConsumer.unsubscribe(topic);
} else {
persistentMqConsumer.unsubscribe(topic);
@@ -290,7 +290,7 @@ public class EventMeshConsumer {
public void updateOffset(String topic, SubscriptionMode subscriptionMode, List<CloudEvent> events,
AbstractContext context) {
- if (SubscriptionMode.BROADCASTING==subscriptionMode) {
+ if (SubscriptionMode.BROADCASTING == subscriptionMode) {
broadcastMqConsumer.updateOffset(events, context);
} else {
persistentMqConsumer.updateOffset(events, context);
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@eventmesh.apache.org
For additional commands, e-mail: commits-help@eventmesh.apache.org