ActiveMQ支持哪些消息类型?

ActiveMQ 支持多种消息类型,主要包括:

  1. TextMessage:文本消息,包含一个字符串内容。
TextMessage msg = session.createTextMessage("Hello");
producer.send(msg);
  1. MapMessage: MAP 消息,包含一组字符串-对象映射关系。
MapMessage msg = session.createMapMessage();
msg.setString("name", "Tom");
msg.setInt("age", 30);
producer.send(msg);
  1. BytesMessage:字节消息,包含一个字节内容。
BytesMessage msg = session.createBytesMessage();
msg.writeBytes("Hello".getBytes()); 
producer.send(msg);  
  1. StreamMessage:流消息,用于传输一连串消息。
StreamMessage msg = session.createStreamMessage();
msg.writeString("Hello");
msg.writeString("World");
producer.send(msg);
  1. ObjectMessage:对象消息,用于传输一个序列化的 Java 对象。
User user = new User("Tom", 30);
ObjectMessage msg = session.createObjectMessage(user);  
producer.send(msg);
  1. Message:基础消息接口,其他消息类型的父接口。
Message msg = session.createTextMessage("Hello");