org.apache.activemq.console.util
Class AmqMessagesUtil

java.lang.Object
  extended by org.apache.activemq.console.util.AmqMessagesUtil

public final class AmqMessagesUtil
extends Object


Field Summary
static String JMS_MESSAGE_BODY_PREFIX
           
static String JMS_MESSAGE_CUSTOM_PREFIX
           
static String JMS_MESSAGE_HEADER_PREFIX
           
 
Method Summary
static QueryFilter createMessageQueryFilter(ConnectionFactory connectionFactory, Destination dest)
           
static QueryFilter createMessageQueryFilter(URI brokerUrl, Destination dest)
           
static List filterMessagesView(List messages, Set groupViews, Set attributeViews)
           
static List getAllMessages(URI brokerUrl, Destination dest)
           
static List getMessages(ConnectionFactory connectionFactory, Destination dest, List selectors)
           
static List getMessages(ConnectionFactory connectionFactory, Destination dest, String selector)
           
static List getMessages(URI brokerUrl, Destination dest, List selectors)
           
static List getMessages(URI brokerUrl, Destination dest, 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 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)


Copyright © 2005-2013 The Apache Software Foundation. All Rights Reserved.