Package org.jgrapes.mail

Class MailStoreMonitor

java.lang.Object

org.jgrapes.core.internal.ComponentVertex

org.jgrapes.core.Component

org.jgrapes.mail.MailComponent

org.jgrapes.mail.MailConnectionManager<OpenMailMonitor,MailStoreMonitor.MonitorChannel>

org.jgrapes.mail.MailStoreMonitor

All Implemented Interfaces:

Iterable<ComponentType>, Channel, ComponentType, Eligible, Manager

public class MailStoreMonitor
extends MailConnectionManager<OpenMailMonitor,MailStoreMonitor.MonitorChannel>

A component that opens mail stores and monitors mail folders for mails.

After establishing a connection to a store and selected folders (see onOpenMailMonitor(OpenMailMonitor, Channel)), the existing and all subsequently arriving mails will be sent downstream using FoldersUpdated events.

This implementation uses the IdleManager. The IdleManager works only if its IdleManager.watch(jakarta.mail.Folder) method is invoked (for a folder) after any operation on that folder. Note that operations such as e.g. setting the deleted flag of a message is also an operation on a folder.

Folders are updated in response to an UpdateFolders event or when the store signals the arrival of new messages. Information about the folders is delivered by a FoldersUpdated event. Folders may be freely used while handling the event, because the folders will be re-registered with the IdleManager when the FoldersUpdated event completes. Any usage of folders independent of handling the events mentioned will result in a loss of the monitor function.

If required, the monitor function may be reestablished any time by firing a UpdateFolders event for the folders used.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
protected class	MailStoreMonitor.MonitorChannel	The specific implementation of the MailChannel.

Nested classes/interfaces inherited from class org.jgrapes.mail.MailConnectionManager

MailConnectionManager.AbstractMailChannel

Nested classes/interfaces inherited from interface org.jgrapes.core.Channel

Channel.Default

Field Summary

Fields inherited from class org.jgrapes.mail.MailConnectionManager

channels

Fields inherited from class org.jgrapes.mail.MailComponent

mailProps

Fields inherited from interface org.jgrapes.core.Channel

BROADCAST, SELF

Constructor Summary

Constructors

Constructor	Description
MailStoreMonitor(Channel componentChannel)	Creates a new server using the given channel.

Method Summary

Modifier and Type	Method	Description
protected void	configureComponent(Map<String,String> values)	Configure the component.
Duration	maxIdleTime()	Returns the max idle time.
void	onClose(Close event, Channel channel)	Closes the channel.
void	onOpenMailMonitor(OpenMailMonitor event, Channel channel)	Open a store as specified by the event and monitor the folders (also specified by the event).
void	onStop(Stop event)	Stops the thread that is associated with this dispatcher.
void	onUpdateFolders(UpdateFolders event, MailChannel channel)	Retrieves the folders specified in the event.
MailStoreMonitor	setMaxIdleTime(Duration maxIdleTime)	Sets the maximum idle time.
String	toString()	If a name has been set for this component (see Manager.setName(String)), return the name, else return the object name provided by Components.objectName(Object), using ComponentVertex.component() as argument.

Methods inherited from class org.jgrapes.mail.MailConnectionManager

executorService, setExecutorService

Methods inherited from class org.jgrapes.mail.MailComponent

onConfigUpdate, setMailProperties

Methods inherited from class org.jgrapes.core.Component

channel, component, defaultCriterion, isEligibleFor, setName

Methods inherited from class org.jgrapes.core.internal.ComponentVertex

activeEventPipeline, addHandler, attach, children, componentPath, componentVertex, detach, fire, initComponentsHandlers, iterator, name, newEventPipeline, newEventPipeline, parent, registerAsGenerator, root, unregisterAsGenerator

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.lang.Iterable

forEach, spliterator

Methods inherited from interface org.jgrapes.core.Manager

stream

Constructor Details

MailStoreMonitor

public MailStoreMonitor(Channel componentChannel)

Creates a new server using the given channel.

Parameters:

componentChannel - the component’s channel

Method Details

setMaxIdleTime

public MailStoreMonitor setMaxIdleTime(Duration maxIdleTime)

Sets the maximum idle time.

A running IMAPFolder.idle() is terminated and renewed after this time. Defaults to 25 minutes.

Parameters:

maxIdleTime - the new max idle time

maxIdleTime

public Duration maxIdleTime()

Returns the max idle time.

Returns:

the duration

configureComponent

protected void configureComponent(Map<String,String> values)

Configure the component.

Currently, only max idle time is supported.

Specified by:

configureComponent in class MailComponent

Parameters:

values - the values

onOpenMailMonitor

@Handler
public void onOpenMailMonitor(OpenMailMonitor event,
 Channel channel)

Open a store as specified by the event and monitor the folders (also specified by the event).

Information about all existing and all subsequently arriving mails will be signaled downstream using FoldersUpdated events.

Parameters:

event - the event

channel - the channel

onClose

@Handler
public void onClose(Close event,
 Channel channel)

Closes the channel.

Parameters:

event - the event

onUpdateFolders

@Handler
public void onUpdateFolders(UpdateFolders event,
 MailChannel channel)

Retrieves the folders specified in the event.

Parameters:

event - the event

channel - the channel

onStop

@Handler
public void onStop(Stop event)
            throws InterruptedException

Stops the thread that is associated with this dispatcher.

Parameters:

event - the event

Throws:

InterruptedException - if the execution is interrupted

toString

public String toString()

Description copied from class: ComponentVertex

If a name has been set for this component (see Manager.setName(String)), return the name, else return the object name provided by Components.objectName(Object), using ComponentVertex.component() as argument.

Overrides:

toString in class MailComponent