(String topic, int partition, BOptions.Data options)
| 30 | } |
| 31 | |
| 32 | public static MQ createMQ(String topic, int partition, BOptions.Data options) throws Exception { |
| 33 | masterAgent.startAndWaitConnectionReady(); |
| 34 | mqAgent.start(); |
| 35 | return new MQ(masterAgent.createMQ(topic, partition, options)); |
| 36 | } |
| 37 | |
| 38 | public static MQ openMQ(String topic) throws Exception { |
| 39 | masterAgent.startAndWaitConnectionReady(); |