src/main/java/org/onap/dmaap/dmf/mr/backends/memory/MessageLogger.java

   1 /*******************************************************************************
   2  *  ============LICENSE_START=======================================================
   3  *  org.onap.dmaap
   4  *  ================================================================================
   5  *  Copyright © 2017 AT&T Intellectual Property. All rights reserved.
   6  *  ================================================================================
   7  *  Licensed under the Apache License, Version 2.0 (the "License");
   8  *  you may not use this file except in compliance with the License.
   9  *  You may obtain a copy of the License at
  10  *        http://www.apache.org/licenses/LICENSE-2.0
  11 *
  12  *  Unless required by applicable law or agreed to in writing, software
  13  *  distributed under the License is distributed on an "AS IS" BASIS,
  14  *  WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  15  *  See the License for the specific language governing permissions and
  16  *  limitations under the License.
  17  *  ============LICENSE_END=========================================================
  18  *
  19  *  ECOMP is a trademark and service mark of AT&T Intellectual Property.
  20  *
  21  *******************************************************************************/
  22 package org.onap.dmaap.dmf.mr.backends.memory;
  23
  24 import org.apache.kafka.clients.producer.ProducerRecord;
  25 import org.onap.dmaap.dmf.mr.backends.Publisher;
  26
  27 import java.io.File;
  28 import java.io.FileNotFoundException;
  29 import java.io.FileOutputStream;
  30 import java.io.IOException;
  31 import java.util.ArrayList;
  32 import java.util.List;
  33
  34
  35 /**
  36  * class used for logging perspective
  37  *
  38  * @author anowarul.islam
  39  *
  40  */
  41 public class MessageLogger implements Publisher {
  42         public MessageLogger() {
  43         }
  44
  45         public void setFile(File f) throws FileNotFoundException {
  46                 fStream = new FileOutputStream(f, true);
  47         }
  48
  49         /**
  50          *
  51          * @param topic
  52          * @param msg
  53          * @throws IOException
  54          */
  55         @Override
  56         public void sendMessage(String topic, message msg) throws IOException {
  57                 logMsg(msg);
  58         }
  59
  60         /**
  61          * @param topic
  62          * @param msgs
  63          * @throws IOException
  64          */
  65         @Override
  66         public void sendMessages(String topic, List<? extends message> msgs) throws IOException {
  67                 for (message m : msgs) {
  68                         logMsg(m);
  69                 }
  70         }
  71
  72         /**
  73          * @param topic
  74          * @param kms
  75          * @throws IOException
  76
  77         @Override
  78         public void sendBatchMessage(String topic, ArrayList<KeyedMessage<String, String>> kms) throws
  79
  80         IOException {
  81         }
  82  */
  83         private FileOutputStream fStream;
  84
  85         /**
  86          *
  87          * @param msg
  88          * @throws IOException
  89          */
  90         private void logMsg(message msg) throws IOException {
  91                 String key = msg.getKey();
  92                 if (key == null)
  93                         key = "<none>";
  94
  95                 fStream.write('[');
  96                 fStream.write(key.getBytes());
  97                 fStream.write("] ".getBytes());
  98                 fStream.write(msg.getMessage().getBytes());
  99                 fStream.write('\n');
 100         }
 101         public void sendBatchMessageNew(String topic, ArrayList<ProducerRecord<String, String>> kms) throws IOException {
 102
 103         }
 104
 105         public void sendMessagesNew(String topic, List<? extends message> msgs) throws IOException {
 106         }
 107 }