Changed to unmaintained

[appc.git] / appc-dispatcher / appc-request-handler / appc-request-handler-core / src / main / java / org / onap / appc / messageadapter / impl / MessageAdapterImpl.java

diff --git a/appc-dispatcher/appc-request-handler/appc-request-handler-core/src/main/java/org/onap/appc/messageadapter/impl/MessageAdapterImpl.java b/appc-dispatcher/appc-request-handler/appc-request-handler-core/src/main/java/org/onap/appc/messageadapter/impl/MessageAdapterImpl.java
index 65f5155..ba56da0 100644 (file)
--- a/appc-dispatcher/appc-request-handler/appc-request-handler-core/src/main/java/org/onap/appc/messageadapter/impl/MessageAdapterImpl.java
+++ b/appc-dispatcher/appc-request-handler/appc-request-handler-core/src/main/java/org/onap/appc/messageadapter/impl/MessageAdapterImpl.java
@@ -11,15 +11,14 @@
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.
  * You may obtain a copy of the License at
- * 
+ *
  *      http://www.apache.org/licenses/LICENSE-2.0
- * 
+ *
  * Unless required by applicable law or agreed to in writing, software
  * distributed under the License is distributed on an "AS IS" BASIS,
  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  * See the License for the specific language governing permissions and
  * limitations under the License.
- * 
  * ============LICENSE_END=========================================================
  */
 
@@ -38,7 +37,7 @@ import org.onap.appc.srvcomm.messaging.MessagingConnector;
 public class MessageAdapterImpl implements MessageAdapter{
 
     private MessagingConnector messageService;
-    private String partition ;
+    private String partition;
 
     private static final EELFLogger logger = EELFManager.getInstance().getLogger(MessageAdapterImpl.class);
 
@@ -46,23 +45,25 @@ public class MessageAdapterImpl implements MessageAdapter{
      * Initialize producer client to post messages using configuration properties
      */
     @Override
-    public void init(){
-       logger.debug("MessageAdapterImpl - init");
+    public void init() {
+        logger.debug("MessageAdapterImpl - init");
         this.messageService = new MessagingConnector();
     }
-    
+
     public void init(MessagingConnector connector) {
         logger.debug("MessageAdapterImpl - init");
         this.messageService = connector;
     }
 
     /**
-     * Posts message to DMaaP. As DMaaP accepts only json messages this method first convert dmaapMessage to json format and post it to DMaaP.
-     * @param asyncResponse response data that based on it a message will be send to DMaaP (the format of the message that will be sent to DMaaP based on the action and its YANG domainmodel).
-     * @return True if message is postes successfully else False
+     * Posts message to DMaaP. As DMaaP accepts only json messages this method first converts dmaapMessage
+     * to json format and posts it to DMaaP.
+     * @param asyncResponse response data on which to base a message that will be sent to DMaaP
+     * (the format of the message that will be sent to DMaaP is based on the action and its YANG domainmodel).
+     * @return True if message is posted successfully, else False
      */
     @Override
-    public boolean post(VNFOperation operation, String rpcName, ResponseContext asyncResponse){
+    public boolean post(VNFOperation operation, String rpcName, ResponseContext asyncResponse) {
         boolean success;
         if (logger.isTraceEnabled()) {
             logger.trace("Entering to post with AsyncResponse = " + ObjectUtils.toString(asyncResponse));
@@ -70,18 +71,19 @@ public class MessageAdapterImpl implements MessageAdapter{
         logger.debug("Entered MessageAdapterImpl.post()");
         String jsonMessage;
         try {
-               logger.debug("Before converting Async Response");
-            jsonMessage = Converter.convAsyncResponseToDmaapOutgoingMessageJsonString(operation, rpcName, asyncResponse);
+            logger.debug("Before converting Async Response");
+            jsonMessage =
+                    Converter.convAsyncResponseToDmaapOutgoingMessageJsonString(operation, rpcName, asyncResponse);
             if (logger.isDebugEnabled()) {
                 logger.debug("DMaaP Response = " + jsonMessage);
             }
-            logger.debug("Before Invoking producer.post(): jsonMessage is::" + jsonMessage);
+            logger.debug("Before Invoking messageService.publishMessage(): jsonMessage is::" + jsonMessage);
             success = messageService.publishMessage("appc.LCM", this.partition, jsonMessage);
-            logger.debug("After Invoking producer.post()");
+            logger.debug("After Invoking messageService.publishMessage()");
         } catch (JsonProcessingException e1) {
             logger.error("Error generating Json from DMaaP message " + e1.getMessage());
             success = false;
-        }catch (Exception e){
+        } catch (Exception e) {
             logger.error("Error sending message to DMaaP " + e.getMessage());
             success = false;
         }