zio sqs 消息属性

Question

我， 我有这样的消费方法：

private def consume(queueUrl: String) =
        SqsStream(
          queueUrl,
          SqsStreamSettings(
            stopWhenQueueEmpty = false,
            waitTimeSeconds = Some(3),
            visibilityTimeout = Some(sqsConfig.visibilityTimeout),
            autoDelete = false,
            messageAttributeNames = List("TEST", AWSTraceHeader.unwrap.toString)
          )
        ).mapError(AwsError.fromThrowable)

然后我将消息发送到队列：

aws sqs 发送消息--endpoint-url “https://sqs.eu-west-2.amazonaws.com/666” --queue-url "https://sqs.eu-west-2.amazonaws.com/666/queue-name" --message-body '{ "event_type": "create", "user_id": "666" }' --message-attributes "AWSTraceHeader={StringValue=TestTenant,DataType=String}"

并且 message.attributes 给了我一张空地图..我做错了什么？谢谢！

Answer 1

我应该使用message.messageAttributes ;) 虚拟错误。