com.atlassian.messagequeue.internal.lifecycle

Class DefaultInstanceLifecycleNotificationObserver

java.lang.Object

com.atlassian.messagequeue.internal.lifecycle.DefaultInstanceLifecycleNotificationObserver

All Implemented Interfaces:

InstanceLifecycleNotificationObserver

public class DefaultInstanceLifecycleNotificationObserver
extends Object
implements InstanceLifecycleNotificationObserver

Observes EC2 instance lifecycle notifications.

Allows listeners to be registered to respond to an instance terminating notification

.

See Also:

AWS Autoscaling lifecycle hooks, Micros lifecycle hooks

Constructor Summary

Constructors

Constructor and Description
DefaultInstanceLifecycleNotificationObserver(String instanceLifecycleNotificationQueueUrl, com.amazonaws.services.sqs.AmazonSQSClient amazonSqsClient, NotificationDeserializer notificationDeserializer) Constructs an instance of InstanceLifecycleNotificationObserver.

Method Summary

Modifier and Type	Method and Description
void	addInstanceTerminatingListener(InstanceLifecycleListener listener) Register a listener to respond to instance terminating notification.
void	initialise() Initialise this observer.
void	shutdown() Shutdown this observer.

Methods inherited from class java.lang.Object

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

Constructor Detail

DefaultInstanceLifecycleNotificationObserver

public DefaultInstanceLifecycleNotificationObserver(String instanceLifecycleNotificationQueueUrl,
                                                    com.amazonaws.services.sqs.AmazonSQSClient amazonSqsClient,
                                                    NotificationDeserializer notificationDeserializer)

Constructs an instance of InstanceLifecycleNotificationObserver.

Parameters:

instanceLifecycleNotificationQueueUrl - URL of SQS queue where lifecycle notifications are being sent to.

amazonSqsClient - SQS client

notificationDeserializer - notification deserializer

See Also:

Micros lifecycle hooks

Method Detail

initialise

public void initialise()

Description copied from interface: InstanceLifecycleNotificationObserver

Initialise this observer.

Specified by:

initialise in interface InstanceLifecycleNotificationObserver

addInstanceTerminatingListener

public void addInstanceTerminatingListener(InstanceLifecycleListener listener)

Register a listener to respond to instance terminating notification.

Specified by:

addInstanceTerminatingListener in interface InstanceLifecycleNotificationObserver

Parameters:

listener - a listener that will be invoked on an instance terminating notification.

shutdown

public void shutdown()

Description copied from interface: InstanceLifecycleNotificationObserver

Shutdown this observer.

Specified by:

shutdown in interface InstanceLifecycleNotificationObserver