首页org.springframework.amqp.core.Message

org.springframework.amqp.core.Message

时间: 2023-10-04 11:08:08 浏览: 80

AMQP消息解决方案SpringAMQP.zip

Spring AMQP 是基于 Spring 框架的 AMQP 消息解决方案，提供模板化的发送和接收消息的抽象层，提供基于消息驱动的 POJO。同时有 Java 和 .NET 的版本。示例代码：public static void main(final String... args) throws Exception { ConnectionFactory cf = new CachingConnectionFactory(); // set up the queue, exchange, binding on the broker RabbitAdmin admin = new RabbitAdmin(cf); Queue queue = new Queue("myQueue"); admin.declareQueue(queue); TopicExchange exchange = new TopicExchange("myExchange"); admin.declareExchange(exchange); admin.declareBinding( BindingBuilder.bind(queue).to(exchange).with("foo.*")); // set up the listener and container SimpleMessageListenerContainer container = new SimpleMessageListenerContainer(cf); Object listener = new Object() { public void handleMessage(String foo) { System.out.println(foo); } }; MessageListenerAdapter adapter = new MessageListenerAdapter(listener); container.setMessageListener(adapter); container.setQueueNames("myQueue"); container.start(); // send something RabbitTemplate template = new RabbitTemplate(cf); template.convertAndSend("myExchange", "foo.bar", "Hello, world!"); Thread.sleep(1000); container.stop(); } 标签：Spring

The org.springframework.amqp.core.Message is a class in the Spring AMQP framework that represents a message to be sent or received from a message broker. It contains the payload (message content) as a byte array, along with message headers and optional properties such as message ID, content type, and delivery mode. The Message class provides various constructors and methods for creating and manipulating messages. For example, it has constructors that take a payload and message properties as arguments, as well as methods for getting and setting message headers and properties. In addition to the Message class, the Spring AMQP framework provides several other classes and interfaces for working with messages, including the MessageProperties class for representing message properties, the MessageConverter interface for converting messages between different formats, and the MessageListener interface for receiving messages from a message broker.

阅读全文