com.netflix.genie.web.events

Class JobStateChangeSNSPublisher

java.lang.Object

com.netflix.genie.web.events.JobStateChangeSNSPublisher

All Implemented Interfaces:

java.util.EventListener, org.springframework.context.ApplicationListener<JobStateChangeEvent>

public class JobStateChangeSNSPublisher
extends java.lang.Object
implements org.springframework.context.ApplicationListener<JobStateChangeEvent>

Publishes Amazon SNS notifications for fine-grained job state changes.

Since:

4.0.0

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected static class	com.netflix.genie.web.events.AbstractSNSPublisher.EventType Types of event.

Field Summary

Fields

Modifier and Type	Field and Description
protected SNSNotificationsProperties	properties
protected io.micrometer.core.instrument.MeterRegistry	registry

Constructor Summary

Constructors

Constructor and Description
JobStateChangeSNSPublisher(com.amazonaws.services.sns.AmazonSNS snsClient, SNSNotificationsProperties properties, io.micrometer.core.instrument.MeterRegistry registry, com.fasterxml.jackson.databind.ObjectMapper mapper) Constructor.

Method Summary

Modifier and Type	Method and Description
void	onApplicationEvent(JobStateChangeEvent event)
protected void	publishEvent(com.netflix.genie.web.events.AbstractSNSPublisher.EventType eventType, java.util.HashMap<java.lang.String,java.lang.Object> eventDetailsMap)

Methods inherited from class java.lang.Object

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

Field Detail

properties

protected final SNSNotificationsProperties properties

registry

protected final io.micrometer.core.instrument.MeterRegistry registry

Constructor Detail

JobStateChangeSNSPublisher

public JobStateChangeSNSPublisher(com.amazonaws.services.sns.AmazonSNS snsClient,
                                  SNSNotificationsProperties properties,
                                  io.micrometer.core.instrument.MeterRegistry registry,
                                  com.fasterxml.jackson.databind.ObjectMapper mapper)

Constructor.

Parameters:

snsClient - Amazon SNS client

properties - configuration properties

registry - metrics registry

mapper - object mapper

Method Detail

onApplicationEvent

public void onApplicationEvent(JobStateChangeEvent event)

Specified by:

onApplicationEvent in interface org.springframework.context.ApplicationListener<JobStateChangeEvent>

publishEvent

protected void publishEvent(com.netflix.genie.web.events.AbstractSNSPublisher.EventType eventType,
                            java.util.HashMap<java.lang.String,java.lang.Object> eventDetailsMap)