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 <[email protected]>
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: [email protected]
For additional commands, e-mail: [email protected]
