Package org.ikasan.spec.bigqueue.service

Interface BigQueueDirectoryManagementService

public interface BigQueueDirectoryManagementService

Method Summary

Modifier and Type	Method	Description
void	deleteAllMessage(String queueName)
void	deleteMessage(String queueName, String biQueueMessageId)
void	deleteQueue(String queueName)
List<BigQueueMessage>	getMessages(String queueName)
String	getQueueDirectory()
List<String>	listQueues()
BigQueueMessage	peek(String queueName)
Map<String,Long>	size(boolean includeZero)
long	size(String queueName)

Method Details

size

long size(String queueName)
   throws IOException

Throws:

IOException

peek

BigQueueMessage peek(String queueName)
              throws IOException

Throws:

IOException

getMessages

List<BigQueueMessage> getMessages(String queueName)
                           throws IOException

Throws:

IOException

deleteAllMessage

void deleteAllMessage(String queueName)
               throws IOException

Throws:

IOException

deleteMessage

void deleteMessage(String queueName,
 String biQueueMessageId)
            throws IOException

Throws:

IOException

listQueues

List<String> listQueues()
                 throws IOException

Throws:

IOException

deleteQueue

void deleteQueue(String queueName)
          throws IOException

Throws:

IOException

getQueueDirectory

String getQueueDirectory()

size

Map<String,Long> size(boolean includeZero)
               throws IOException

Throws:

IOException