Package es.kukenan.smartfi.microservice.communication.controller

Class InternalMailJetEventsQueueController

java.lang.Object

es.kukenan.smartfi.microservice.communication.controller.InternalMailJetEventsQueueController

@Controller
public class InternalMailJetEventsQueueController
extends Object

Internal MailJet events queue controller. This queue is used just to avoid flooding and for load-balancing.

Field Summary

Fields

Modifier and Type	Field	Description
private org.springframework.amqp.core.AmqpTemplate	amqpTemplate	AMQP template used to send messages to the queue.
private org.springframework.amqp.core.Queue	eventsQueue	The events queue.
private MailjetEventsService	eventsService	The service where the logic to the events handling is located.
static final String	RECEIVE_METHOD	Entrypoint for the "MailJet real-time events" message handling.

Constructor Summary

Constructors

Constructor	Description
InternalMailJetEventsQueueController()

Method Summary

Modifier and Type	Method	Description
void	onEvent(AbstractEvent event)	This event is invoked to handle an event from the event queue.
void	publish(AbstractEvent event)	Send an event to the internal queue.

Methods inherited from class java.lang.Object

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

Field Details

RECEIVE_METHOD

public static final String RECEIVE_METHOD

Entrypoint for the "MailJet real-time events" message handling.

See Also:

• Constant Field Values

eventsQueue

@Autowired
@Qualifier("internalMailJetEventsQueue")
private org.springframework.amqp.core.Queue eventsQueue

The events queue.

amqpTemplate

@Autowired
@Qualifier("internalMailJetEventsAmqpTemplate")
private org.springframework.amqp.core.AmqpTemplate amqpTemplate

AMQP template used to send messages to the queue.

eventsService

@Autowired
private MailjetEventsService eventsService

The service where the logic to the events handling is located.

Constructor Details

InternalMailJetEventsQueueController

public InternalMailJetEventsQueueController()

Method Details

onEvent

public void onEvent(AbstractEvent event)

This event is invoked to handle an event from the event queue. The logic is delegated to the service.

Parameters:

event - a new event to handle.

publish

public void publish(AbstractEvent event)

Send an event to the internal queue.

Parameters:

event - the event to send to the queue.