import org.apache.kafka.clients.consumer.KafkaConsumer;
import org.junit.jupiter.api.BeforeAll;
+import org.junit.jupiter.api.Disabled;
import org.junit.jupiter.api.Test;
import com.samsung.ci.basic.api.MQListenerAPI;
* @throws InterruptedException the interrupted exception
* @throws IOException the io exception
*/
+ @Disabled
@Test
public void testTVPolicyPositiveTestCase() throws InterruptedException, IOException {
Thread.sleep(TIMEOUT);
* @throws InterruptedException the interrupted exception
* @throws IOException the io exception
*/
+ @Disabled
@Test
public void testPhonePolicyPositiveTestCase() throws InterruptedException, IOException {
Thread.sleep(TIMEOUT);