访问现有SQS队列时引发AWS.SimpleQueueService.NonExistentQueue异常

Question

我对AWS SQS服务比较陌生。我编写了一些代码来包装Amazon SQS API。

我能够使用创建的队列执行基本功能，但尽管如此（事实上，我一直在使用这段代码，没有任何问题，并且我创建JUnit测试是作为一种形式），我的JUnit测试失败了，因为一个对我来说毫无意义的错误。

我已经使用AWS管理控制台创建了一个名为SerenaQForTest的队列。当我查看AWS控制台时，我可以看到我创建的队列已经列出。我已经在队列上设置了为每个人打开的权限。我在用Java编程。

当我尝试与队列交互时，我得到一个AmazonServiceException，错误代码为aws.SimpleQueueService.NonExistentQueueError。

这是我的代码。

/**
 * Prefix for queues used to run junit tests.
 */
private static final String TESTQ = "SerenaForTest";

/**
 * Ensures that the queue exists.
 */
@Test
public void testExists() {
    System.out.println("JUnit Test EXISTS.");
    CloudSQS cloudsqs = new CloudSQS();
    // this queue does exist and i can see it through the aws management console in sqs
    assertTrue(cloudsqs.exists(TESTQ));
    // this queue does not exist.
    assertTrue(cloudsqs.exists("thisQDoesNotExist") == false);
}

/**
 * Determines if the queue exists or not.
 * 
 * @param qName
 *            , name of the queue to determine existence of.
 * @return boolean, true if the queue exists; false otherwise.
 */
public boolean exists(final String qName) {
    boolean retVal = false;
    try {
        // create a request for the url of qName
        GetQueueUrlRequest getQueueUrlRequest = new GetQueueUrlRequest(qName);

        String addy = sqs.getQueueUrl(getQueueUrlRequest).getQueueUrl();
        System.out.println(qName + " url : " + addy);
        if (addy != null) {
            // get all queues on sqs
            ListQueuesResult queues = sqs.listQueues();
            // for each url,
            for (String url : queues.getQueueUrls()) {
                // System.out.println("Comparing " + addy + " and " + url);
                if (url.equalsIgnoreCase(addy)) {
                    System.out.println("Queue exists.");
                    retVal = true;
                    break;
                }
            }
        } else {
            System.out.println("Queue " + qName + " does not exist.");
        }
    } catch (AmazonServiceException ase) {
        System.err.println("ERR: AmazonServiceException. Error code: " + ase.getErrorCode());
    } catch (AmazonClientException ace) {
        System.err.println("ERR: AmazonClientException.");
        ace.printStackTrace();
    } catch (Exception e) {
        System.err.println("ERR: Regular Old Error.");
        e.printStackTrace();
    }
    return retVal;
}

JUnit测试存在。SerenaForTest url：https://sqs.us-west-2.amazonaws.com/079023477467/SerenaForTest队列存在。错误：AmazonServiceException。错误代码：AWS.SimpleQueueService.NonExistentQueue

下面是StackTrace：

从这一点上，您可以看到函数能够抓取队列URL，并且找到了匹配项。但它仍然会抛出一个异常。

Answer 1

您确定您创建的队列与您的Java SQS客户机要到达的区域相同吗？AWS SDK for Java中的默认区域是US-EAST-1。您可以通过查看右上方的管理控制台来验证队列的区域。