You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airavata.apache.org by sc...@apache.org on 2017/04/05 19:10:38 UTC
[14/50] [abbrv] airavata git commit: Send ack for db-event message
after processing in Registry
Send ack for db-event message after processing in Registry
Project: http://git-wip-us.apache.org/repos/asf/airavata/repo
Commit: http://git-wip-us.apache.org/repos/asf/airavata/commit/45ecfa35
Tree: http://git-wip-us.apache.org/repos/asf/airavata/tree/45ecfa35
Diff: http://git-wip-us.apache.org/repos/asf/airavata/diff/45ecfa35
Branch: refs/heads/develop
Commit: 45ecfa357009aea47d47c4fa5ec1b6dcde031200
Parents: 5808332
Author: Gourav Shenoy <sh...@gmail.com>
Authored: Mon Apr 3 16:15:52 2017 -0400
Committer: Gourav Shenoy <sh...@gmail.com>
Committed: Mon Apr 3 16:15:52 2017 -0400
----------------------------------------------------------------------
.../api/service/messaging/RegistryServiceDBEventHandler.java | 8 ++++----
1 file changed, 4 insertions(+), 4 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/airavata/blob/45ecfa35/modules/registry/registry-server/registry-api-service/src/main/java/org/apache/airavata/registry/api/service/messaging/RegistryServiceDBEventHandler.java
----------------------------------------------------------------------
diff --git a/modules/registry/registry-server/registry-api-service/src/main/java/org/apache/airavata/registry/api/service/messaging/RegistryServiceDBEventHandler.java b/modules/registry/registry-server/registry-api-service/src/main/java/org/apache/airavata/registry/api/service/messaging/RegistryServiceDBEventHandler.java
index 0aa103a..b572189 100644
--- a/modules/registry/registry-server/registry-api-service/src/main/java/org/apache/airavata/registry/api/service/messaging/RegistryServiceDBEventHandler.java
+++ b/modules/registry/registry-server/registry-api-service/src/main/java/org/apache/airavata/registry/api/service/messaging/RegistryServiceDBEventHandler.java
@@ -134,11 +134,11 @@ public class RegistryServiceDBEventHandler implements MessageHandler {
default: {
logger.error("Handler not defined for Entity: " + publisherContext.getEntityType());
}
-
- // send ack for received message
- logger.info("RegistryServiceDBEventHandler | Sending ack. Message Delivery Tag: " + messageContext.getDeliveryTag());
- RegistryServiceDBEventMessagingFactory.getDBEventSubscriber().sendAck(messageContext.getDeliveryTag());
}
+
+ // send ack for received message
+ logger.info("RegistryServiceDBEventHandler | Sending ack. Message Delivery Tag: " + messageContext.getDeliveryTag());
+ RegistryServiceDBEventMessagingFactory.getDBEventSubscriber().sendAck(messageContext.getDeliveryTag());
} catch (TException ex) {
logger.error("Error processing message: " + ex, ex);
} catch (ApplicationSettingsException ex) {