| Modifier and Type | Method and Description |
|---|---|
protected NevadoQueue |
NevadoSession.createInternalQueue(String name) |
NevadoQueue |
NevadoTopicSession.createQueue(String s) |
NevadoQueue |
NevadoSession.createQueue(String name) |
| Modifier and Type | Method and Description |
|---|---|
protected void |
NevadoConnection.deleteQueue(NevadoQueue queue) |
String |
NevadoConnection.subscribe(NevadoTopic topic,
NevadoQueue topicEndpoint) |
| Modifier and Type | Method and Description |
|---|---|
NevadoQueue |
SQSConnector.createQueue(String queueName) |
NevadoQueue |
AbstractSQSConnector.createQueue(String queueName)
Create a queue
|
| Modifier and Type | Method and Description |
|---|---|
Collection<NevadoQueue> |
SQSConnector.listQueues(String temporaryQueuePrefix) |
| Modifier and Type | Method and Description |
|---|---|
void |
SQSConnector.deleteQueue(NevadoQueue queue) |
void |
AbstractSQSConnector.deleteQueue(NevadoQueue queue) |
protected abstract SQSQueue |
AbstractSQSConnector.getSQSQueueImpl(NevadoQueue queue) |
protected String |
AbstractSQSConnector.sendSQSMessage(NevadoQueue queue,
String serializedMessage) |
String |
SQSConnector.subscribe(NevadoTopic topic,
NevadoQueue topicEndpoint) |
| Modifier and Type | Method and Description |
|---|---|
Collection<NevadoQueue> |
AmazonAwsSQSConnector.listQueues(String temporaryQueuePrefix) |
| Modifier and Type | Method and Description |
|---|---|
protected AmazonAwsSQSQueue |
AmazonAwsSQSConnector.getSQSQueueImpl(NevadoQueue queue) |
String |
AmazonAwsSQSConnector.subscribe(NevadoTopic topic,
NevadoQueue topicEndpoint) |
| Modifier and Type | Method and Description |
|---|---|
NevadoQueue |
MockSQSQueue.getQueue() |
| Modifier and Type | Method and Description |
|---|---|
Collection<NevadoQueue> |
MockSQSConnector.listQueues(String temporaryQueuePrefix) |
| Modifier and Type | Method and Description |
|---|---|
protected MockSQSQueue |
MockSQSConnector.getSQSQueueImpl(NevadoQueue queue) |
protected void |
MockSQSConnector.removeQueue(NevadoQueue queue) |
String |
MockSQSConnector.subscribe(NevadoTopic topic,
NevadoQueue topicEndpoint) |
| Constructor and Description |
|---|
MockSQSQueue(MockSQSConnector connector,
NevadoQueue queue) |
| Modifier and Type | Class and Description |
|---|---|
class |
NevadoTemporaryQueue
Nevado implementation of a temporary queue
|
| Modifier and Type | Method and Description |
|---|---|
NevadoQueue |
NevadoTopic.getTopicEndpoint() |
| Constructor and Description |
|---|
NevadoTemporaryQueue(NevadoConnection connection,
NevadoQueue queue) |
NevadoTopic(NevadoTopic topic,
NevadoQueue topicEndpoint,
String subscriptionArn,
boolean durable) |
Copyright © 2014. All Rights Reserved.