Amazon SQS Java SDK-无法接收消息属性
messageRequest.addMessageAttributesEntry(
"attributeTest",
new MessageAttributeValue()
.withDataType("String")
.withStringValue("attributeTest 123"));
// Message was previously checked in SQS console and contains
// an attribute named "attributeTest"
AmazonSQS sqs = ...
List<Message> messages = sqs.receiveMessage(receiveMessageRequest).getMessages();
for (Message : messages)
{
Map<String, MessageAttributeValue> attributes = message.getMessageAttributes();
System.out.println("" + attributes.size() + " attributes.");
}
谢谢你的帮助！
共有1个答案
您必须在请求中指定您想要的消息属性（或者使用“all”获取所有消息属性）。所以在你的情况下你可以用任何一种
List<Message> messages = sqs.receiveMessage(receiveMessageRequest.withMessageAttributeNames("attributeTest")).getMessages();
或
List<Message> messages = sqs.receiveMessage(receiveMessageRequest.withMessageAttributeNames("All")).getMessages();
如果您希望将标准属性(ExampiateFirstReceiveTimeStamp、ExampiateReceiveCount、SenderId和SentTimestamp)与消息一起使用，请使用withAttributeNames（“all”）。您可以在ReceiveMessageRequest的Javadocs中找到更多详细信息。
-
如果我创建上面的类并尝试在tomcat7上部署war，我会看到以下错误。
-
我在远程机器上设置了Kafka和动物园管理员。在那台机器上，我可以看到下面使用官方网站上的测试方法工作。 但是当我使用本地消费者脚本时，它就不起作用了： 我试着把它改成： 然后运行客户端使用者脚本，它会给出错误： [2017-08-11 15:49:01,591]获取相关id为3的元数据时警告错误：{listings-incoming=leader_not_available}(org.apach
-
我是一个使用python进行套接字编程的初学者。我正在做我的课程项目。我的项目的一部分需要用不同的端口发送和接收UDP消息。提供了名为robot的服务器程序，我需要编写名为student的客户端程序，它可以与机器人进行交互。因此，我不能显示服务器程序中的所有源代码。 这是服务器程序中与UDP套接字相关的部分 这是我的客户端程序。s3 是 UDP 套接字。我可以成功地向服务器程序发送消息，但无法从中
-
（如这张图所示，我有5条消息可用，但我只能收到2条消息。） 我试图删除收到的两条消息中的一条，然后再次轮询。删除的没有了，我收到了新的消息。但总共还是2条消息。
-
在使用SocketIO的时候，消息将被作为活动(event)的两端接收。在客户端使用JavaScript回叫信号。使用Flask-SocketIO服务器，需要为这些活动注册处理器(handler)，类似于视图函数怎样处理路由。 下面的例子是为一个未命名的活动创建了一个服务端的活动处理器(event handler)： @socketio.on('message') def handle_mess
-
26.4 接收消息 26.4.1 同步接收 虽然 JMS 通常与异步处理相关，但它也可以同步地消费消息。可重载的receive(..)方法提供了这个功能。在同步接收期间，调用线程阻塞，直到接收到消息。这可能是一个危险的操作，因为调用线程可能无限期地被阻塞。receiveTimeout属性指定了接收者等待消息的超时时间。 26.4.2 异步接收 - 消息驱动的 POJOs Spring 还可以通过使