@RabbitListener 不起作用,但是信息可以发。

这两天整理RabbitMq,写了个问个测试东西,但是一直收到不信息,发就可以,在mq的
界面也能看到信息。以下是代码,大神帮忙看看哇

//连接rabbitMQ的基本配置
@Configuration
@EnableRabbit
public class RabbitConfig {
        @Bean
        public ConnectionFactory connectionFactory() {
            CachingConnectionFactory connectionFactory = new CachingConnectionFactory("192.168.88.246");
            connectionFactory.setUsername("admin");
            connectionFactory.setPassword("123456");
            connectionFactory.setPort(5672);
            return connectionFactory;
        }
        @Bean
        public AmqpAdmin amqpAdmin() {
            return new RabbitAdmin(connectionFactory());
        }
        @Bean
        public RabbitTemplate rabbitTemplate() {
            return new RabbitTemplate(connectionFactory());
        }
        //配置消费者监听的容器
        @Bean
        public SimpleRabbitListenerContainerFactory rabbitListenerContainerFactory() {
            SimpleRabbitListenerContainerFactory factory = new SimpleRabbitListenerContainerFactory();
            factory.setConnectionFactory(connectionFactory());
            factory.setConcurrentConsumers(3);
            factory.setMaxConcurrentConsumers(10);
            return factory;
        }
}

订阅配置


@Configuration
public class PublishSubscribeConfig {

    @Autowired
    RabbitConfig rabbitconfig;

    @Autowired
    UpdateOrgConfig orgConfig;

    @Bean
    public Queue myQueue1() {
       Queue queue=new Queue(orgConfig.getName());
       return queue;
    }

    @Bean
    public Queue myQueue2() {
       Queue queue=new Queue("com..updateorg.msg.2");
       return queue;
    }

    @Bean
    public FanoutExchange fanoutExchange(){
        FanoutExchange fanoutExchange=new FanoutExchange("fanout");
        return fanoutExchange;
    }

    @Bean
    public Binding binding1(){
        Binding binding=BindingBuilder.bind(myQueue1()).to(fanoutExchange());
        return binding;
    }

    @Bean
    public Binding binding2(){
        Binding binding=BindingBuilder.bind(myQueue2()).to(fanoutExchange());
        return binding;
    }

}

监听配置


@Component
public class OrgConsumer2 {

    @RabbitListener(queues = "com..updateorg.msg.2")
    public void subscribe(String msg) throws IOException {
        System.out.println("订阅者2收到消息"+ msg);
    }
}

死活收到不信息

1个回答

yeyein9
yeyein9 还是没用
4 个月之前 回复
Csdn user default icon
上传中...
上传图片
插入图片
抄袭、复制答案,以达到刷声望分或其他目的的行为,在CSDN问答是严格禁止的,一经发现立刻封号。是时候展现真正的技术了!
其他相关推荐
设置了中断但是不起作用
我在调试某一个aspx页的时候,在page_onload里面一个地方加上了断点,rn但是执行这个页面的时候,中断根本不起作用,其他的文件中断都好用,为什么呢?rnrn还有一个页面,在page_onload执行结束后,又执行了其他页面中的后台程序,rn肯定没有嵌套,为什么会有这样的情况呢?rnrn
可以在这里发招聘信息吗?
rn公司在北京, 朝阳门, 详见这个帖子: http://topic.csdn.net/u/20080925/14/c2359441-798b-4b14-a260-956141b77cb4.htmlrn
啊但是发萨芬
阿斯顿发
java小程序可以运行,但是actionPerformed()好像不起作用?帮忙看看谢谢
import java.util.Vector;rnimport javax.swing.JOptionPane;rnimport javax.swing.*;rnimport java.awt.event.ActionEvent;rnimport java.awt.event.ActionListener; rnimport java.awt.GridLayout;rnrnrnrnpublic class PswFrame extends JFrame implements ActionListenerrn public JButton btn;rn public JLabel lbl;rn private JTextField tf;rn //public JLabel tip;rn Vector pswVector;rn rn pswVector=new Vector(3);rn String [] psw=new String[3];rn psw[0]="19891989";rn psw[1]="123456";rn psw[2]="62175918";rn for(int i=0;i
VC6.0编译可以通过,但是运行按钮不起作用!求真相!
电脑安装过一次VC6.0,什么情况都OK,有一次编译一个很大的东西,不行,我删除以后,重新安装VC6.0,就出现现在的问题:“[color=#3366FF]VC6.0编译可以通过,但是运行按钮不起作用! 但是我在cmd 里面运行编译后的exe程序是能运行成功的[/color]” 求真相!
信息发射源
定义:一个信息发射源在任何人都可见的地方显示信息。有了信息发射源,大家不需要问任 何问题。 有效的信息发射源 简单:易于掌握 突显:错误不应该掩盖,而是应该用于提高工作和性能 当前:展示的信息必须是当前的 转移:一旦问题被纠正,应该从图表中移除 影响:授权团队做决定 高度可见:容易看到和理解 最小的数量:关键信息应该被强调 信息发射源有助于对于成功验收、交付物的共识。 信息发射源用来促进干系人期望...
局域网发公告信息
局域网发公告信息
求救:串口收不到电机的反馈信息,但是可以成功发命令给电机
问题如下:rnrn要调试一个步进电机,用串口调试工具和xp的超级终端都可以,打开串口发送命令即可。现在我写了一个工具,可以对电机进行傻瓜式的设置和调试,问题出来了,正常情况下,用串口调试助手给电机发送指令,电机会将该指令回发给串口助手,并在执行完该指令后返回“ok”。rnrn例如:发送 “MR1000”给电机rnrn则电机反馈"MR1000"rnrn “ok”rnrn用串口助手操作,收发都没有任何问题,而用我的工具对电机操作(程序采用MSComm控件),只能成功发送指令,却收不到电机的反馈信息,经调试发现是在GetInput()函数处出现问题,扔出异常了···rnrn而我利用虚拟串口,可和串口调试助手互发消息,并且可以正常接收,没有丝毫问题···rnrn让我很不解···为啥可以收到串口调试助手的信息,却无法收到电机发来的信息呢?rnrn rnrn卡了好久了,求高人解答···rnrnrn[url=http://url.cn/NjEms4][/url]rn(上传图片老是报错,这是图片地址)rn坐等,欢迎讨论····rnrn​rn
C语言。将信息输入到文件中,打开文件发现是乱码,但是可以正常输出
[img=https://img-bbs.csdn.net/upload/201801/01/1514813572_952290.png][/img]rn这是输入部分的代码rn[img=https://img-bbs.csdn.net/upload/201801/01/1514813579_326066.png][/img]rn这是运行以后打开的文件内容rn但是输出信息的时候是正确的,为什么?
EXchange 2003 外发限制不起作用问题
EX 03 已经作了外发限制 但测试还是可以外发 点解rnrn还有 作了邮箱策略 如何指定用于某个邮箱 如何手动应用策略rnrn另外 我处使用 一个outlook先接受外网邮件 然后再通过exchange转发到内网各用户邮箱rnoutlook 已经设置了自动转发规则 但每天还是大约有1/3邮件没有转发,需过手动转发 累死了rnrn改用outlook express(6.0)做自动转发的话 转发后的信件没有原来邮件的邮件头(手动转发却带,郁闷。。。。)rn请问有没有好方法 或者有没有能使用ot或oe邮件格式的第三方 邮件客户端软件
exchange2003,不能接收其它邮件服务器的发的邮件,但是可以发送
原来都可以,今天不行了,怎么办啊
为啥我发的NM_CLICK消息不起作用
我想用代码摸拟点击一个对话框内里的CListCtrl特定的网格(ListCtrl是rn Report型且带网格线的风格),但却不起作用,请各位大虾给看看源码中的错误。 rnrn NMLISTVIEW nlv;rn NMHDR nh;rn nh.hwndFrom=m_listCtrl.GetSafeHwnd();rn nh.idFrom=IDC_LIST1;rn nh.code=NM_CLICK;rn nlv.hdr=nh;rn nlv.iItem=min(m_listCtrl.GetItemCount(),1);rn nlv.iSubItem=0;rn nlv.uNewState=0;rn nlv.uOldState=0;rn nlv.uChanged =0;rn BOOL b=FALSE;rn m_listCtrl.SetFocus();rn b=m_listCtrl.SendMessage(NM_CLICK,0,(LPARAM)&nlv);rn //b always is FALSE!!!rn if(!b) TRACE0("Failed\n");
hibernate 中配置了show_sql但是还是不起作用
rn rn org.hibernate.dialect.MySQLDialectrn rn rn jdbc:mysql://localhost:3306/oa1rn rn rootrn rootrn rn com.mysql.jdbc.Driverrn rn ssh-12-28rn truern
在delphi2007中设置断点,但是不起作用
用delphi2007编写的一个Dll程序,把程序修改,直接点执行,程序也会修改。但是我在修改处加上断点,就是不管用,一执行,断点就变暗,更本不管用,这可能是什么原因导致的啊?
echart中的地图,设置了颜色,但是不起作用
nn```n itemStyle: n normal: n borderWidth:2,n borderColor:'#969696',//边框颜色n color: '#333399',//地图颜色(设置后没起作用),n //areaStyle:color:'#333399',n areaStyle:color:'green',n label: n show: truen n ,n```nn
江苏的可以发证书了
我昨天打了电话,他们说江苏的证书29日就可以发了,但市里拿可能慢了点,你可以打电话给市里,告诉他们这个消息,让他们去省里拿,我叫市里29日就去,4月1日就可以拿到了!!!!rn省里的电话:025-----83342413
android:layout_marginTop="10dp"不报错 但是不起作用
rn rn rn android:layout_marginTop="10dp"不报错 但是不起作用其他控件都起作用就view不起作用
添加JMAIL功能,但是不起作用,请帮帮忙!
我的空间支持JMAIL,有一次我发送成功了,不过后来我又改了一下代码,就改不回来了,55555~~~rndim msgrnSet msg = Server.CreateObject("JMail.Message")rnmsg.silent = truernmsg.Logging = truernmsg.Charset = "gb2312"rnmsg.MailServerUserName = "username" '输入smtp服务器验证登陆名 我在163的IDrnmsg.MailServerPassword = "password" '输入smtp服务器验证密码 我在163的密码rnmsg.From = "username@163.com" '发件人rnmsg.FromName = "username"rnmsg.AddRecipient ""&trim(request("useremail"))&"" '收件人rnmsg.Subject = "haha" '主题rnmsg.Body = "this is body!" '正文rnmsg.Send ("smtp.163.com") 'smtp服务器地址rnset msg = nothing
组合键不起作用,但是也没提示错误
[code=C#] rn private void Form1_KeyDown(object sender, KeyEventArgs e)rn rn if (e.Alt && e.KeyCode == Keys.S)rn rn rtbget.Text += rtbsend.Text + System.Environment.NewLine;//显示框显示输入的字符并换行rn rtbsend.Clear();//清空自身rn rnrn rn[/code]rn如题
关于鼠标指针的问题(设置了但是不起作用)
我把鼠标设置成沙漏,可是在程序执行的时候,却没有像想像中那样的效果,如果看的仔细一点,可以看到鼠标变成沙漏一闪而过,时间不超过1/4秒。请问大家有谁碰到过这种情况?有谁知道为什么,有谁知道解决方法。
包含文件1.aspx,但是1.aspx.cs不起作用的问题
我用temp.aspx文件包含1.aspx文件rn代码如下:rnrn结果写在1.aspx.cs里面的代码不起作用rn如何解决??????rn
springMVC+ehcache 配置没有问题,但是缓存不起作用
照着网上的例子用springMVC+ehcache 基于注解的方式 实现缓存功能,配置 没有报错,但是 却不能实现 缓存。 :( 后来 我又用原先成功实现缓存的springAOP拦截器的方式, 也还是不能实现缓存,我觉得 可能是有些冲突或者是被拦截了。rn具体代码如下,大家看看吧(这里用了springMVC+mybatis+ehcache):rnrnspring-config.xml:rnrnrnrn rn rn rn rn rn rn rn rn rn rn rnrnrn rn rn rn rn rn rn rn rn rn rn rn rn rn rn rn rnrn rn rn rn classpath:mybatis.xmlrn rn rn rn rn classpath:com/myword/mapper/*.xmlrn rn rn rn rn rn rn rn rnrn rn rn rn rnrn rn rn rn rnrnrnrnspring-mvc.xml:rnrnrnrn rn rn rnrn rn rn rnrn rn rn rn rn rn rn rn rn rn rn rn rn rn rn rn rn rn rn rn rn rn rn rn rn rn rn rn rn rn rn rn rn rn rn rn rn rn rn rn rn rn rn rn rn rn rn rn classpath:ehcache.xmlrn rn rn rn主要的配置 就是这两个,其他导入的 ehcache.xml和mybatis.xml就没有贴出来了。rnrnservice 的javabean:rn@Servicernpublic class UsersServI implements UsersServrn rn @Autowiredrn private UsersMapper usersMapper;rnrn @Cacheable("baseCache")rn public List getUsersAll(UsersExample example) rn System.out.println("======ok======");rn return usersMapper.selectByExample(example);rn rnrnaction 中的打印处理:rnCache baseCache = manager.getCache("baseCache");rn System.out.println("Cache named baseCache:"+baseCache);rnSystem.out.println("============one===============");rn UsersExample example = new UsersExample();rn usersServ.getUsersAll(example);rn System.out.println("============two===============");rn usersServ.getUsersAll(example);rnrnrn结果发现 执行后 后台打印出:rnCache named baseCache:[ name = baseCache status = STATUS_ALIVE eternal = false overflowToDisk = true maxEntriesLocalHeap = 10000 maxEntriesLocalDisk = 0 memoryStoreEvictionPolicy = LRU timeToLiveSeconds = 600000 timeToIdleSeconds = 300000 persistence = none diskExpiryThreadIntervalSeconds = 120 cacheEventListeners: net.sf.ehcache.statistics.LiveCacheStatisticsWrapper hitCount = 0 memoryStoreHitCount = 0 diskStoreHitCount = 0 missCountNotFound = 0 missCountExpired = 0 maxBytesLocalHeap = 0 overflowToOffHeap = false maxBytesLocalOffHeap = 0 maxBytesLocalDisk = 0 pinned = false ]rn============one===============rn======ok======rn============two===============rn======ok======rnrnrnrn第一个打印"Cache named ..."说明ehcache配置是成功的,ehcache.xml中的cache name 也被打印出来了。rn但是 后面getUsersAll方法却被执行了两次 说明 ehcache根本没有起作用。到底哪里出问题了呀?
TCP的监视端口。可以接收UDP发送来的信息吗?
TCP的监视端口。可以接收UDP发送来的信息吗?
终于可以发存信息了.问二个问题先.
1.有谁做过SOCKS5的编程,或者哪有例子\网站....rnrn2.哪里有TAPI的详细资料?rnrn3.我用lineinitialize(...,mycallpoc,...)初始化rn用lineNegotitateAPIVersion()协商版本rn用lineGetDevCaps()查询有关信息rn用lineOpen()打开设备rn用lineMakeCall()发出呼叫rn这些可以正确完成,但我后来不用lineMakeCall(),我想在有rn电话打来时响应一些事件,但是mycallpoc中好像没有接收到有关rnLineState消息.rnrn4.是不是普通用户不可以用lineRedirect进行电话转移?非要电信rn局才可以?rnrn
?用smtpmail 发别人可以,发自己就不可以
Private Sub Button1_Click(ByVal sender As System.Object, ByVal e As System.EventArgs) Handles Button1.Clickrnrn Dim newmail As MailMessage = New MailMessage()rn newmail.To = "caiyiming8888@126.com"rn newmail.From = "caiyiming8888@163.com"rn newmail.Subject = "test"rn newmail.Body = "sdfsfsadfasdf"rn newmail.BodyFormat = MailFormat.Htmlrn SmtpMail.Send(newmail)rn End Subrn发送成功rn但newmail.To = "caiyiming8888@126.com" 改成rnnewmail.To = "caiyiming8888@163.com"就不可以
Android TextVies:设置背景颜色动态显示,但是不起作用
给一个android的TextView设置背景颜色动态显示,到那时好像不起作用。我是少了什么东西么?rnrn TextView et = new TextView(activity);rn et.setText("350");rn et.setBackgroundColor(R.color.white);rn I also have this file (colors.xml) in my res/values folderrnrn在我的res/values文件夹中还有这个文件(colors.xml)rnrn rn #ffffffffrn #ff000000rn rnrnrn而且,设置文本的颜色引起了TextView消失。rnrn TextView c1 = new TextView(activity);rn c1.setTextColor(R.color.solid_red);rn c1.setText("My Text");
dns不起作用 但是重起后即好
dns两个。 能ping 通 但是不能解析域名 ie不能上网。 但是重起后 恢复正常
vs2010安装AnkhSVN,但是不起作用解决方法
Tool->option->Source control->plug-in selection,选择ankhSVN
linux jdk新版本 但是不起作用的问题
注:我在配置JAVA环境变量的时候,运行java -version得到的却是java version "1.4.2" export PATH=$JAVA_HOME/bin:$PATH,注意将$PATH放到最后。(如果放到最前,则会出现上述问题)...
微信信息发送与接收
微信的关注弹出推送信息,用户回复数字,回复给用户相应的信息,Java代码实现
socket发送与接收信息
我想用socket完成这样一个功能:rn 在客户端输入编号与密码,发送到服务器,然后服务器接受数据并对编号和密码进行判断是否正确,若正确则发送信息rn给客户端,让客户进入系统,否则同样发送错误信息。rn以下是客户端代码:[code=C/C++][/code]rnvoid MLoginDlg::OnOkBtn() rnrn // TODO: Add your control notification handler code herern UpdateData(true);rn if(m_pass=="")rn rn MessageBox("密码不能为空!");rn return;rn rn if(m_mno=="")rn rn MessageBox("编号不能为空!");rn return;rn rnrn WSABUF wsabuf;rn DWORD dwSend;rn SOCKADDR_IN addrTo;rn addrTo.sin_family=AF_INET;rn addrTo.sin_port=htons(2000);rn addrTo.sin_addr.S_un.S_addr=inet_addr("127.0.0.1");rn rn CString strSend;rn strSend=m_mno+"\\"+m_pass;rnrn int len;rn len=strSend.GetLength();rn wsabuf.buf=strSend.GetBuffer(len);rn wsabuf.len=len+1;rnrnrn if(SOCKET_ERROR==WSASendTo(m_cliSocket,&wsabuf,1,&dwSend,0,rn (SOCKADDR*)&addrTo,sizeof(SOCKADDR),NULL,NULL))rn rn MessageBox("发送数据失败!");rn return;rn rnrnrn WSABUF wsabufrecv;rn wsabufrecv.buf=new char[20];rn wsabufrecv.len=20;rn DWORD dwRead;rn DWORD dwFlag=0;rn CString str;rn int addlen;rn addlen=sizeof(SOCKADDR);rn if(SOCKET_ERROR==WSARecvFrom(m_cliSocket,&wsabufrecv,1,&dwRead,&dwFlag,rn (SOCKADDR*)&addrTo,&addlen,NULL,NULL))rn rn MessageBox("接收数据失败!");rn return;rn rnrn str.Format("%s",wsabufrecv.buf);rn if(str=="true")rn rn mno=m_mno;rn CDialog::OnOK();rn managerDlg dlg;rn dlg.DoModal();rn rn elsern rn MessageBox("你输入的编号或密码错误,请重新输入!");rn return;rn rnrn下面是服务器代码:rnrn[code=C/C++][/code]rnswitch(LOWORD(lParam))rn rn case FD_READ:rn WSABUF wsabuf;rn wsabuf.buf=new char[200];rn wsabuf.len=200;rn DWORD dwRead;rn DWORD dwFlag=0;rn SOCKADDR_IN addrFrom;rn int len=sizeof(SOCKADDR);rn CString str,host;rn CString noStr,passStr;rn int pos;rn HOSTENT *pHost;rn if(SOCKET_ERROR==WSARecvFrom(m_serSocket,&wsabuf,1,&dwRead,&dwFlag,rn (SOCKADDR*)&addrFrom,&len,NULL,NULL))rn rn MessageBox("接收数据失败!");rn return;rn rn pHost=gethostbyaddr((char*)&addrFrom.sin_addr.S_un.S_addr,4,AF_INET);rn str.Format("%s",wsabuf.buf);rn host.Format("%s",pHost->h_name);rn m_list.AddString("host 想登陆管理系统!");rn pos=str.ReverseFind ('\\');rn noStr=str.Left(pos); //获取编号rn passStr=str.Right(pos); //获取密码rnrn CString strSend;rn WSABUF wsabufsend;rn DWORD dwSend;rn int sendlen;rn tryrn rn m_mangerSet->m_strFilter.Format("mno='%s' and mpass='%s'",noStr,passStr);rn m_mangerSet->Open();rn if(m_mangerSet->IsEOF())rn strSend="false";rn elsern strSend="true";rn rn sendlen=strSend.GetLength();rn wsabufsend.buf=strSend.GetBuffer(len);rn wsabufsend.len=sendlen+1;rnrn if(SOCKET_ERROR==WSASendTo(m_serSocket,&wsabufsend,1,&dwSend,0,rn (SOCKADDR*)&addrFrom,sizeof(SOCKADDR),NULL,NULL))rn rn MessageBox("发送数据失败!");rn return;rn rn rn catch(CDBException* e)rn rn e->ReportError();rn e->Delete();rn return;rn rn break;rn rnrn请各位看看有什么错误,请指正
网站有人发垃圾信息
我的一个供求信息网站 [url=http://www.fcp18.com][/url] 也不知道是什么问题老是有人可以在上面发垃圾信息 rn好像还是用什么工具发的 是程序些的有什么漏洞 还是怎么回事rn我刚清除完 一会垃圾供求信息有有了 这个页面下面的信息 [url=http://www.fcp18.com/sca.asp][/url]
免费聊天室发不了信息
http://expert.csdn.net/Expert/topic/2271/2271595.xml?temp=.1448328
发送接受消息实战之@RabbitListener接受消息
本课程适用于RabbitMQ实战者以及SpringBoot整合RabbitMQ实战需求者。课程将首先带领大家拜读RabbitMQ官网的技术开发手册,之后会将学到的知识深入的实战到实际的各种应用场景中,从而加深知识点的理解,rn其中包括如何实现单一队列多个消费者监听消费、业务服务模块解耦通信、抢单高并发方案的解决、登录成功异步写日志、异步发送邮件、死信队列实战以及实现用户下单超时未支付自动失效等等。
使用SqlDataReader取得数据库返回信息,不起作用~
我想实现一个通过if语句接收存储过程的返回结果,rn从而判断出用户输入是否是数据库中的帐号!rn以下代码能够运行,但if语句不起作用!点击确定后,rn无论数据库有没有用户信息,都直接显示else里的帐号错误;我该怎样修改?rnDefault.aspxrn<%@ import namespace="System.Data"%>rn<%@ import namespace="System.Data.SqlClient"%>rnrnrn 无标题页rnrnrn rn rn rn rn rnrnrnrn rn存储过程为:rnCREATE PROCEDURE APPrn@roots varchar(8)rnasrnselect roots from table2 where roots='@roots'rnGO
Java流媒体 可以读取MediaServer发布点的信息吗?比如获取发布点的名称等。。。。。
如题
不起作用?
......高手请教! 如何让选框只读?
Windows2000共享上网,但是却发不了邮件
大家好,小弟有一个问题想请你们解决一下。rn  我们公司一开始是用Windwos98系统作代理服务器的。现在我改成Windows2000专业版来做服务器,但却发现一个问题,就是上网可以,收邮件也可以。但就是发不了邮件。我是用Internet连接共享来共享上网的。rn  请大家给一个问题的所在,让小弟可以解决这个一个问题。
was 5.0 可以发 email 吗?
要怎么做呢?
短信可以这样发吗??
发给对方的同时上传到WEB网站中保存下来。
相关热词 c#入门推荐书 c# 解码海康数据流 c# xml的遍历循环 c# 取 查看源码没有的 c#解决高并发 委托 c#日期转化为字符串 c# 显示问号 c# 字典对象池 c#5.0 安装程序 c# 分页算法