Change Actor makeCoder() to getCoder() 07/108707/2
authorJim Hahn <jrh3@att.com>
Tue, 2 Jun 2020 20:46:47 +0000 (16:46 -0400)
committerJim Hahn <jrh3@att.com>
Tue, 2 Jun 2020 20:56:28 +0000 (16:56 -0400)
Issue-ID: POLICY-2603
Change-Id: I29d5c73f4b8b129bfdd6d0c9fb6d766b260e27c4
Signed-off-by: Jim Hahn <jrh3@att.com>
12 files changed:
models-interactions/model-actors/actor.appc/src/main/java/org/onap/policy/controlloop/actor/appc/AppcOperation.java
models-interactions/model-actors/actor.appclcm/src/main/java/org/onap/policy/controlloop/actor/appclcm/AppcLcmOperation.java
models-interactions/model-actors/actor.appclcm/src/test/java/org/onap/policy/controlloop/actor/appclcm/AppcLcmOperationTest.java
models-interactions/model-actors/actor.so/src/main/java/org/onap/policy/controlloop/actor/so/SoOperation.java
models-interactions/model-actors/actor.so/src/main/java/org/onap/policy/controlloop/actor/so/VfModuleDelete.java
models-interactions/model-actors/actor.so/src/test/java/org/onap/policy/controlloop/actor/so/SoOperationTest.java
models-interactions/model-actors/actorServiceProvider/src/main/java/org/onap/policy/controlloop/actorserviceprovider/impl/BidirectionalTopicOperation.java
models-interactions/model-actors/actorServiceProvider/src/main/java/org/onap/policy/controlloop/actorserviceprovider/impl/HttpOperation.java
models-interactions/model-actors/actorServiceProvider/src/main/java/org/onap/policy/controlloop/actorserviceprovider/impl/OperationPartial.java
models-interactions/model-actors/actorServiceProvider/src/test/java/org/onap/policy/controlloop/actorserviceprovider/impl/BidirectionalTopicOperationTest.java
models-interactions/model-actors/actorServiceProvider/src/test/java/org/onap/policy/controlloop/actorserviceprovider/impl/HttpOperationTest.java
models-interactions/model-actors/actorServiceProvider/src/test/java/org/onap/policy/controlloop/actorserviceprovider/impl/OperationPartialTest.java

index 3e5ed2c..0be723c 100644 (file)
@@ -136,7 +136,7 @@ public class AppcLcmOperation extends BidirectionalTopicOperation<AppcLcmDmaapWr
      */
     private void convertPayload(Map<String, Object> source, AppcLcmInput request) {
         try {
-            String encodedPayloadString = makeCoder().encode(source);
+            String encodedPayloadString = getCoder().encode(source);
             request.setPayload(encodedPayloadString);
         } catch (CoderException e) {
             throw new IllegalArgumentException("Cannot convert payload", e);
index c5ec58a..fcfb6b8 100644 (file)
@@ -203,7 +203,7 @@ public class AppcLcmOperationTest extends BasicBidirectionalTopicOperation {
         // coder exception
         oper = new AppcLcmOperation(params, config) {
             @Override
-            protected Coder makeCoder() {
+            protected Coder getCoder() {
                 return new StandardCoder() {
                     @Override
                     public String encode(Object object) throws CoderException {
index 04f0287..9dbdc58 100644 (file)
@@ -165,7 +165,7 @@ public class VfModuleDelete extends SoOperation {
         // propagate "cancel" to the future
         controller.add(future);
 
-        future.thenApply(response -> new RestManagerResponse(response.statusCode(), response.body(), makeCoder()))
+        future.thenApply(response -> new RestManagerResponse(response.statusCode(), response.body(), getCoder()))
                         .whenComplete((resp, thrown) -> {
                             if (thrown != null) {
                                 callback.failed(thrown);
index 9e72c8a..b794eab 100644 (file)
@@ -431,8 +431,8 @@ public class SoOperationTest extends BasicSoOperation {
     }
 
     @Test
-    public void testMakeCoder() throws CoderException {
-        Coder opcoder = oper.makeCoder();
+    public void testGetCoder() throws CoderException {
+        Coder opcoder = oper.getCoder();
 
         // ensure we can decode an SO timestamp
         String json = "{'request':{'finishTime':'Fri, 15 May 2020 12:14:21 GMT'}}";
index 2a46066..13231e6 100644 (file)
@@ -201,7 +201,7 @@ public abstract class BidirectionalTopicOperation<Q, S> extends OperationPartial
 
         } else {
             try {
-                response = makeCoder().decode(rawResponse, responseClass);
+                response = getCoder().decode(rawResponse, responseClass);
             } catch (CoderException e) {
                 logger.warn("{}.{} cannot decode response for {}", params.getActor(), params.getOperation(),
                                 params.getRequestId());
index 766468c..fb6d382 100644 (file)
@@ -186,7 +186,7 @@ public abstract class HttpOperation<T> extends OperationPartial {
             response = responseClass.cast(strResponse);
         } else {
             try {
-                response = makeCoder().decode(strResponse, responseClass);
+                response = getCoder().decode(strResponse, responseClass);
             } catch (CoderException e) {
                 logger.warn("{}.{} cannot decode response for {}", params.getActor(), params.getOperation(),
                                 params.getRequestId(), e);
index 1df3187..b280216 100644 (file)
@@ -1029,7 +1029,7 @@ public abstract class OperationPartial implements Operation {
             return message.toString();
         } else {
             try {
-                return makeCoder().encode(message, true);
+                return getCoder().encode(message, true);
             } catch (CoderException e) {
                 throw new IllegalArgumentException("cannot encode message", e);
             }
@@ -1071,7 +1071,7 @@ public abstract class OperationPartial implements Operation {
 
     // these may be overridden by junit tests
 
-    protected Coder makeCoder() {
+    protected Coder getCoder() {
         return coder;
     }
 }
index 84a4d5d..b62eae8 100644 (file)
@@ -323,8 +323,8 @@ public class BidirectionalTopicOperationTest {
     }
 
     @Test
-    public void testMakeCoder() {
-        assertNotNull(oper.makeCoder());
+    public void testGetCoder() {
+        assertNotNull(oper.getCoder());
     }
 
     /**
@@ -333,7 +333,7 @@ public class BidirectionalTopicOperationTest {
     private void setOperCoderException() {
         oper = new MyOperation() {
             @Override
-            protected Coder makeCoder() {
+            protected Coder getCoder() {
                 return new StandardCoder() {
                     @Override
                     public String encode(Object object, boolean pretty) throws CoderException {
index f5fd9fb..6d8c60b 100644 (file)
@@ -1259,7 +1259,7 @@ public class OperationPartialTest {
     private void setOperCoderException() {
         oper = new MyOper() {
             @Override
-            protected Coder makeCoder() {
+            protected Coder getCoder() {
                 return new StandardCoder() {
                     @Override
                     public String encode(Object object, boolean pretty) throws CoderException {