diff options
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] ); |