本文整理汇总了Java中com.amazonaws.services.sns.model.Topic类的典型用法代码示例。如果您正苦于以下问题：Java Topic类的具体用法？Java Topic怎么用？Java Topic使用的例子？那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。
Topic类属于com.amazonaws.services.sns.model包，在下文中一共展示了Topic类的20个代码示例，这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞，您的评价将有助于我们的系统推荐出更棒的Java代码示例。
示例1: getOrCreateNotification
import com.amazonaws.services.sns.model.Topic; //导入依赖的package包/类
/**
*
* @param email
* @return
*/
public String getOrCreateNotification(String email) {
String ret = null;
String topicName = getTopicName(email);
String nextToken = null;
do {
ListTopicsResult listTopics = asyncSnsClient.listTopics(nextToken);
List<Topic> topics = listTopics.getTopics();
for (Topic s : topics) {
if (s.getTopicArn().endsWith(topicName)) {
ret = s.getTopicArn();
break;
}
}
nextToken = listTopics.getNextToken();
} while (ret == null && nextToken != null);
if (ret == null) {
// create the topic and the subscription
CreateTopicResult topic = asyncSnsClient.createTopic(topicName);
SubscribeRequest req = new SubscribeRequest(topic.getTopicArn(), "email", email);
asyncSnsClient.subscribeAsync(req);
ret = topic.getTopicArn();
}
return ret;
}
开发者ID:intuit，项目名称:Tank，代码行数:31，代码来源:CloudwatchInstance.java
示例2: shouldCreateSnsTopicResource_withName
import com.amazonaws.services.sns.model.Topic; //导入依赖的package包/类
@Test
public void shouldCreateSnsTopicResource_withName() throws Exception {
// Given
final String name = randomString();
final String topicArn = topicArnForName(name);
final List<Topic> topics = Arrays.asList(randomTopic(), randomTopic(), topicForArn(topicArn), randomTopic());
final ListTopicsResult mockListTopicsResult = mock(ListTopicsResult.class);
when(mockListTopicsResult.getTopics()).thenReturn(topics);
when(mockListTopicsResult.getNextToken()).thenReturn(null);
final String nextToken = null;
when(mockAmazonSnsClient.listTopics(nextToken)).thenReturn(mockListTopicsResult);
final SnsTopicResource mockSnsTopicResource = mock(SnsTopicResource.class);
whenNew(SnsTopicResource.class).withArguments(name, topicArn, mockAmazonSnsClient)
.thenReturn(mockSnsTopicResource);
// When
final SnsTopicResource result = factory.createSnsTopicResource(name);
// Then
assertSame(mockSnsTopicResource, result);
}
开发者ID:travel-cloud，项目名称:Cheddar，代码行数:22，代码来源:DefaultSnsTopicResourceFactoryTest.java
示例3: resolveDestination_withExistentTopic_returnsTopicArnFoundWhileListingTopic
import com.amazonaws.services.sns.model.Topic; //导入依赖的package包/类
@Test
public void resolveDestination_withExistentTopic_returnsTopicArnFoundWhileListingTopic() throws Exception {
// Arrange
String topicArn = "arn:aws:sns:eu-west:123456789012:test";
AmazonSNS sns = mock(AmazonSNS.class);
when(sns.listTopics(new ListTopicsRequest(null))).thenReturn(new ListTopicsResult().withTopics(new Topic().withTopicArn(topicArn)));
DynamicTopicDestinationResolver resolver = new DynamicTopicDestinationResolver(sns);
// Act
String resolvedDestinationName = resolver.resolveDestination("test");
// Assert
assertEquals(topicArn, resolvedDestinationName);
}
开发者ID:spring-cloud，项目名称:spring-cloud-aws，代码行数:17，代码来源:DynamicTopicDestinationResolverTest.java
示例4: resolveDestination_withExistentTopicAndMarker_returnsTopicArnFoundWhileListingTopic
import com.amazonaws.services.sns.model.Topic; //导入依赖的package包/类
@Test
public void resolveDestination_withExistentTopicAndMarker_returnsTopicArnFoundWhileListingTopic() throws Exception {
// Arrange
AmazonSNS sns = mock(AmazonSNS.class);
when(sns.listTopics(new ListTopicsRequest(null))).thenReturn(new ListTopicsResult().withNextToken("mark"));
String topicArn = "arn:aws:sns:eu-west:123456789012:test";
when(sns.listTopics(new ListTopicsRequest("mark"))).thenReturn(new ListTopicsResult().withTopics(new Topic().withTopicArn(topicArn)));
DynamicTopicDestinationResolver resolver = new DynamicTopicDestinationResolver(sns);
// Act
String resolvedDestinationName = resolver.resolveDestination("test");
// Assert
assertEquals(topicArn, resolvedDestinationName);
}
开发者ID:spring-cloud，项目名称:spring-cloud-aws，代码行数:19，代码来源:DynamicTopicDestinationResolverTest.java
示例5: resolveDestination_withResourceIdResolver_shouldCallIt
import com.amazonaws.services.sns.model.Topic; //导入依赖的package包/类
@Test
public void resolveDestination_withResourceIdResolver_shouldCallIt() throws Exception {
// Arrange
String physicalTopicName = "arn:aws:sns:eu-west:123456789012:myTopic";
String logicalTopicName = "myTopic";
ResourceIdResolver resourceIdResolver = mock(ResourceIdResolver.class);
when(resourceIdResolver.resolveToPhysicalResourceId(logicalTopicName)).thenReturn(physicalTopicName);
AmazonSNS sns = mock(AmazonSNS.class);
when(sns.listTopics(new ListTopicsRequest(null))).thenReturn(new ListTopicsResult().withTopics(new Topic().withTopicArn(physicalTopicName)));
DynamicTopicDestinationResolver resolver = new DynamicTopicDestinationResolver(sns, resourceIdResolver);
// Assert
String resolvedDestinationName = resolver.resolveDestination(logicalTopicName);
// Assert
assertEquals(physicalTopicName, resolvedDestinationName);
}
开发者ID:spring-cloud，项目名称:spring-cloud-aws，代码行数:21，代码来源:DynamicTopicDestinationResolverTest.java
示例6: send_validTextMessage_usesTopicChannel
import com.amazonaws.services.sns.model.Topic; //导入依赖的package包/类
@Test
public void send_validTextMessage_usesTopicChannel() throws Exception {
// Arrange
AmazonSNS amazonSns = mock(AmazonSNS.class);
NotificationMessagingTemplate notificationMessagingTemplate = new NotificationMessagingTemplate(amazonSns);
String physicalTopicName = "arn:aws:sns:eu-west:123456789012:test";
when(amazonSns.listTopics(new ListTopicsRequest(null))).thenReturn(new ListTopicsResult().withTopics(new Topic().withTopicArn(physicalTopicName)));
notificationMessagingTemplate.setDefaultDestinationName(physicalTopicName);
// Act
notificationMessagingTemplate.send(MessageBuilder.withPayload("Message content").build());
// Assert
verify(amazonSns).publish(new PublishRequest(physicalTopicName,
"Message content", null).withMessageAttributes(isNotNull()));
}
开发者ID:spring-cloud，项目名称:spring-cloud-aws，代码行数:17，代码来源:NotificationMessagingTemplateTest.java
示例7: getTopicARN
import com.amazonaws.services.sns.model.Topic; //导入依赖的package包/类
public String getTopicARN() {
try {
if (topicANR.isEmpty()) {
ListTopicsResult topics = snsClient.listTopics();
for(Topic topic : topics.getTopics()) {
String foundArn = topic.getTopicArn();
if (foundArn.contains(TOPIC_NAME)) {
logger.info("Found notification topic for SNS, ARN is: " + foundArn);
topicANR = foundArn;
break;
}
}
}
if (topicANR.isEmpty()) {
logger.info("Did not find notification topic for SNS, to receive updates create topic: " + TOPIC_NAME);
}
return topicANR;
}
catch (AuthorizationErrorException authException) {
logger.error("Did not send SNS notification. You may need to update permissions for user via IAM. Exception was " + authException);
return "";
}
}
开发者ID:cartwrightian，项目名称:cfnassist，代码行数:24，代码来源:SNSNotificationSender.java
示例8: createTopicIfNotExists
import com.amazonaws.services.sns.model.Topic; //导入依赖的package包/类
private void createTopicIfNotExists() {
for (Topic topic : client.listTopics().getTopics()) {
if (topic.getTopicArn().contains(topicName)) {
topicArn = topic.getTopicArn();
break;
}
}
if (topicArn == null) {
CreateTopicRequest request = new CreateTopicRequest(topicName);
CreateTopicResult result = client.createTopic(request);
topicArn = result.getTopicArn();
log.debug("Topic created, arn: " + topicArn);
} else {
log.debug("Topic already created: " + topicArn);
}
}
开发者ID:3pillarlabs，项目名称:spring-integration-aws，代码行数:17，代码来源:SnsExecutor.java
示例9: getEssTopicArn
import com.amazonaws.services.sns.model.Topic; //导入依赖的package包/类
/**
* Returns ARN of topic where AutoScaling publishes system events
*
* @return
*/
private String getEssTopicArn() {
Topic ess_topic = amazonSNS.listTopics().getTopics()
.stream().filter(topic -> topic.getTopicArn().endsWith(ESS_TOPIC_NAME)).findFirst()
.orElseThrow(() -> new ConfigurationException("Topic " + ESS_TOPIC_NAME + " does not exist."));
return ess_topic.getTopicArn();
}
开发者ID:SungardAS，项目名称:enhanced-snapshots，代码行数:12，代码来源:ClusterConfigurationServiceImpl.java
示例10: next
import com.amazonaws.services.sns.model.Topic; //导入依赖的package包/类
@Override
public Topic next() {
if (cursor == topics.size() && result.getNextToken() != null) {
result = sns.listTopics(result.getNextToken());
topics = result.getTopics();
cursor = 0;
}
try {
return topics.get(cursor++);
} catch (IndexOutOfBoundsException e) {
throw new NoSuchElementException();
}
}
开发者ID:OpenG，项目名称:aws-java-sdk，代码行数:14，代码来源:SNSTopics.java
示例11: topicArnForNameInTopics
import com.amazonaws.services.sns.model.Topic; //导入依赖的package包/类
private String topicArnForNameInTopics(final String name, final List<Topic> topics) {
final String topicArnSuffix = ":" + name;
for (final Topic topic : topics) {
final String topicArn = topic.getTopicArn();
final int pos = topicArn.lastIndexOf(topicArnSuffix);
if (pos == -1) {
continue;
}
final String actualName = topicArn.substring(pos + 1);
if (actualName.equals(name)) {
return topicArn;
}
}
return null;
}
开发者ID:travel-cloud，项目名称:Cheddar，代码行数:16，代码来源:DefaultSnsTopicResourceFactory.java
示例12: getTopicResourceName
import com.amazonaws.services.sns.model.Topic; //导入依赖的package包/类
private String getTopicResourceName(String marker, String topicName) {
ListTopicsResult listTopicsResult = this.amazonSns.listTopics(new ListTopicsRequest(marker));
for (Topic topic : listTopicsResult.getTopics()) {
AmazonResourceName resourceName = AmazonResourceName.fromString(topic.getTopicArn());
if (resourceName.getResourceType().equals(topicName)) {
return topic.getTopicArn();
}
}
if (StringUtils.hasText(listTopicsResult.getNextToken())) {
return getTopicResourceName(listTopicsResult.getNextToken(), topicName);
} else {
throw new IllegalArgumentException("No topic found for name :'" + topicName + "'");
}
}
开发者ID:spring-cloud，项目名称:spring-cloud-aws，代码行数:16，代码来源:DynamicTopicDestinationResolver.java
示例13: convertAndSend_withDestinationPayloadAndSubject_shouldSetSubject
import com.amazonaws.services.sns.model.Topic; //导入依赖的package包/类
@Test
public void convertAndSend_withDestinationPayloadAndSubject_shouldSetSubject() throws Exception {
// Arrange
AmazonSNS amazonSns = mock(AmazonSNS.class);
NotificationMessagingTemplate notificationMessagingTemplate = new NotificationMessagingTemplate(amazonSns);
String physicalTopicName = "arn:aws:sns:eu-west:123456789012:test";
when(amazonSns.listTopics(new ListTopicsRequest(null))).thenReturn(new ListTopicsResult().withTopics(new Topic().withTopicArn(physicalTopicName)));
// Act
notificationMessagingTemplate.sendNotification(physicalTopicName, "My message", "My subject");
// Assert
verify(amazonSns).publish(new PublishRequest(physicalTopicName, "My message", "My subject").withMessageAttributes(isNotNull()));
}
开发者ID:spring-cloud，项目名称:spring-cloud-aws，代码行数:15，代码来源:NotificationMessagingTemplateTest.java
示例14: convertAndSend_withPayloadAndSubject_shouldSetSubject
import com.amazonaws.services.sns.model.Topic; //导入依赖的package包/类
@Test
public void convertAndSend_withPayloadAndSubject_shouldSetSubject() throws Exception {
// Arrange
AmazonSNS amazonSns = mock(AmazonSNS.class);
NotificationMessagingTemplate notificationMessagingTemplate = new NotificationMessagingTemplate(amazonSns);
String physicalTopicName = "arn:aws:sns:eu-west:123456789012:test";
when(amazonSns.listTopics(new ListTopicsRequest(null))).thenReturn(new ListTopicsResult().withTopics(new Topic().withTopicArn(physicalTopicName)));
notificationMessagingTemplate.setDefaultDestinationName(physicalTopicName);
// Act
notificationMessagingTemplate.sendNotification("My message", "My subject");
// Assert
verify(amazonSns).publish(new PublishRequest(physicalTopicName, "My message", "My subject").withMessageAttributes(isNotNull()));
}
开发者ID:spring-cloud，项目名称:spring-cloud-aws，代码行数:16，代码来源:NotificationMessagingTemplateTest.java
示例15: iterator
import com.amazonaws.services.sns.model.Topic; //导入依赖的package包/类
@Override
public Iterator<Topic> iterator() {
return new Itr(sns);
}
开发者ID:OpenG，项目名称:aws-java-sdk，代码行数:5，代码来源:SNSTopics.java
示例16: arnValues
import com.amazonaws.services.sns.model.Topic; //导入依赖的package包/类
public List<String> arnValues(List<Topic> topics) {
return topics.stream().map(Topic::getTopicArn).collect(Collectors.toList());
}
开发者ID:OpenG，项目名称:aws-java-sdk，代码行数:4，代码来源:AmazonSNSFakeListTopicsTest.java
示例17: topicForArn
import com.amazonaws.services.sns.model.Topic; //导入依赖的package包/类
private Topic topicForArn(final String topicArn) {
return new Topic().withTopicArn(topicArn);
}
开发者ID:travel-cloud，项目名称:Cheddar，代码行数:4，代码来源:DefaultSnsTopicResourceFactoryTest.java
示例18: randomTopic
import com.amazonaws.services.sns.model.Topic; //导入依赖的package包/类
private Topic randomTopic() {
return topicForArn(topicArnForName(randomString(20)));
}
开发者ID:travel-cloud，项目名称:Cheddar，代码行数:4，代码来源:DefaultSnsTopicResourceFactoryTest.java
示例19: apply
import com.amazonaws.services.sns.model.Topic; //导入依赖的package包/类
@Override
public Topic apply(String s) {
return new Topic().withTopicArn(s);
}
开发者ID:bazaarvoice，项目名称:awslocal，代码行数:5，代码来源:InMemorySNS.java
示例20: getTopicArn
import com.amazonaws.services.sns.model.Topic; //导入依赖的package包/类
public static String getTopicArn( final AmazonSNSClient sns, final String queueName, final boolean createOnMissing )
throws Exception {
if ( logger.isTraceEnabled() ) {
logger.trace( "Looking up Topic ARN: {}", queueName );
}
ListTopicsResult listTopicsResult = sns.listTopics();
String topicArn = null;
for ( Topic topic : listTopicsResult.getTopics() ) {
String arn = topic.getTopicArn();
if ( queueName.equals( arn.substring( arn.lastIndexOf( ':' ) ) ) ) {
topicArn = arn;
if (logger.isTraceEnabled()) {
logger.trace( "Found existing topic arn=[{}] for queue=[{}]", topicArn, queueName );
}
}
}
if ( topicArn == null && createOnMissing ) {
if (logger.isTraceEnabled()) {
logger.trace("Creating topic for queue=[{}]...", queueName);
}
CreateTopicResult createTopicResult = sns.createTopic( queueName );
topicArn = createTopicResult.getTopicArn();
if (logger.isTraceEnabled()) {
logger.trace("Successfully created topic with name {} and arn {}", queueName, topicArn);
}
}
else {
logger.error( "Error looking up topic ARN for queue=[{}] and createOnMissing=[{}]", queueName,
createOnMissing );
}
if ( logger.isTraceEnabled() ) {
logger.trace( "Returning Topic ARN=[{}] for Queue=[{}]", topicArn, queueName );
}
return topicArn;
}
开发者ID:apache，项目名称:usergrid，代码行数:47，代码来源:AmazonNotificationUtils.java
注：本文中的com.amazonaws.services.sns.model.Topic类示例整理自Github/MSDocs等源码及文档管理平台，相关代码片段筛选自各路编程大神贡献的开源项目，源码版权归原作者所有，传播和使用请参考对应项目的License；未经允许，请勿转载。 |
客服电话
APP下载
官方微信
请发表评论