Package org.ikasan.spec.bigqueue.service

Interface BigQueueManagementService

public interface BigQueueManagementService

Method Summary

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

Method Details

size

long size(String queueName)

peek

BigQueueMessage peek(String queueName)
              throws IOException

Throws:

IOException

getMessages

List<BigQueueMessage> getMessages(String queueName)
                           throws IOException

Throws:

IOException

deleteMessage

void deleteMessage(String queueName,
 String biQueueMessageId)
            throws IOException

Throws:

IOException

deleteAllMessage

void deleteAllMessage(String queueName)
               throws IOException

Throws:

IOException

listQueues

List<String> listQueues(String queueDir)
                 throws IOException

Throws:

IOException

deleteQueue

void deleteQueue(String queueDir,
 String queueName)
          throws IOException

Throws:

IOException