lzkisok commented on issue #215:
URL: https://github.com/apache/rocketmq-mqtt/issues/215#issuecomment-1780653347
Thread t1 = new Thread(new Runnable(){
@Override
public void run() {
try {
sendMessage(1);
} catch (MQBrokerException e) {
throw new RuntimeException(e);
} catch (RemotingException e) {
throw new RuntimeException(e);
} catch (InterruptedException e) {
throw new RuntimeException(e);
} catch (MQClientException e) {
throw new RuntimeException(e);
}
}
});
Thread t2 = new Thread(new Runnable(){
@Override
public void run() {
try {
sendMessage(2);
} catch (MQBrokerException e) {
throw new RuntimeException(e);
} catch (RemotingException e) {
throw new RuntimeException(e);
} catch (InterruptedException e) {
throw new RuntimeException(e);
} catch (MQClientException e) {
throw new RuntimeException(e);
}
}
});
Thread t3 = new Thread(new Runnable(){
@Override
public void run() {
try {
sendMessage(3);
} catch (MQBrokerException e) {
throw new RuntimeException(e);
} catch (RemotingException e) {
throw new RuntimeException(e);
} catch (InterruptedException e) {
throw new RuntimeException(e);
} catch (MQClientException e) {
throw new RuntimeException(e);
}
}
});
Thread t4 = new Thread(new Runnable(){
@Override
public void run() {
try {
sendMessage(4);
} catch (MQBrokerException e) {
throw new RuntimeException(e);
} catch (RemotingException e) {
throw new RuntimeException(e);
} catch (InterruptedException e) {
throw new RuntimeException(e);
} catch (MQClientException e) {
throw new RuntimeException(e);
}
}
});
Thread t5 = new Thread(new Runnable(){
@Override
public void run() {
try {
sendMessage(5);
} catch (MQBrokerException e) {
throw new RuntimeException(e);
} catch (RemotingException e) {
throw new RuntimeException(e);
} catch (InterruptedException e) {
throw new RuntimeException(e);
} catch (MQClientException e) {
throw new RuntimeException(e);
}
}
});
t1.start();
t2.start();
t3.start();
t4.start();
t5.start();
这是测试用的RocketMQProducer中main方法的发送mq的代码
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: commits-unsubscr...@rocketmq.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
