diff options
| author |   Sunil Unnava <su622b@att.com> | 2018-03-06 11:41:18 -0500 |
|---|---|---|
| committer | Sunil Unnava <su622b@att.com> | 2018-03-06 11:48:56 -0500 |
| commit | 173a07c146746f85c17f2d58f2ded84b99818f9a (patch) | |
| tree | b7e57e93665f62e4987fedf15177cf587482f999 /src/main/java/com/att/nsa/mr/tools/MessageCommand.java | |
| parent | fa39dc549397b12c23096bf003b3d24016cfdd44 (diff) | |
testcases for code coverage
Issue-ID: DMAAP-271
Change-Id: I9b11a61d1098598f8dc6c687a10ebf765128d977
Signed-off-by: Sunil Unnava <su622b@att.com>
Diffstat (limited to 'src/main/java/com/att/nsa/mr/tools/MessageCommand.java')
| -rw-r--r-- | src/main/java/com/att/nsa/mr/tools/MessageCommand.java | 7 |
1 files changed, 1 insertions, 6 deletions
diff --git a/src/main/java/com/att/nsa/mr/tools/MessageCommand.java b/src/main/java/com/att/nsa/mr/tools/MessageCommand.java index 354dc18..1c0e666 100644 --- a/src/main/java/com/att/nsa/mr/tools/MessageCommand.java +++ b/src/main/java/com/att/nsa/mr/tools/MessageCommand.java @@ -85,12 +85,7 @@ public class MessageCommand implements Command<MRCommandContext> } else { - final MRBatchingPublisher pub = new PublisherBuilder (). - usingHosts ( context.getCluster () ). - onTopic ( parts[1] ). - authenticatedBy ( context.getApiKey(), context.getApiPwd() ). - build () - ; + final MRBatchingPublisher pub=ToolsUtil.createBatchPublisher(context, parts[1]); try { pub.send ( parts[2], parts[3] ); |