jackhalfalltrades commented on code in PR #307:
URL: https://github.com/apache/atlas/pull/307#discussion_r2066770845
##########
webapp/src/main/java/org/apache/atlas/notification/NotificationHookConsumer.java:
##########
@@ -443,6 +454,32 @@ public int getHandlerOrder() {
return HandlerOrder.NOTIFICATION_HOOK_CONSUMER.getOrder();
}
+ public void closeImportConsumer(String importId, String topic) {
+ try {
+ LOG.info("==> closeImportConsumer(importId={}, topic={})",
importId, topic);
+
+ String consumerName =
ATLAS_IMPORT_CONSUMER_THREAD_PREFIX + importId;
+ ListIterator<HookConsumer> consumersIterator =
consumers.listIterator();
Review Comment:
At present, it is not possible for multiple threads to call
closeImportConsumer() simultaneously. This method is only called for Async
Imports and they run on a background one at a time.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: dev-unsubscr...@atlas.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
