Use BidirectionalTopicClient from policy-common

[policy/models.git] / models-interactions / model-actors / actorServiceProvider / src / main / java / org / onap / policy / controlloop / actorserviceprovider / parameters / BidirectionalTopicParams.java

diff --git a/models-interactions/model-actors/actorServiceProvider/src/main/java/org/onap/policy/controlloop/actorserviceprovider/parameters/TopicPairParams.java b/models-interactions/model-actors/actorServiceProvider/src/main/java/org/onap/policy/controlloop/actorserviceprovider/parameters/BidirectionalTopicParams.java
similarity index 77%
rename from models-interactions/model-actors/actorServiceProvider/src/main/java/org/onap/policy/controlloop/actorserviceprovider/parameters/TopicPairParams.java
rename to models-interactions/model-actors/actorServiceProvider/src/main/java/org/onap/policy/controlloop/actorserviceprovider/parameters/BidirectionalTopicParams.java
index 33fcf30..cafca1f 100644 (file)
--- a/models-interactions/model-actors/actorServiceProvider/src/main/java/org/onap/policy/controlloop/actorserviceprovider/parameters/TopicPairParams.java
+++ b/models-interactions/model-actors/actorServiceProvider/src/main/java/org/onap/policy/controlloop/actorserviceprovider/parameters/BidirectionalTopicParams.java
@@ -29,31 +29,33 @@ import org.onap.policy.common.parameters.annotations.NotBlank;
 import org.onap.policy.common.parameters.annotations.NotNull;
 
 /**
- * Parameters used by Operators that use a pair of Topics, one to publish requests and the
- * other to receive responses.
+ * Parameters used by Operators that use a bidirectional topic.
  */
 @NotNull
 @NotBlank
 @Data
 @Builder(toBuilder = true)
-public class TopicPairParams {
+public class BidirectionalTopicParams {
 
     /**
-     * Source topic end point, from which to read responses.
+     * Sink topic name to which requests should be published.
      */
-    private String source;
+    private String sinkTopic;
 
     /**
-     * Name of the target topic end point to which requests should be published.
+     * Source topic name, from which to read responses.
      */
-    private String target;
+    private String sourceTopic;
 
     /**
-     * Amount of time, in seconds to wait for the response. The default is five minutes.
+     * Amount of time, in seconds to wait for the response.
+     * <p/>
+     * Note: this should NOT have a default value, as it receives its default value from
+     * {@link BidirectionalTopicActorParams}.
      */
     @Min(1)
-    @Builder.Default
-    private int timeoutSec = 300;
+    private int timeoutSec;
+
 
     /**
      * Validates the parameters.