Package gov.usgs.earthquake.aws

Class SnsPublisher

java.lang.Object

gov.usgs.util.DefaultConfigurable

gov.usgs.earthquake.aws.SnsPublisher

All Implemented Interfaces:

EventPublisher, Configurable

public class SnsPublisher
extends DefaultConfigurable
implements EventPublisher

Field Summary

Fields

Modifier and Type	Field	Description
static final Logger	LOGGER	Logger to use for this class
static final String	REGION_PROPERTY
static final String	TOPIC_ARN_PROPERTY

Constructor Summary

Constructors

Constructor	Description
SnsPublisher(software.amazon.awssdk.regions.Region region, String topicArn, software.amazon.awssdk.services.sns.SnsClient snsClient)	Configurable SNS publisher.

Method Summary

Modifier and Type	Method	Description
void	configure(Config config)	Process configuration settings.
void	publishMessage(String message)	Publishes a message to the configured SNS topic.
void	shutdown()	Closes the SNS client.

Methods inherited from class gov.usgs.util.DefaultConfigurable

getName, setName, startup

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

LOGGER

public static final Logger LOGGER

Logger to use for this class

REGION_PROPERTY

public static final String REGION_PROPERTY

See Also:

• Constant Field Values

TOPIC_ARN_PROPERTY

public static final String TOPIC_ARN_PROPERTY

See Also:

• Constant Field Values

Constructor Details

SnsPublisher

public SnsPublisher(software.amazon.awssdk.regions.Region region,
 String topicArn,
 software.amazon.awssdk.services.sns.SnsClient snsClient)

Configurable SNS publisher.

Parameters:

region - AWS region where the SNS topic is.

topicArn - The ARN of the target SNS topic.

Method Details

configure

public void configure(Config config)
               throws Exception

Description copied from class: DefaultConfigurable

Process configuration settings. Called before startup().

Specified by:

configure in interface Configurable

Overrides:

configure in class DefaultConfigurable

Parameters:

config - the Config object with settings.

Throws:

Exception - if configuration exceptions occur.

publishMessage

public void publishMessage(String message)

Publishes a message to the configured SNS topic. Alerts on failure by printing an error message.

Specified by:

publishMessage in interface EventPublisher

Parameters:

message - The message to publish.

shutdown

public void shutdown()

Closes the SNS client.

Specified by:

shutdown in interface Configurable

Overrides:

shutdown in class DefaultConfigurable