diff options
| author |   Jim Hahn <jrh3@att.com> | 2020-03-02 23:55:07 -0500 |
|---|---|---|
| committer | Jim Hahn <jrh3@att.com> | 2020-03-02 23:55:07 -0500 |
| commit | eeaffa39795210244f8ae1fe4c6620026d43bd05 (patch) | |
| tree | 76c344acb5a2cce58f16fd421be1968b77e8ed05 /models-interactions/model-actors/actorServiceProvider/src | |
| parent | d5fc0bddf4f1e02d47a95d070c000ff0a6557edd (diff) | |
Log topic message before publishing
Code was publishing and then logging the message. Reversed the
order.
Issue-ID: POLICY-1625
Signed-off-by: Jim Hahn <jrh3@att.com>
Change-Id: I1b5dd5e96d86d818cd38d2a671fb37c2576e2054
Diffstat (limited to 'models-interactions/model-actors/actorServiceProvider/src')
| -rw-r--r-- | models-interactions/model-actors/actorServiceProvider/src/main/java/org/onap/policy/controlloop/actorserviceprovider/impl/BidirectionalTopicOperation.java | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/models-interactions/model-actors/actorServiceProvider/src/main/java/org/onap/policy/controlloop/actorserviceprovider/impl/BidirectionalTopicOperation.java b/models-interactions/model-actors/actorServiceProvider/src/main/java/org/onap/policy/controlloop/actorserviceprovider/impl/BidirectionalTopicOperation.java index 1ae80490c..b38ddb08a 100644 --- a/models-interactions/model-actors/actorServiceProvider/src/main/java/org/onap/policy/controlloop/actorserviceprovider/impl/BidirectionalTopicOperation.java +++ b/models-interactions/model-actors/actorServiceProvider/src/main/java/org/onap/policy/controlloop/actorserviceprovider/impl/BidirectionalTopicOperation.java @@ -172,11 +172,11 @@ public abstract class BidirectionalTopicOperation<Q, S> extends OperationPartial throw new IllegalArgumentException("cannot encode request", e); } + logMessage(EventType.OUT, topicHandler.getSinkTopicCommInfrastructure(), topicHandler.getSinkTopic(), request); + if (!topicHandler.send(json)) { throw new IllegalStateException("nothing published"); } - - logMessage(EventType.OUT, topicHandler.getSinkTopicCommInfrastructure(), topicHandler.getSinkTopic(), request); } /** |