public final class AmqMessagesUtil extends Object
Modifier and Type | Field and Description |
---|---|
static String |
JMS_MESSAGE_BODY_PREFIX |
static String |
JMS_MESSAGE_CUSTOM_PREFIX |
static String |
JMS_MESSAGE_HEADER_PREFIX |
Modifier and Type | Method and Description |
---|---|
static QueryFilter |
createMessageQueryFilter(javax.jms.ConnectionFactory connectionFactory,
javax.jms.Destination dest) |
static QueryFilter |
createMessageQueryFilter(URI brokerUrl,
javax.jms.Destination dest) |
static List |
filterMessagesView(List messages,
Set groupViews,
Set attributeViews) |
static List |
getAllMessages(URI brokerUrl,
javax.jms.Destination dest) |
static List |
getMessages(javax.jms.ConnectionFactory connectionFactory,
javax.jms.Destination dest,
List selectors) |
static List |
getMessages(javax.jms.ConnectionFactory connectionFactory,
javax.jms.Destination dest,
String selector) |
static List |
getMessages(URI brokerUrl,
javax.jms.Destination dest,
List selectors) |
static List |
getMessages(URI brokerUrl,
javax.jms.Destination dest,
String selector) |
public static final String JMS_MESSAGE_HEADER_PREFIX
public static final String JMS_MESSAGE_CUSTOM_PREFIX
public static final String JMS_MESSAGE_BODY_PREFIX
public static List getAllMessages(URI brokerUrl, javax.jms.Destination dest) throws Exception
Exception
public static List getMessages(URI brokerUrl, javax.jms.Destination dest, String selector) throws Exception
Exception
public static List getMessages(javax.jms.ConnectionFactory connectionFactory, javax.jms.Destination dest, String selector) throws Exception
Exception
public static List getMessages(URI brokerUrl, javax.jms.Destination dest, List selectors) throws Exception
Exception
public static List getMessages(javax.jms.ConnectionFactory connectionFactory, javax.jms.Destination dest, List selectors) throws Exception
Exception
public static List filterMessagesView(List messages, Set groupViews, Set attributeViews) throws Exception
Exception
public static QueryFilter createMessageQueryFilter(URI brokerUrl, javax.jms.Destination dest)
public static QueryFilter createMessageQueryFilter(javax.jms.ConnectionFactory connectionFactory, javax.jms.Destination dest)
Copyright © 2005–2018 FuseSource, Corp.. All rights reserved.