io.cloudboost

Class CloudQueue

java.lang.Object

io.cloudboost.CloudQueue

public class CloudQueue
extends Object

Field Summary

Fields

Modifier and Type	Field and Description
ACL	acl
protected long	delay
protected JSONObject	document
protected ArrayList<QueueMessage>	messages
protected String	name
static String	QUEUE_TYPE
protected String	queueType
protected ArrayList<String>	subscribers
protected long	timeout

Constructor Summary

Constructors

Constructor and Description
CloudQueue(String queueName, String queueType)

Method Summary

Modifier and Type	Method and Description
void	addChangedColumn(String columnName)
void	addMessage(Object message, CloudQueueMessageCallback callback)
void	addSubscriber(Object subscriber, CloudQueueCallback callback)
void	clear(CloudQueueCallback callback)
void	create(CloudQueueCallback callback)
void	delete(CloudQueueCallback callback)
void	deleteMessage(QueueMessage message, CloudQueueMessageCallback callback)
void	deleteMessage(String id, CloudQueueMessageCallback callback)
void	deleteQueue(CloudQueueCallback callback)
void	deleteQueue(String queueName, CloudQueueCallback callback)
void	deleteSubscriber(Object subscriber, CloudQueueCallback callback)
void	get(CloudQueueCallback callback)
void	get(String queueName, CloudQueueCallback callback)
ACL	getAcl()
static void	getAll(CloudQueueArrayCallback callback)
void	getAllMessages(CloudQueueArrayCallback callback)
Object	getAttribute(String key)
long	getDelay()
JSONObject	getDocument()
void	getMessage(int count, CloudQueueMessageCallback callback)
void	getMessageById(String id, CloudQueueMessageCallback callback)
ArrayList<QueueMessage>	getMessages()
String	getName()
static String	getQueueType()
ArrayList<String>	getSubscribers()
CloudQueue	getThisObj()
long	getTimeout()
static void	main(String[] args)
void	peek(int count, CloudQueueMessageCallback callback)
void	peekMessage(int count, CloudQueueMessageCallback callback)
void	pull(int count, CloudQueueMessageCallback callback)
void	push(Object message, CloudQueueMessageCallback callback)
void	refreshMessageTimeout(QueueMessage msg, CloudQueueMessageCallback callback)
void	refreshMessageTimeout(QueueMessage msg, int timeout, CloudQueueMessageCallback callback)
void	removeSubscriber(Object subscriber, CloudQueueCallback callback)
void	setAcl(ACL acl)
void	setAttribute(String propertyName, Object value)
void	setDelay(long delay)
void	setDocument(JSONObject document)
void	setMessages(ArrayList<QueueMessage> messages)
void	setName(String name)
void	setQueueType(String queueType)
void	setSubscribers(ArrayList<String> subscribers)
void	setThisObj(CloudQueue thisObj)
void	setTimeout(long timeout)
void	update(CloudQueueCallback callback)
void	updateMessage(QueueMessage[] message, CloudQueueMessageCallback callback)
boolean	validate()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

acl

public ACL acl

document

protected JSONObject document

subscribers

protected ArrayList<String> subscribers

queueType

protected String queueType

timeout

protected long timeout

delay

protected long delay

messages

protected ArrayList<QueueMessage> messages

QUEUE_TYPE

public static final String QUEUE_TYPE

See Also:

Constant Field Values

name

protected String name

Constructor Detail

CloudQueue

public CloudQueue(String queueName,
                  String queueType)

Method Detail

getDocument

public JSONObject getDocument()

setDocument

public void setDocument(JSONObject document)

getSubscribers

public ArrayList<String> getSubscribers()

setSubscribers

public void setSubscribers(ArrayList<String> subscribers)

getAcl

public ACL getAcl()

setAcl

public void setAcl(ACL acl)

getThisObj

public CloudQueue getThisObj()

setThisObj

public void setThisObj(CloudQueue thisObj)

setQueueType

public void setQueueType(String queueType)

getTimeout

public long getTimeout()

setTimeout

public void setTimeout(long timeout)

getDelay

public long getDelay()

setDelay

public void setDelay(long delay)

getMessages

public ArrayList<QueueMessage> getMessages()

setMessages

public void setMessages(ArrayList<QueueMessage> messages)

getName

public String getName()

setName

public void setName(String name)

getQueueType

public static String getQueueType()

getAttribute

public Object getAttribute(String key)

refreshMessageTimeout

public void refreshMessageTimeout(QueueMessage msg,
                                  CloudQueueMessageCallback callback)

refreshMessageTimeout

public void refreshMessageTimeout(QueueMessage msg,
                                  int timeout,
                                  CloudQueueMessageCallback callback)

addChangedColumn

public void addChangedColumn(String columnName)

setAttribute

public void setAttribute(String propertyName,
                         Object value)

validate

public boolean validate()

peekMessage

public void peekMessage(int count,
                        CloudQueueMessageCallback callback)

peek

public void peek(int count,
                 CloudQueueMessageCallback callback)

getMessage

public void getMessage(int count,
                       CloudQueueMessageCallback callback)

deleteMessage

public void deleteMessage(String id,
                          CloudQueueMessageCallback callback)

deleteMessage

public void deleteMessage(QueueMessage message,
                          CloudQueueMessageCallback callback)

getMessageById

public void getMessageById(String id,
                           CloudQueueMessageCallback callback)

deleteSubscriber

public void deleteSubscriber(Object subscriber,
                             CloudQueueCallback callback)

addSubscriber

public void addSubscriber(Object subscriber,
                          CloudQueueCallback callback)

removeSubscriber

public void removeSubscriber(Object subscriber,
                             CloudQueueCallback callback)

addMessage

public void addMessage(Object message,
                       CloudQueueMessageCallback callback)

push

public void push(Object message,
                 CloudQueueMessageCallback callback)

deleteQueue

public void deleteQueue(CloudQueueCallback callback)

pull

public void pull(int count,
                 CloudQueueMessageCallback callback)

clear

public void clear(CloudQueueCallback callback)

get

public void get(String queueName,
                CloudQueueCallback callback)

deleteQueue

public void deleteQueue(String queueName,
                        CloudQueueCallback callback)

update

public void update(CloudQueueCallback callback)

get

public void get(CloudQueueCallback callback)

getAllMessages

public void getAllMessages(CloudQueueArrayCallback callback)

delete

public void delete(CloudQueueCallback callback)

create

public void create(CloudQueueCallback callback)

getAll

public static void getAll(CloudQueueArrayCallback callback)

updateMessage

public void updateMessage(QueueMessage[] message,
                          CloudQueueMessageCallback callback)

main

public static void main(String[] args)