src/test/java/org/onap/dmaap/mr/test/support/MRBatchingPublisherMockTest.java

   1 /*-
   2  * ============LICENSE_START=======================================================
   3  * ONAP Policy Engine
   4  * ================================================================================
   5  * Copyright (C) 2017 AT&T Intellectual Property. All rights reserved.
   6  * ================================================================================
   7  * Modifications Copyright © 2021 Orange.
   8  * ================================================================================
   9  * Licensed under the Apache License, Version 2.0 (the "License");
  10  * you may not use this file except in compliance with the License.
  11  * You may obtain a copy of the License at
  12  *
  13  *      http://www.apache.org/licenses/LICENSE-2.0
  14  *
  15  * Unless required by applicable law or agreed to in writing, software
  16  * distributed under the License is distributed on an "AS IS" BASIS,
  17  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  18  * See the License for the specific language governing permissions and
  19  * limitations under the License.
  20  * ============LICENSE_END=========================================================
  21  */
  22
  23 package org.onap.dmaap.mr.test.support;
  24
  25 import org.junit.After;
  26 import org.junit.Before;
  27 import org.junit.Test;
  28 import org.onap.dmaap.mr.client.MRPublisher.Message;
  29
  30 import java.util.ArrayList;
  31
  32 import static org.junit.Assert.assertTrue;
  33
  34 public class MRBatchingPublisherMockTest {
  35     private MRBatchingPublisherMock pub = null;
  36
  37     private MRBatchingPublisherMock.Entry entry = null;
  38
  39     @Before
  40     public void setUp() throws Exception {
  41         pub = new MRBatchingPublisherMock();
  42         entry = pub.new Entry("partition", "msg");
  43
  44     }
  45
  46     @After
  47     public void tearDown() throws Exception {
  48
  49     }
  50
  51     @Test
  52     public void testToString() {
  53
  54         entry.toString();
  55         assertTrue(true);
  56
  57     }
  58
  59     @Test
  60     public void testAddListener() {
  61
  62         pub.addListener(null);
  63         assertTrue(true);
  64
  65     }
  66
  67     @Test
  68     public void testGetCaptures() {
  69
  70         pub.getCaptures();
  71         assertTrue(true);
  72
  73     }
  74
  75     @Test
  76     public void testGetCaptures2() {
  77
  78         pub.getCaptures(null);
  79         assertTrue(true);
  80
  81     }
  82
  83     @Test
  84     public void testReceived() {
  85
  86         pub.received();
  87         assertTrue(true);
  88
  89     }
  90
  91     @Test
  92     public void testResend() {
  93
  94         pub.reset();
  95         assertTrue(true);
  96
  97     }
  98
  99     @Test
 100     public void testSend() {
 101
 102         pub.send("partition", "msg");
 103         assertTrue(true);
 104
 105     }
 106
 107     @Test
 108     public void testSend2() {
 109
 110         pub.send("msg");
 111         assertTrue(true);
 112
 113     }
 114
 115     @Test
 116     public void testSend3() {
 117         //sending message m obj
 118         pub.send(new ArrayList<Message>());
 119         assertTrue(true);
 120
 121     }
 122
 123     @Test
 124     public void testSend4() {
 125         //sending collection of message m objects
 126         pub.send(new Message("partition", "msg"));
 127         assertTrue(true);
 128
 129     }
 130
 131     @Test
 132     public void testSendBatchWithResponse() {
 133
 134         pub.sendBatchWithResponse();
 135         assertTrue(true);
 136
 137     }
 138
 139     @Test
 140     public void testLogTo() {
 141
 142         pub.logTo(null);
 143         assertTrue(true);
 144
 145     }
 146
 147     @Test
 148     public void testClearApiCredentials() {
 149
 150         pub.clearApiCredentials();
 151         assertTrue(true);
 152
 153     }
 154
 155     @Test
 156     public void testSetApiCredentials() {
 157
 158         pub.setApiCredentials("apikey", "apisecret");
 159         assertTrue(true);
 160
 161     }
 162
 163     @Test
 164     public void testClose() {
 165
 166         pub.close();
 167         assertTrue(true);
 168
 169     }
 170
 171     @Test
 172     public void testClose2() {
 173
 174         pub.close(100, null);
 175         assertTrue(true);
 176
 177     }
 178
 179     @Test
 180     public void testGetPendingMessageCount() {
 181
 182         pub.getPendingMessageCount();
 183         assertTrue(true);
 184
 185     }
 186 }