|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectcom.shephertz.app42.paas.sdk.jme.message.QueueService
public class QueueService
Manages Asynchronous queues. Allows to create, delete, purge messages, view pending messages and get all messages
Queue
Constructor Summary | |
---|---|
QueueService(java.lang.String apiKey,
java.lang.String secretKey,
java.lang.String baseURL)
this is a constructor that takes |
Method Summary | |
---|---|
Queue |
createPullQueue(java.lang.String queueName,
java.lang.String queueDescription)
Creates a type Pull Queue |
App42Response |
deletePullQueue(java.lang.String queueName)
Deletes the Pull type Queue |
Queue |
getMessages(java.lang.String queueName,
long receiveTimeOut)
Messages are retrieved and dequeued from the Queue. |
Queue |
pendingMessages(java.lang.String queueName)
Messages which are pending to be dequeue. |
App42Response |
purgePullQueue(java.lang.String queueName)
Purges message on the Queue. |
Queue |
receiveMessage(java.lang.String queueName,
long receiveTimeOut)
Pulls all the message from the queue |
Queue |
receiveMessageByCorrelationId(java.lang.String queueName,
long receiveTimeOut,
java.lang.String correlationId)
Pull message based on the correlation id |
App42Response |
removeMessage(java.lang.String queueName,
java.lang.String messageId)
Remove message from the queue based on the message id. |
Queue |
sendMessage(java.lang.String queueName,
java.lang.String msg,
long exp)
Send message on the queue with an expiry. |
Methods inherited from class java.lang.Object |
---|
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
---|
public QueueService(java.lang.String apiKey, java.lang.String secretKey, java.lang.String baseURL)
apiKey
- secretKey
- baseURL
- Method Detail |
---|
public Queue createPullQueue(java.lang.String queueName, java.lang.String queueDescription) throws App42Exception
queueName
- - The name of the queue which has to be createdqueueDescription
- - The description of the queue
App42Exception
public App42Response deletePullQueue(java.lang.String queueName) throws App42Exception
queueName
- - The name of the queue which has to be deleted
App42Exception
public Queue getMessages(java.lang.String queueName, long receiveTimeOut) throws App42Exception
queueName
- - The name of the queue which have to be retrievedreceiveTimeOut
- - Receive time out
App42Exception
public Queue pendingMessages(java.lang.String queueName) throws App42Exception
queueName
- - The name of the queue from which pending messages have to be
fetched
App42Exception
public App42Response purgePullQueue(java.lang.String queueName) throws App42Exception
queueName
- - The name of the queue which has to be purged
App42Exception
public Queue receiveMessage(java.lang.String queueName, long receiveTimeOut) throws App42Exception
queueName
- - The name of the queue from which messages have to be pulledreceiveTimeOut
- - Receive time out
App42Exception
public Queue receiveMessageByCorrelationId(java.lang.String queueName, long receiveTimeOut, java.lang.String correlationId) throws App42Exception
queueName
- - The name of the queue from which the message has to be
pulledreceiveTimeOut
- - Receive time outcorrelationId
- - Correlation Id for which message has to be pulled
App42Exception
public App42Response removeMessage(java.lang.String queueName, java.lang.String messageId) throws App42Exception
queueName
- - The name of the queue from which the message has to be
removedmessageId
- - The message id of the message which has to be removed.
App42Exception
public Queue sendMessage(java.lang.String queueName, java.lang.String msg, long exp) throws App42Exception
queueName
- - The name of the queue to which the message has to be sentmsg
- - Message that has to be sentexp
- - Message expiry time
App42Exception
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |