org.apache.activemq.console.util

Class AmqMessagesUtil

java.lang.Object

org.apache.activemq.console.util.AmqMessagesUtil

public final class AmqMessagesUtil
extends java.lang.Object

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	JMS_MESSAGE_BODY_PREFIX
static java.lang.String	JMS_MESSAGE_CUSTOM_PREFIX
static java.lang.String	JMS_MESSAGE_HEADER_PREFIX

Method Summary

Methods

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

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 java.lang.String JMS_MESSAGE_HEADER_PREFIX

See Also:

Constant Field Values

JMS_MESSAGE_CUSTOM_PREFIX

public static final java.lang.String JMS_MESSAGE_CUSTOM_PREFIX

See Also:

Constant Field Values

JMS_MESSAGE_BODY_PREFIX

public static final java.lang.String JMS_MESSAGE_BODY_PREFIX

See Also:

Constant Field Values

Method Detail

getAllMessages

public static java.util.List getAllMessages(java.net.URI brokerUrl,
                            javax.jms.Destination dest)
                                     throws java.lang.Exception

Throws:

java.lang.Exception

getMessages

public static java.util.List getMessages(java.net.URI brokerUrl,
                         javax.jms.Destination dest,
                         java.lang.String selector)
                                  throws java.lang.Exception

Throws:

java.lang.Exception

getMessages

public static java.util.List getMessages(javax.jms.ConnectionFactory connectionFactory,
                         javax.jms.Destination dest,
                         java.lang.String selector)
                                  throws java.lang.Exception

Throws:

java.lang.Exception

getMessages

public static java.util.List getMessages(java.net.URI brokerUrl,
                         javax.jms.Destination dest,
                         java.util.List selectors)
                                  throws java.lang.Exception

Throws:

java.lang.Exception

getMessages

public static java.util.List getMessages(javax.jms.ConnectionFactory connectionFactory,
                         javax.jms.Destination dest,
                         java.util.List selectors)
                                  throws java.lang.Exception

Throws:

java.lang.Exception

filterMessagesView

public static java.util.List filterMessagesView(java.util.List messages,
                                java.util.Set groupViews,
                                java.util.Set attributeViews)
                                         throws java.lang.Exception

Throws:

java.lang.Exception

createMessageQueryFilter

public static QueryFilter createMessageQueryFilter(java.net.URI brokerUrl,
                                   javax.jms.Destination dest)

createMessageQueryFilter

public static QueryFilter createMessageQueryFilter(javax.jms.ConnectionFactory connectionFactory,
                                   javax.jms.Destination dest)