Examples of MsgSender

Examples of com.taobao.metamorphosis.tools.monitor.core.MsgSender

172
173
174
175
176
177
178
179
180
181
182
183
184
  private long getServerMaxOffset(String serverUrl, final String topic,String partition) {
    final List<Long> serverMaxOffsetList = new ArrayList<Long>();
//    String key=partition+"_"+topic;
    final String partitionId = partition.substring(partition.indexOf("-")+1, partition.length());
    MsgSender msgSender = this.coreManager.getSender(serverUrl);
//    final String brokerId = partition.substring(0,partition.indexOf("-"));
        StatsResult ret = msgSender.getStats("offsets", 5000);
        if (ret.isSuccess()) {
          try {
                Utils.processEachLine(ret.getStatsInfo(), new Action() {
                  @Override
                    public void process(String line) {
View Full Code Here

Examples of org.jboss.test.cts.jms.MsgSender

657
658
659
660
661
662
663
664
665
    * Send a JMS message.
    */
   private void sendMsg(String msg)
   {
      if (ms == null)
         ms = new MsgSender();

      ms.sendMsg(msg);
   }
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.