String text = "message! From: " + Thread.currentThread().getName() + " : " + System.currentTimeMillis(); 
TextMessage message = session.createTextMessage(text); 
// 设置消息属性 
message.setStringProperty("subtype", “aaa"); 
// 7、通过producer 发送消息 
producer.send(message);

@JmsListener(destination = "queue1", selector = "subtype='bbb'")public void receive(String text, @Header("subtype") String subtype) {     System.out.println(Thread.currentThread().getName() + " Received <" + text + ">     subtype=" + subtype); 
}

@Transactional // 在开启事务的情况下需要加事务注解public void sendMessage(String subtype) { // 发送延时消息 jmsTemplate.convertAndSend("queue1", "message with property", message -> { // 设置消息属性 message.setStringProperty("subtype", subtype); return message; 
});System.out.println("Sending an message with subtype=" + subtype); }

默认的MessageConverter只能转换基本类型（如String、Map、Serializable），而我们的电子邮件不是故意序列化的。我们想用Jackson和将内容序列化为文本格式的json（即作为文本消息）。Spring Boot将检测到存在MessageConverter，并将其与默认JmsTemplate和任何由DefaultJmsListenerContainerFactoryConfigurer创建的JmsListenerContainerFactory。

@Bean // Serialize message content to json using TextMessage 
public MessageConverter jacksonJmsMessageConverter() { MappingJackson2MessageConverter converter = new MappingJackson2MessageConverter();    converter.setTargetType(MessageType.TEXT); converter.setTypeIdPropertyName("_type"); return converter; 
}

@JmsListener

带注释的JMS侦听器方法允许具有类似于MessageMapping提供：

获取对jms会话的访问权javax.jms.Message或其子类之一，以访问原始jms消息

org.springframework.messaging.Message使用Spring的消息传递抽象对应方

• @有效负载-带注释的方法参数，包括对验证的支持
• @Header-带注释的方法参数，用于提取特定的头值，包括标准头值

由org.springframework.JMS.support.JmsHeaders@headers定义的JMS头-带注释的方法参数，该参数还必须可分配给获取对所有标头的访问权org.springframework.messaging.MessageHeaders用于获取对所有标题org.springframework.messaging.support.MessageHeaderAccessororg.springframework.jms.support.JmsMessageHeaderAccessor，方便访问所有方法参数带注释的方法可能具有非void返回类型。当他们这样做时，方法的结果调用作为JMS应答发送到由传入消息。如果未设置此标头，则可以通过添加@发送到方法声明。

DefaultJmsListenerContainerFactory 的配置

注释，该注释将方法标记为指定对象上JMS消息侦听器的目标目的地containerFactory标识用于构建jms的org.springframework.jms.config.JmsListenerContainerFactory侦听器容器。如果未设置，则假定默认容器工厂可用于beanjmsListenerContainerFactory的名称，除非通过提供了显式默认值

配置考虑设置习惯org.springframework.jms.config.defaultjmsListenerContainerFactorybean。用于生产为此，您通常会微调超时和恢复设置。最重要的是，违约“自动确认”模式不提供可靠性保证，因此请确保使用在可靠性需要的情况下处理会话。

@Configuration 
static class JmsConfiguration { @Beanpublic DefaultJmsListenerContainerFactory myFactory(ConnectionFactory connectionFactory, DefaultJmsListenerContainerFactoryConfigurer configurer) { DefaultJmsListenerContainerFactory factory = new DefaultJmsListenerContainerFactory(); //This provides all boot's default to this factory, including the 
// message converter configurer.configure(factory, connectionFactory);// You could still override some of Boot's default if necessary.// factory.setSessionAcknowledgeMode(Session.CLIENT_ACKNOWLEDGE); 
// factory.setSessionTransacted(true); return factory; 
} 
}

@Componentpublic class Receiver { @JmsListener(destination = "mailbox", containerFactory = "myFactory") public void receiveMessage(Email email) { System.out.println("Received <" + email + ">"); } 
}

此注释可用作元注释，以创建具有属性覆盖。

CachingConnectionFactory

CachingConnectionFactory extends SingleConnectionFactory

 缓存的连接工厂，创建的工厂。添加的配置

JmsPoolConnectionFactory

<dependency> <groupId>org.messaginghub</groupId> <artifactId>pooled-jms</artifactId> 
</dependency>

spring.activemq.pool.enabled=true
spring.activemq.pool.max-connections=50