amazon sqs java_无法在侦听器端Amazon SQS java上读取原始字节消息

「爱情、让人受尽委屈。」 2022-11-06 01:52 19阅读 0赞

嗨我在我的春季启动项目中使用SQS，我正尝试发送ByteMessage队列。在侦听器端，我试图将消息转换为byteMessage，但它不工作，我得到异常

org.springframework.jms.listener.adapter.ListenerExecutionFailedException: Listener method 'public void com.sterling.ven

dor.integration.SQSListeners.IFNRequestListener.recieveRequest(javax.jms.Message)' threw exception; nested exception is

java.lang.ClassCastException: com.amazon.sqs.javamessaging.message.SQSTextMessage cannot be cast to javax.jms.BytesMessagemessageSender，和

package com.sterling.vendor.integration.service.impl;

import javax.jms.BytesMessage;

import javax.jms.JMSException;

import javax.jms.Message;

import javax.jms.Session;

import javax.jms.TextMessage;

import org.slf4j.Logger;

import org.slf4j.LoggerFactory;

import org.springframework.beans.factory.annotation.Autowired;

import org.springframework.jms.core.JmsTemplate;

import org.springframework.jms.core.MessageCreator;

import org.springframework.stereotype.Service;

import com.sterling.vendor.integration.service.MessageServiceClient;

@Service("messageServiceClient")

public class MessageServiceClientImpl implements MessageServiceClient \{

final static Logger logger = LoggerFactory.getLogger(MessageServiceClientImpl.class);

@Autowired

private JmsTemplate sqsJmsTemplate;

@Override

public void sendCompress(final String message, String queueName) \{

logger.debug("Sending request message to \{\}", queueName);

sqsJmsTemplate.send(queueName, new MessageCreator() \{

@Override

public Message createMessage(Session session) throws JMSException \{

BytesMessage bytesMessage = session.createBytesMessage();

bytesMessage.writeBytes(DataCompressUtil.compress(message));

return bytesMessage;

\}

\});

\}

\}消息监听

@Service

public class IFNRequestListener\{

private static final Logger LOGGER = LoggerFactory.getLogger(IFNRequestListener.class);

@Value("$\{aws.sqs.ifn.error\}")

private String errorQueue;

@Autowired

private MessageServiceClient messageServiceClient;

@Autowired

private VendorRequestProcessor vendorRequestProcessorImpl;

@Autowired

VendorPostProcessor vendorPostProcessor;

@JmsListener(destination = "$\{aws.sqs.ifn.request\}")

public void recieveRequest(Message message) \{

LOGGER.debug("Message received at IFN Request Listener.");

String strMessagePayload = null;

try \{

BytesMessage byteMessage =(BytesMessage)message;

byte\[\] payload=new byte\[(int) byteMessage.getBodyLength()\];

byteMessage.readBytes(payload);

strMessagePayload = DataCompressUtil.unCompress2String(payload);

LOGGER.info("IFN SQS RequestListener received message Payload");

\} catch (JMSException jmsExcp) \{

LOGGER.error("Failed to parse message body, cannot process this request any further...", jmsExcp);

return;

\}

processMessage(strMessagePayload);

\}

\}虽然我不发送消息，因为SQSTextMessage仍然监听器收到消息作为我不想要的SQSTextMessage。任何人都可以帮助我，让我知道如何让我的原始消息在侦听器端得到我的byteMessage？

发表评论取消回复

表情：

评论列表（有 0 条评论，19人围观）

还没有评论，来说两句吧...

相关阅读

相关 [ 云计算 | AWS ] 对比分析：Amazon SNS 与 SQS 消息服务的异同与选择

![在这里插入图片描述][f6b4b45ef01445aa9a147e7c5f1a8f15.png] 文章目录一、前言二、Amazon S

朱雀/ 2024年02月05日 20:36/ 0 赞/ 104 阅读

相关结合使用Springboot JMS 与 Amazon SQS 标准队列

1. 首先，来了解下[JMS的一些概念][JMS]，[AWS官网例子][AWS]。关于SQS的使用总结可以参考：[https://blog.csdn.net/BAStriver

àì夳堔傛蜴生んèń/ 2023年06月16日 10:50/ 0 赞/ 7 阅读

相关 Query查询(SQ01/SQ02/SQ03)分配事务代码（T-CODE）

文章目录一、概述二、方式1：报表事物类型 - ZA367\_Q001 2.1 Query查询对应的程序名 2.2 分配事物代码

旧城等待，/ 2023年03月02日 13:13/ 0 赞/ 47 阅读

相关根据Query分配的事务代码（T-CODE）查找对应的Query名称（SQ01）、信息集（SQ02）、用户组（SQ03）

文章目录一、概述二、Query查询如何分配事务代码三、根据事务代码反查Query信息 3.1 查询“方式1：报表事物类型”的Query

你的名字/ 2023年03月02日 07:45/ 0 赞/ 79 阅读

相关 SQ小组KTV点歌系统简介

![format_png][] ![format_png 1][] 19级青鸟三班 SQ小组指导老师：穆雄雄老师班主任：王欣欣老师小组成员: 组长:王

男娘i/ 2022年12月25日 02:53/ 0 赞/ 183 阅读

相关 amazon sqs java_无法在侦听器端Amazon SQS java上读取原始字节消息

嗨我在我的春季启动项目中使用SQS，我正尝试发送ByteMessage队列。在侦听器端，我试图将消息转换为byteMessage，但它不工作，我得到异常 org.spring

「爱情、让人受尽委屈。」/ 2022年11月06日 01:52/ 0 赞/ 20 阅读

相关 amazon ec2 mysql_Amazon RDS for MySQL与在Amazon EC2实例上安装MySQL

我一般都是AWS的忠实粉丝…但是RDS,不是那么多. @RolandoMySQLDBA已经指出了一些非常好的反对它. 与EC2上的MySQL相比,我在RDS中看到的唯一优势

痛定思痛。/ 2022年10月24日 05:52/ 0 赞/ 209 阅读

相关 Amazon Aurora

Amazon Aurora 它基于存储计算分离的架构，并将回放日志部分下推到分布式存储层，存储节点与数据库实例(计算节点)松耦合，并包含部分计算功能。 A

太过爱你忘了你带给我的痛/ 2022年06月07日 07:54/ 0 赞/ 177 阅读

相关 Amazon SQS 触发 AWS Lambda 及重试/DLQ

Amazon 在 2018 年 6 月份宣布可以设置用 SQS 来触发 Lambda，SQS 不再是单纯用于 ECS 服务中，或用于伸缩控制的。这儿就来亲自尝试一下用 SQS

缺乏、安全感/ 2022年05月08日 01:10/ 0 赞/ 285 阅读

相关 sql: sq_helptext

--查看表生成脚本 sql server --- '\r'是回车，'\n'是换行 /t相当于键盘的Tab键 --- 操作系统的不同，换行符操也不同：/r

川长思鸟来/ 2021年12月13日 00:53/ 0 赞/ 250 阅读