diff options
Diffstat (limited to 'src/main/java/org/onap/dmaap/mr/test/clients')
3 files changed, 3 insertions, 3 deletions
diff --git a/src/main/java/org/onap/dmaap/mr/test/clients/ConsolePublisher.java b/src/main/java/org/onap/dmaap/mr/test/clients/ConsolePublisher.java index 62e4cda..d8b1979 100644 --- a/src/main/java/org/onap/dmaap/mr/test/clients/ConsolePublisher.java +++ b/src/main/java/org/onap/dmaap/mr/test/clients/ConsolePublisher.java @@ -49,7 +49,7 @@ public class ConsolePublisher public static void main ( String[] args ) throws IOException //throws IOException, InterruptedException { // read the hosts(s) from the command line - final String hosts = args.length > 0 ? args[0] : "aaa.it.att.com,bbb.it.att.com,ccc.it.att.com"; + final String hosts = args.length > 0 ? args[0] : "mr1.onap.com,mr2.onap.com,mr3.onap.com"; // read the topic name from the command line final String topic = args.length > 1 ? args[1] : "TEST-TOPIC"; diff --git a/src/main/java/org/onap/dmaap/mr/test/clients/SampleConsumer.java b/src/main/java/org/onap/dmaap/mr/test/clients/SampleConsumer.java index 1f78be1..eb96780 100644 --- a/src/main/java/org/onap/dmaap/mr/test/clients/SampleConsumer.java +++ b/src/main/java/org/onap/dmaap/mr/test/clients/SampleConsumer.java @@ -38,7 +38,7 @@ public class SampleConsumer { log.info("Sample Consumer Class executing"); - final String topic = "com.att.app.dmaap.mr.testingTopic"; + final String topic = "org.onap.dmaap.mr.testingTopic"; final String url = ( args.length > 1 ? args[1] : "localhost:8181" ); final String group = ( args.length > 2 ? args[2] :"grp" ); diff --git a/src/main/java/org/onap/dmaap/mr/test/clients/SamplePublisher.java b/src/main/java/org/onap/dmaap/mr/test/clients/SamplePublisher.java index 5f8768c..f857afd 100644 --- a/src/main/java/org/onap/dmaap/mr/test/clients/SamplePublisher.java +++ b/src/main/java/org/onap/dmaap/mr/test/clients/SamplePublisher.java @@ -42,7 +42,7 @@ public class SamplePublisher { // read the topic name from the command line - final String topic = ( args.length > 1 ? args[1] : "com.att.app.dmaap.mr.testingTopic" ); + final String topic = ( args.length > 1 ? args[1] : "org.onap.dmaap.mr.testingTopic" ); // set up some batch limits and the compression flag final int maxBatchSize = 100; |