dcae-analytics-cdap-plugins/src/test/java/org/openecomp/dcae/apod/analytics/cdap/plugins/domain/config/dmaap/TestDMaaPMRSinkPluginConfig.java

   1 /*
   2  * ===============================LICENSE_START======================================
   3  *  dcae-analytics
   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  *
  11  *          http://www.apache.org/licenses/LICENSE-2.0
  12  *
  13  *  Unless required by applicable law or agreed to in writing, software
  14  *  distributed under the License is distributed on an "AS IS" BASIS,
  15  *  WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  16  *  See the License for the specific language governing permissions and
  17  *  limitations under the License.
  18  *  ============================LICENSE_END===========================================
  19  */
  20
  21 package org.openecomp.dcae.apod.analytics.cdap.plugins.domain.config.dmaap;
  22
  23 import javax.annotation.Nullable;
  24
  25 /**
  26  * Test {@link DMaaPMRSinkPluginConfig} for testing purposes only
  27  * <p>
  28  * @author Rajiv Singla . Creation Date: 1/23/2017.
  29  */
  30 public class TestDMaaPMRSinkPluginConfig extends DMaaPMRSinkPluginConfig {
  31
  32     public void setReferenceName(String referenceName) {
  33         this.referenceName = referenceName;
  34     }
  35
  36     public void setHostName(String hostName) {
  37         this.hostName = hostName;
  38     }
  39
  40     public void setPortNumber(@Nullable Integer portNumber) {
  41         this.portNumber = portNumber;
  42     }
  43
  44     public void setTopicName(String topicName) {
  45         this.topicName = topicName;
  46     }
  47
  48     public void setProtocol(@Nullable String protocol) {
  49         this.protocol = protocol;
  50     }
  51
  52     public void setUserName(@Nullable String userName) {
  53         this.userName = userName;
  54     }
  55
  56     public void setUserPassword(@Nullable String userPassword) {
  57         this.userPassword = userPassword;
  58     }
  59
  60     public void setContentType(@Nullable String contentType) {
  61         this.contentType = contentType;
  62     }
  63
  64     public void setMaxBatchSize(@Nullable Integer maxBatchSize) {
  65         this.maxBatchSize = maxBatchSize;
  66     }
  67
  68     public void setMaxRecoveryQueueSize(@Nullable Integer maxRecoveryQueueSize) {
  69         this.maxRecoveryQueueSize = maxRecoveryQueueSize;
  70     }
  71
  72     public void setMessageColumnName(String messageColumnName) {
  73         this.messageColumnName = messageColumnName;
  74     }
  75
  76 }