我有一个需要通过存储队列与 Azure C# 应用程序通信的 java 进程。
在Azure Web中运行时,java 进程能够读取消息并将消息写入存储队列。
但是,当我在本地运行 java 进程并尝试与 Azure 的模拟器通信时,我可以从队列中读取消息,但无法写入队列。
下面是我使用的代码,它挂在最后一行,然后在几分钟后超时。
任何建议将不胜感激。
CloudStorageAccount acct;
if (configuration.equals(configurationTypeLocal)) {
acct = CloudStorageAccount.parse(localStorageConnectionString);
} else {
acct = CloudStorageAccount.parse(cloudStorageConnectionString);
}
CloudQueueClient client = acct.createCloudQueueClient();
_queue = client.getQueueReference(queueName);
_queue.createIfNotExist();
_queue.addMessage(new CloudQueueMessage(txt));