yujunjun/OpenMetadata
1
0
Fork 0
mirror of https://github.com/open-metadata/OpenMetadata.git synced 2025-11-09 23:40:05 +00:00
Code Issues Packages Projects Releases Wiki Activity

Call Stop at the end

Browse Source
This commit is contained in:
mohitdeuex 2024-01-17 10:51:29 +05:30
parent dccfd9a776
commit cfbb94aa32
3 changed files with 6 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
openmetadata-service/src/main/java/org/openmetadata/service/apps/bundles/changeEvent/AbstractEventConsumer.java
View File

@ -301,6 +301,9 @@ public abstract class AbstractEventConsumer
offset += batchSize; offset += batchSize;
commit(jobExecutionContext); commit(jobExecutionContext);
} }
// Call stop to close the client
this.stop();
} }
public EventSubscription getEventSubscription() { public EventSubscription getEventSubscription() {

2
openmetadata-service/src/main/java/org/openmetadata/service/apps/bundles/changeEvent/Alert.java
View File

@ -17,4 +17,6 @@ import org.openmetadata.service.events.errors.EventPublisherException;
public interface Alert<T> { public interface Alert<T> {
void sendAlert(T event) throws EventPublisherException; void sendAlert(T event) throws EventPublisherException;
void stop();
} }

3
openmetadata-service/src/main/java/org/openmetadata/service/apps/bundles/changeEvent/Consumer.java
View File

@ -13,12 +13,11 @@
package org.openmetadata.service.apps.bundles.changeEvent; package org.openmetadata.service.apps.bundles.changeEvent;
import io.dropwizard.lifecycle.Managed;
import java.util.List; import java.util.List;
import org.openmetadata.service.events.errors.EventPublisherException; import org.openmetadata.service.events.errors.EventPublisherException;
import org.quartz.JobExecutionContext; import org.quartz.JobExecutionContext;
public interface Consumer<T> extends Managed { public interface Consumer<T> {
List<T> pollEvents(long offset, long batchSize); List<T> pollEvents(long offset, long batchSize);
void publishEvents(List<T> events); void publishEvents(List<T> events);