Modifier and Type | Method and Description |
---|---|
NevadoTopic |
NevadoSession.createTopic(String name) |
NevadoTopic |
NevadoQueueSession.createTopic(String s) |
Modifier and Type | Method and Description |
---|---|
void |
NevadoConnection.deleteTopic(NevadoTopic topic) |
String |
NevadoConnection.subscribe(NevadoTopic topic,
NevadoQueue topicEndpoint) |
void |
NevadoConnection.unsubscribe(NevadoTopic topic) |
Constructor and Description |
---|
NevadoMessageConsumer(NevadoSession session,
NevadoTopic topic,
String durableSubscriptionName,
String selector,
boolean noLocal) |
Modifier and Type | Method and Description |
---|---|
NevadoTopic |
SQSConnector.createTopic(String topicName) |
Modifier and Type | Method and Description |
---|---|
Collection<NevadoTopic> |
SQSConnector.listTopics() |
Modifier and Type | Method and Description |
---|---|
void |
SQSConnector.deleteTopic(NevadoTopic topic) |
protected abstract void |
AbstractSQSConnector.sendSNSMessage(NevadoTopic topic,
String serializedMessage) |
String |
SQSConnector.subscribe(NevadoTopic topic,
NevadoQueue topicEndpoint) |
void |
SQSConnector.unsubscribe(NevadoTopic topic) |
Modifier and Type | Method and Description |
---|---|
NevadoTopic |
AmazonAwsSQSConnector.createTopic(String topicName) |
Modifier and Type | Method and Description |
---|---|
Collection<NevadoTopic> |
AmazonAwsSQSConnector.listTopics() |
Modifier and Type | Method and Description |
---|---|
void |
AmazonAwsSQSConnector.deleteTopic(NevadoTopic topic) |
protected String |
AmazonAwsSQSConnector.getTopicARN(NevadoTopic topic) |
protected void |
AmazonAwsSQSConnector.sendSNSMessage(NevadoTopic topic,
String serializedMessage) |
String |
AmazonAwsSQSConnector.subscribe(NevadoTopic topic,
NevadoQueue topicEndpoint) |
void |
AmazonAwsSQSConnector.unsubscribe(NevadoTopic topic) |
Modifier and Type | Method and Description |
---|---|
NevadoTopic |
MockSQSConnector.createTopic(String topicName) |
Modifier and Type | Method and Description |
---|---|
Collection<NevadoTopic> |
MockSQSConnector.listTopics() |
Modifier and Type | Method and Description |
---|---|
void |
MockSQSConnector.deleteTopic(NevadoTopic topic) |
protected void |
MockSQSConnector.sendSNSMessage(NevadoTopic topic,
String body) |
String |
MockSQSConnector.subscribe(NevadoTopic topic,
NevadoQueue topicEndpoint) |
void |
MockSQSConnector.unsubscribe(NevadoTopic topic) |
Modifier and Type | Class and Description |
---|---|
class |
NevadoTemporaryTopic
Nevado implementation of a temporary topic
|
Modifier and Type | Method and Description |
---|---|
static NevadoTopic |
NevadoTopic.getInstance(javax.jms.Topic topic) |
Constructor and Description |
---|
NevadoTemporaryTopic(NevadoConnection connection,
NevadoTopic topic) |
NevadoTopic(NevadoTopic topic,
NevadoQueue topicEndpoint,
String subscriptionArn,
boolean durable) |
Copyright © 2014. All Rights Reserved.