Rabbitmq 在项目中的使用

项目中要用mq,为了保证最终一致性;但是demo里面消费没有问题,放到项目里面总是报错

Caused by: java.lang.IllegalStateException: The mapped handler method class 'com.tfjybj.intern.provider.service.impl.SenderServiceImpl$$EnhancerBySpringCGLIB$$7277e23b' is not an instance of the actual endpoint bean class 'com.tfjybj.intern.provider.service.impl.SenderServiceImpl$$EnhancerBySpringCGLIB$$ab569431'. If the endpoint requires proxying (e.g. due to @Transactional), please use class-based proxying.
HandlerMethod details:
Endpoint [com.tfjybj.intern.provider.service.impl.SenderServiceImpl]
Method [public final void com.tfjybj.intern.provider.service.impl.SenderServiceImpl$$EnhancerBySpringCGLIB$$7277e23b.receive0(org.springframework.amqp.core.Message,com.rabbitmq.client.Channel) throws java.io.IOException]
Resolved arguments:
[0] [type=org.springframework.amqp.core.Message] [value=(Body:'{"processDefinitionId":null,"processDefinitionKey":"intern-recruit-1.2","message":null,"businessKey":"1135743530518454279","variables":null,"tenantId":null,"returnVariables":false}' MessageProperties [headers={spring_listener_return_correlation=e1dcd58e-f693-44da-b39f-4050ba48b001, __TypeId__=com.dmsdbj.activiti.qo.ProcessInstanceCreateRequest}, contentType=application/json, contentEncoding=UTF-8, contentLength=0, receivedDeliveryMode=PERSISTENT, priority=0, redelivered=true, receivedExchange=RECRUIT_EXCHANGE, receivedRoutingKey=recruit, deliveryTag=1, consumerTag=amq.ctag-nDzPAKCOjVhkezn-bMtsRA, consumerQueue=RECRUIT_QUEUE])]
[1] [type=com.sun.proxy.$Proxy280] [value=Cached Rabbit Channel: PublisherCallbackChannelImpl: AMQChannel(amqp://root@192.168.67.128:5672/,1), conn: Proxy@37c887f7 Shared Rabbit Connection: SimpleConnection@2b2e5df7 [delegate=amqp://root@192.168.67.128:5672/, localPort= 27889]]at org.springframework.messaging.handler.invocation.InvocableHandlerMethod.assertTargetBean(InvocableHandlerMethod.java:222)at org.springframework.messaging.handler.invocation.InvocableHandlerMethod.doInvoke(InvocableHandlerMethod.java:184)at org.springframework.messaging.handler.invocation.InvocableHandlerMethod.invoke(InvocableHandlerMethod.java:114)at org.springframework.amqp.rabbit.listener.adapter.HandlerAdapter.invoke(HandlerAdapter.java:51)at org.springframework.amqp.rabbit.listener.adapter.MessagingMessageListenerAdapter.invokeHandler(MessagingMessageListenerAdapter.java:182)... 10 common frames omitted

Rabbitmq 在项目中的使用相关推荐

php订单模块解耦,PHP快速使用RabbitMQ实现项目中部分业务的解耦
PHP快速使用RabbitMQ实现项目中部分业务的解耦步骤: 1. Linux安装完rabbitMQ后,没有配置文件,需要去github(https://github.com/rabbitmq/ra ...
（RabbitMQ 二）Springboot项目中使用RabbitMQ的相关依赖
(RabbitMQ 二)Springboot项目中使用RabbitMQ的相关依赖 RabbitMQ系列文章如下: (RabbitMQ 一[转载])windows10环境下的RabbitMQ安装步骤 h ...
面试精讲之面试考点及大厂真题 - 分布式专栏 13项目中为什么要使用消息队列
13项目中为什么要使用消息队列学习从来无捷径,循序渐进登高峰. -- 高永祚引言上个章节把Redis夺命连环问掰扯完,面试还没有结束,消息队列同样是面试中必问的,分布式构建三把斧:缓存+异步+数 ...
电商项目中的经典问题
转载自:https://blog.csdn.net/A_BlackMoon/article/details/80094814 请描述一下这个系统? [回答技巧] 从3个方面来回答这个问题: |--系统 ...
java开发项目中遇到的难点，帮你突破瓶颈
这些面试题你都会了吗?(精选97道Java核心面试题) 常量池有哪些,数据结构,自己设计一个常量池 String为啥设计为final,好处是啥,其中的equals方法如何实现的 jdk序列化怎么实现, ...
怎样破解项目中的“死亡螺旋”困境
你在项目中有没有遇到过这样的困境-- 时间不足,团队新人较多,项目前期质量问题不时爆发需要加急解决,新特性排上日程又没时间开发-- 这些问题往往一环扣一环,如果处理不好,会出现这样的恶性循环-- 爆发 ...
Spring Cloud Alibaba微服务项目中集成Redis实现分布式事务锁实践
引言我们知道同一个进程里面为了解决资源共享而不出现高并发的问题可以通过高并发编程解决,通过给变量添加volatile关键字实现线程间变量可见:通过synchronized关键字修饰代码块.对象或者方 ...
第五课实战go语言改造php仿优酷-RabbitMQ改造项目
第五课实战go语言改造php仿优酷-RabbitMQ改造项目 tags: Beego 慕课网 categories: RabbitMQ 五种工作模式文章目录第五课实战go语言改造php仿优酷- ...
canvas java 上传截图_在Vue项目中使用html2canvas生成页面截图并上传
使用方法项目中引入 npm install html2canvas html代码 //html代码 js代码 // 引入html2canvas import html2canvas from 'ht ...

Rabbitmq 在项目中的使用

Rabbitmq 在项目中的使用相关推荐

最新文章

热门文章