FeedbackReceiver 类
定义
FeedbackReceiver is a specialized receiver whose ReceiveAsync method returns a FeedbackBatch instead of a Message.
public class FeedbackReceiver extends Receiver
- 继承
构造函数
FeedbackReceiver(String hostName, String userName, String sasToken, IotHubServiceClientProtocol iotHubServiceClientProtocol) |
Constructor to verify initialization parameters Create instance of AmqpReceive |
FeedbackReceiver(String hostName, String userName, String sasToken, IotHubServiceClientProtocol iotHubServiceClientProtocol, ProxyOptions proxyOptions) |
Constructor to verify initialization parameters Create instance of AmqpReceive |
FeedbackReceiver(String hostName, String userName, String sasToken, IotHubServiceClientProtocol iotHubServiceClientProtocol, ProxyOptions proxyOptions, SSLContext sslContext) |
Constructor to verify initialization parameters Create instance of AmqpReceive |
FeedbackReceiver(String hostName, String userName, String sasToken, IotHubServiceClientProtocol iotHubServiceClientProtocol, String deviceId) |
Constructor to verify initialization parameters Create instance of AmqpReceive |
方法
close() |
Close AmqpReceive object |
closeAsync() |
Async wrapper for close() operation |
open() |
Open AmqpReceive object |
openAsync() |
Async wrapper for open() operation |
receive() |
Receive FeedbackBatch with default timeout This function is synchronized internally so that only one receive operation is allowed at a time. In order to do more receive operations at a time, you will need to instantiate another FeedbackReceiver instance. |
receive(long timeoutMs) |
Receive FeedbackBatch with specific timeout This function is synchronized internally so that only one receive operation is allowed at a time. In order to do more receive operations at a time, you will need to instantiate another FeedbackReceiver instance. |
receiveAsync() |
Async wrapper for receive() operation with default timeout |
receiveAsync(long timeoutMs) |
Async wrapper for receive() operation with specific timeout |