org.skyscreamer.nevado.jms.connector

Interface SQSConnector

All Known Implementing Classes:

AbstractSQSConnector, AmazonAwsSQSConnector, MockSQSConnector, PlainTextAmazonSQSConnector

public interface SQSConnector

Interface for connecting to the underlying implementation of the messaging system

Author:

Carter Page

Method Summary

Methods

Modifier and Type	Method and Description
NevadoQueue	createQueue(String queueName)
NevadoTopic	createTopic(String topicName)
void	deleteMessage(NevadoMessage message)
void	deleteQueue(NevadoQueue queue)
void	deleteTopic(NevadoTopic topic)
Collection<NevadoQueue>	listQueues(String temporaryQueuePrefix)
Collection<NevadoTopic>	listTopics()
NevadoMessage	receiveMessage(NevadoConnection connection, NevadoDestination destination, long timeoutMs)
void	resetMessage(NevadoMessage message)
void	sendMessage(NevadoDestination destination, NevadoMessage outgoingMessage)
void	sendMessages(NevadoDestination destination, List<NevadoMessage> outgoingMessages)
String	subscribe(NevadoTopic topic, NevadoQueue topicEndpoint)
void	test()
void	unsubscribe(NevadoTopic topic)

Method Detail

sendMessage

void sendMessage(NevadoDestination destination,
               NevadoMessage outgoingMessage)
                 throws javax.jms.JMSException

Throws:

javax.jms.JMSException

sendMessages

void sendMessages(NevadoDestination destination,
                List<NevadoMessage> outgoingMessages)
                  throws javax.jms.JMSException

Throws:

javax.jms.JMSException

receiveMessage

NevadoMessage receiveMessage(NevadoConnection connection,
                           NevadoDestination destination,
                           long timeoutMs)
                             throws javax.jms.JMSException,
                                    InterruptedException

Throws:

javax.jms.JMSException

InterruptedException

deleteMessage

void deleteMessage(NevadoMessage message)
                   throws javax.jms.JMSException

Throws:

javax.jms.JMSException

resetMessage

void resetMessage(NevadoMessage message)
                  throws javax.jms.JMSException

Throws:

javax.jms.JMSException

test

void test()
          throws javax.jms.JMSException

Throws:

javax.jms.JMSException

createQueue

NevadoQueue createQueue(String queueName)
                        throws javax.jms.JMSException

Throws:

javax.jms.JMSException

listQueues

Collection<NevadoQueue> listQueues(String temporaryQueuePrefix)
                                   throws javax.jms.JMSException

Throws:

javax.jms.JMSException

deleteQueue

void deleteQueue(NevadoQueue queue)
                 throws javax.jms.JMSException

Throws:

javax.jms.JMSException

createTopic

NevadoTopic createTopic(String topicName)
                        throws javax.jms.JMSException

Throws:

javax.jms.JMSException

deleteTopic

void deleteTopic(NevadoTopic topic)
                 throws javax.jms.JMSException

Throws:

javax.jms.JMSException

listTopics

Collection<NevadoTopic> listTopics()
                                   throws javax.jms.JMSException

Throws:

javax.jms.JMSException

subscribe

String subscribe(NevadoTopic topic,
               NevadoQueue topicEndpoint)
                 throws javax.jms.JMSException

Throws:

javax.jms.JMSException

unsubscribe

void unsubscribe(NevadoTopic topic)
                 throws javax.jms.JMSException

Throws:

javax.jms.JMSException