Package io.openems.backend.alerting.handler

Class OfflineEdgeHandler

java.lang.Object

io.openems.backend.alerting.handler.OfflineEdgeHandler

All Implemented Interfaces:

Handler<OfflineEdgeMessage>

public class OfflineEdgeHandler
extends Object
implements Handler<OfflineEdgeMessage>

Field Summary

Fields

Modifier and Type	Field	Description
static final int	EDGE_REBOOT_MINUTES
static final int	MAX_SIMULTANEOUS_EDGES
static final int	MAX_SIMULTANEOUS_MSGS

Constructor Summary

Constructors

Constructor	Description
OfflineEdgeHandler(MessageSchedulerService mss, TimedExecutor timeService, Mailer mailer, Metadata metadata, int initialDelay)

Method Summary

Modifier and Type	Method	Description
protected OfflineEdgeMessage	getEdgeMessage(Edge edge)	Add Edge to list, with calculated TimeStamp (at which to notify).
Consumer<EventReader>	getEventHandler(String eventTopic)	Handle given event.
Class<OfflineEdgeMessage>	getGeneric()	Return generic type of handler as Class object.
void	send(ZonedDateTime sentAt, List<OfflineEdgeMessage> pack)	Send the messages.
void	stop()	Stop the Handler.
protected void	tryAddEdge(Edge edge)
protected void	tryRemoveEdge(Edge edge)

Methods inherited from class java.lang.Object

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

Field Details

MAX_SIMULTANEOUS_MSGS

public static final int MAX_SIMULTANEOUS_MSGS

See Also:

• Constant Field Values

MAX_SIMULTANEOUS_EDGES

public static final int MAX_SIMULTANEOUS_EDGES

See Also:

• Constant Field Values

EDGE_REBOOT_MINUTES

public static final int EDGE_REBOOT_MINUTES

See Also:

• Constant Field Values

Constructor Details

OfflineEdgeHandler

public OfflineEdgeHandler(MessageSchedulerService mss,
 TimedExecutor timeService,
 Mailer mailer,
 Metadata metadata,
 int initialDelay)

Method Details

stop

public void stop()

Description copied from interface: Handler

Stop the Handler.

Specified by:

stop in interface Handler<OfflineEdgeMessage>

send

public void send(ZonedDateTime sentAt,
 List<OfflineEdgeMessage> pack)

Description copied from interface: Handler

Send the messages.

Specified by:

send in interface Handler<OfflineEdgeMessage>

Parameters:

sentAt - TimeStamp at with sending was initiated

pack - which to send

getEdgeMessage

protected OfflineEdgeMessage getEdgeMessage(Edge edge)

Add Edge to list, with calculated TimeStamp (at which to notify).

Parameters:

edge - to add

Returns:

OfflineEdgeMessage generated from edge

tryRemoveEdge

protected void tryRemoveEdge(Edge edge)

tryAddEdge

protected void tryAddEdge(Edge edge)

getEventHandler

public Consumer<EventReader> getEventHandler(String eventTopic)

Description copied from interface: Handler

Handle given event.

Specified by:

getEventHandler in interface Handler<OfflineEdgeMessage>

Parameters:

eventTopic - to handle

Returns:

Consumer to be scheduled in executor

getGeneric

public Class<OfflineEdgeMessage> getGeneric()

Description copied from interface: Handler

Return generic type of handler as Class object.

Specified by:

getGeneric in interface Handler<OfflineEdgeMessage>

Returns:

GenericType of handler