问题描述
使用Azure Service Bus SDK, 从生产端发送消息进入Service Bus中,频繁遇见如下错误,不知消息是否有成功发送到Service Bus中。
发送代码
public void sendMessage(String msg) { // create a Service Bus Sender client for the topic // send one message to the topic if(senderClient!=null) { senderClient.sendMessage(new ServiceBusMessage(msg)); } }
错误消息
- onTransportError hostname[xxx-xxx-xxx.servicebus.chinacloudapi.cn]...
- Error is transient. Rescheduling authorization task at interval 1079000 ms. scopes[amqp://xxx-xxx-xxx.servicebus.chinacloudapi.cn] Connection reset by peer
- Retry #1. Transient error occurred. Retrying after 4511 ms.
问题解答
日志中记录的TransportError是SDK底层遇到数据传输错误时打出的日志。正常情况下SDK会自动恢复连接和链路,不会对应用或者业务层面造成影响。
... ...