1. 程式人生 > >rocketmq發送消息代碼

rocketmq發送消息代碼

ket keyword ack error end print tty ddr i++

        DefaultMQProducer defaultMQProducer = new DefaultMQProducer();
        defaultMQProducer.setProducerGroup(Constant.operationLogGroup);
        defaultMQProducer.setInstanceName(Constant.operationLogInstance);
        defaultMQProducer.setNamesrvAddr(Constant.rocketQueneAddr);
        try
{ defaultMQProducer.start(); defaultMQProducer.send(message); } catch (Exception e) { logger.error("produce operation log message error", e); } finally { defaultMQProducer.shutdown(); }
‘).addClass(‘pre-numbering‘).hide(); $(this).addClass(‘has-numbering‘).parent().append($numbering); for (i = 1; i <= lines; i++) { $numbering.append($(‘
  • ‘).text(i)); }; $numbering.fadeIn(1700); }); });

    rocketmq發送消息代碼