我正在使用JMX通过QueueControl类及其Browse方法连接到Artemis队列,该方法返回一个CompositeData数组,但我无法使用GET方法获得各个标头,因为没有任何标头.请告诉我如何通过Artemis上的JMX获取某些字段,而不是整个头部
我还try 了listMessage方法,但它提供了一个不完整的标头列表,并且不显示消息正文
我正在使用JMX通过QueueControl类及其Browse方法连接到Artemis队列,该方法返回一个CompositeData数组,但我无法使用GET方法获得各个标头,因为没有任何标头.请告诉我如何通过Artemis上的JMX获取某些字段,而不是整个头部
我还try 了listMessage方法,但它提供了一个不完整的标头列表,并且不显示消息正文
从CompositeData
中获取消息详细信息的关键是CompositeDataConstants
类.
如果我发送这样一条消息:
ConnectionFactory connectionFactory = new ActiveMQConnectionFactory("tcp://localhost:61616");
Connection connection = connectionFactory.createConnection();
Session session = connection.createSession();
MessageProducer messageProducer = session.createProducer(session.createQueue("myQueue"));
TextMessage message = session.createTextMessage();
message.setJMSReplyTo(session.createQueue("myReplyTo"));
message.setText("myText");
message.setStringProperty("myKey1", "myValue1");
message.setStringProperty("myKey2", "myValue2");
messageProducer.send(message);
connection.close();
您可以浏览队列并反序列化消息数据,例如:
QueueControl queueControl = ...
CompositeData[] messages = queueControl.browse();
for (CompositeData message : messages) {
System.out.println("JMSMessageID: " + message.get(CompositeDataConstants.USER_ID));
System.out.println("Destination: " + message.get(CompositeDataConstants.ADDRESS));
System.out.println("Text: " + message.get(CompositeDataConstants.TEXT_BODY));
System.out.println("DeliveryMode: " + ((Boolean) message.get(CompositeDataConstants.DURABLE) ? "persistent" : "non-persistent"));
TabularData stringProps = (TabularData) message.get(CompositeDataConstants.STRING_PROPERTIES);
for (CompositeData o : (Collection<CompositeData>) stringProps.values()) {
System.out.println(o.get("key") + ": " + o.get("value"));
}
}
它会打印出这样的内容:
JMSMessageID: ID:41171b0e-dfae-11ed-9217-3ce1a1d12939
Destination: myQueue
Text: myText
DeliveryMode: persistent
JMSReplyTo: queue://myReplyTo
myKey1: myValue1
myKey2: myValue2
__AMQ_CID: 41123909-dfae-11ed-9217-3ce1a1d12939
如果您不想直接使用常量,您可以找到它们各自的值here.
请记住,由于management-message-attribute-size-limit
,返回的数据可能会被截断.The documentation解释此设置:
management-message-attribute-size-limit
是从邮件中收集的用于浏览的字节数.这与队列控件上公开的browse
和list
管理方法相关.长于该值的消息属性显示为截断.默认为256
.使用-1
关闭此限制.请注意,需要为在给定时刻可见的所有消息分配内存.由于浏览许多邮件可能需要大量内存,因此将此值设置得太高可能会影响浏览器的 solidity .