public class QueueBrowserClient extends Object
Constructor and Description |
---|
QueueBrowserClient(String nameOfQueue,
String userName,
String accessKey)
Constructor - create a new browser instance for the given queue as given user.
|
Modifier and Type | Method and Description |
---|---|
Enumeration |
browseQueue()
Return a lazy-loading iterator (java.util.Enumeration) of the messages of the given queue.
|
void |
closeBrowser()
Close browser instance on this queue of this user.
|
String |
getMsgContentType(javax.jms.Message queueMessage)
Determines the type of the JMS message
|
String |
getMsgProperties(javax.jms.Message queueMessage)
Get message details of the input javax.jms.Message object.
|
public static final String QPID_ICF
public QueueBrowserClient(String nameOfQueue, String userName, String accessKey) throws FileNotFoundException, XMLStreamException, org.wso2.andes.kernel.AndesException
nameOfQueue
- name of queueuserName
- User's username as per user storeaccessKey
- as generated by andes authentication service for the user.FileNotFoundException
XMLStreamException
org.wso2.andes.kernel.AndesException
public Enumeration browseQueue()
public void closeBrowser() throws javax.jms.JMSException
javax.jms.JMSException
public String getMsgProperties(javax.jms.Message queueMessage) throws javax.jms.JMSException
queueMessage
- javax.jms.Message (ideally fetched through the Queue Browser Enumeration)javax.jms.JMSException
public String getMsgContentType(javax.jms.Message queueMessage)
queueMessage
- - input messageCopyright © 2023 WSO2. All rights reserved.