文档章节

JMS

慕容若冰
 慕容若冰
发布于 2016/12/09 15:35
字数 186
阅读 10
收藏 0
  1. 安装ActiveMQ,运行ActiveMQ
  2. 新建Spring Boot项目,添加spring-jms和activemq-client依赖
  3. 消息定义
    package com.jms;
    
    import org.springframework.jms.core.MessageCreator;
    
    import javax.jms.JMSException;
    import javax.jms.Message;
    import javax.jms.Session;
    
    /**
     * 消息定义
     * Created by Administrator on 2016/12/9.
     */
    public class Msg implements MessageCreator{
        @Override
        public Message createMessage(Session session) throws JMSException {
            return session.createTextMessage("测试消息");
        }
    }
  4. 消息发送及目的地定义
    package com.jms;
    
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.boot.CommandLineRunner;
    import org.springframework.boot.SpringApplication;
    import org.springframework.boot.autoconfigure.SpringBootApplication;
    import org.springframework.jms.core.JmsTemplate;
    
    /**
     * 消息发送及目的地定义
     */
    @SpringBootApplication
    public class JmsApplication implements CommandLineRunner{
    
       @Autowired
       JmsTemplate jmsTemplate;//注入Spring Boot配置好的JmsTemplate Bean
    
       public static void main(String[] args) {
          SpringApplication.run(JmsApplication.class, args);
       }
    
       @Override
       public void run(String... strings) throws Exception {
          jmsTemplate.send("my-destination", new Msg());//向my-destination目的地发送Msg消息
       }
    }
  5. 消息监听
    package com.jms;
    
    import org.springframework.jms.annotation.JmsListener;
    import org.springframework.stereotype.Component;
    
    /**
     * 消息监听
     * Created by Administrator on 2016/12/9.
     */
    @Component
    public class Receiver {
    
        @JmsListener(destination = "my-destination")
        public void receiveMessage(String message) {
            System.out.print("接收到:<" + message + ">");
        }
    }
  6. 运行

© 著作权归作者所有

共有 人打赏支持
慕容若冰
粉丝 0
博文 44
码字总数 9774
作品 0
广州
程序员

暂无文章

spring 容器实现对bean的管理(注解方式解析,源码阅读)

因为最近在研究学习spring boot,所以这里想详细学习回顾了一下spring 容器对bean的一些管理方式和部分源码学习。 首先初始类AnnotationConfigApplicationContext,简单源码查看,支持两个参...

小海bug
20分钟前
0
0
数据结构:二分查找 java

二分查找的前提是有序存储,利用顺序存储和元素排序 /** * 二分查找,查找成功,返回下标记 * @param values * @param begin * @param end * @param key * @param <T> * @ret...

京一
37分钟前
0
0
@SpringBootApplication 注解

@SpringBootApplication注解是一个组合注解,包含以下注解 @Target(ElementType.TYPE) 注解的作用目标 @Retention(RetentionPolicy.RUNTIME) Reteniton的作用是定义被它所注解的注解保留多久,...

java.刘
50分钟前
0
0
sentinel自定义DataSource实战

序 本文主要研究一下如何自定义sentinel的DataSource,这里以jdbc为例。 maven <dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-sen......

go4it
今天
1
0
xgboost/gbdt在调参时为什么树的深度很少就能达到很高的精度?

问题: 用xgboost/gbdt在在调参的时候把树的最大深度调成6就有很高的精度了。但是用DecisionTree/RandomForest的时候需要把树的深度调到15或更高。用RandomForest所需要的树的深度和Decisio...

tantexian
今天
0
0

没有更多内容

加载失败,请刷新页面

加载更多

下一页

返回顶部
顶部