public final class AmqMessagesUtil extends java.lang.Object
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 |
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) |
public static final java.lang.String JMS_MESSAGE_HEADER_PREFIX
public static final java.lang.String JMS_MESSAGE_CUSTOM_PREFIX
public static final java.lang.String JMS_MESSAGE_BODY_PREFIX
public static java.util.List getAllMessages(java.net.URI brokerUrl, javax.jms.Destination dest) throws java.lang.Exception
java.lang.Exception
public static java.util.List getMessages(java.net.URI brokerUrl, javax.jms.Destination dest, java.lang.String selector) throws java.lang.Exception
java.lang.Exception
public static java.util.List getMessages(javax.jms.ConnectionFactory connectionFactory, javax.jms.Destination dest, java.lang.String selector) throws java.lang.Exception
java.lang.Exception
public static java.util.List getMessages(java.net.URI brokerUrl, javax.jms.Destination dest, java.util.List selectors) throws java.lang.Exception
java.lang.Exception
public static java.util.List getMessages(javax.jms.ConnectionFactory connectionFactory, javax.jms.Destination dest, java.util.List selectors) throws java.lang.Exception
java.lang.Exception
public static java.util.List filterMessagesView(java.util.List messages, java.util.Set groupViews, java.util.Set attributeViews) throws java.lang.Exception
java.lang.Exception
public static QueryFilter createMessageQueryFilter(java.net.URI brokerUrl, javax.jms.Destination dest)
public static QueryFilter createMessageQueryFilter(javax.jms.ConnectionFactory connectionFactory, javax.jms.Destination dest)
Copyright © 2005-2017. All Rights Reserved.