Package org.apache.activemq.console.util

Class AmqMessagesUtil

java.lang.Object

org.apache.activemq.console.util.AmqMessagesUtil

public final class AmqMessagesUtil
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
static String	JMS_MESSAGE_BODY_PREFIX
static String	JMS_MESSAGE_CUSTOM_PREFIX
static String	JMS_MESSAGE_HEADER_PREFIX

Method Summary

Modifier and Type	Method	Description
static QueryFilter	createMessageQueryFilter(URI brokerUrl, Destination dest)
static QueryFilter	createMessageQueryFilter(ConnectionFactory connectionFactory, Destination dest)
static List	filterMessagesView(List messages, Set groupViews, Set attributeViews)
static List	getAllMessages(URI brokerUrl, Destination dest)
static List	getMessages(URI brokerUrl, Destination dest, String selector)
static List	getMessages(URI brokerUrl, Destination dest, List selectors)
static List	getMessages(ConnectionFactory connectionFactory, Destination dest, String selector)
static List	getMessages(ConnectionFactory connectionFactory, Destination dest, List selectors)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

JMS_MESSAGE_HEADER_PREFIX

public static final String JMS_MESSAGE_HEADER_PREFIX

See Also:

Constant Field Values

JMS_MESSAGE_CUSTOM_PREFIX

public static final String JMS_MESSAGE_CUSTOM_PREFIX

See Also:

Constant Field Values

JMS_MESSAGE_BODY_PREFIX

public static final String JMS_MESSAGE_BODY_PREFIX

See Also:

Constant Field Values

Method Detail

getAllMessages

public static List getAllMessages(URI brokerUrl,
                                  Destination dest)
                           throws Exception

Throws:

Exception

getMessages

public static List getMessages(URI brokerUrl,
                               Destination dest,
                               String selector)
                        throws Exception

Throws:

Exception

getMessages

public static List getMessages(ConnectionFactory connectionFactory,
                               Destination dest,
                               String selector)
                        throws Exception

Throws:

Exception

getMessages

public static List getMessages(URI brokerUrl,
                               Destination dest,
                               List selectors)
                        throws Exception

Throws:

Exception

getMessages

public static List getMessages(ConnectionFactory connectionFactory,
                               Destination dest,
                               List selectors)
                        throws Exception

Throws:

Exception

filterMessagesView

public static List filterMessagesView(List messages,
                                      Set groupViews,
                                      Set attributeViews)
                               throws Exception

Throws:

Exception

createMessageQueryFilter

public static QueryFilter createMessageQueryFilter(URI brokerUrl,
                                                   Destination dest)

createMessageQueryFilter

public static QueryFilter createMessageQueryFilter(ConnectionFactory connectionFactory,
                                                   Destination dest)