Package ch.tocco.nice2.messaging.mail.api

Class CompositeMailReaderHandler<T>

java.lang.Object

ch.tocco.nice2.messaging.mail.api.AbstractMailboxReaderHandler<T>

ch.tocco.nice2.messaging.mail.api.CompositeMailReaderHandler<T>

All Implemented Interfaces:

MailboxReaderHandler<T>, Iterable<MailboxReaderHandler<T>>

public class CompositeMailReaderHandler<T>
extends AbstractMailboxReaderHandler<T>
implements Iterable<MailboxReaderHandler<T>>

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	CompositeMailReaderHandler.Progress<R>

Constructor Summary

Constructors

Constructor	Description
CompositeMailReaderHandler(MailboxReaderHandler<T>... handlers)
CompositeMailReaderHandler(Iterable<MailboxReaderHandler<T>> handlers)
CompositeMailReaderHandler(Iterable<MailboxReaderHandler<T>> handlers, CompositeMailReaderHandler.Progress<?> progress)

Method Summary

Modifier and Type	Method	Description
void	addHandler(int index, MailboxReaderHandler<T> handler)
void	addHandler(MailboxReaderHandler<T> handler)
void	addHandlers(MailboxReaderHandler<T>... handlers)
void	addHandlers(Iterable<MailboxReaderHandler<T>> handlers)
CompositeMailReaderHandler<T>	copy()
<R> CompositeMailReaderHandler<T>	copyWithProgress(CompositeMailReaderHandler.Progress<R> progress)
void	finish(MailboxReader.Context<T> context)	Called once after iterating finished, regardless of error.
MailboxReaderHandler<T>	getHandler(int index)
int	getHandlerCount()
void	init(MailboxReader.Context<T> context)	Called once before the reading process starts.
Iterator<MailboxReaderHandler<T>>	iterator()
void	onMessage(jakarta.mail.Message message, MailboxReader.Context<T> context)	Called for each message.
void	removeHandler(MailboxReaderHandler<T> handler)

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.lang.Iterable

forEach, spliterator

Constructor Details

CompositeMailReaderHandler

public CompositeMailReaderHandler(Iterable<MailboxReaderHandler<T>> handlers,
 CompositeMailReaderHandler.Progress<?> progress)

CompositeMailReaderHandler

public CompositeMailReaderHandler(Iterable<MailboxReaderHandler<T>> handlers)

CompositeMailReaderHandler

public CompositeMailReaderHandler(MailboxReaderHandler<T>... handlers)

Method Details

addHandler

public void addHandler(MailboxReaderHandler<T> handler)

addHandler

public void addHandler(int index,
 MailboxReaderHandler<T> handler)

addHandlers

public void addHandlers(Iterable<MailboxReaderHandler<T>> handlers)

addHandlers

public void addHandlers(MailboxReaderHandler<T>... handlers)

removeHandler

public void removeHandler(MailboxReaderHandler<T> handler)

getHandler

public MailboxReaderHandler<T> getHandler(int index)

getHandlerCount

public int getHandlerCount()

init

public void init(MailboxReader.Context<T> context)

Description copied from interface: MailboxReaderHandler

Called once before the reading process starts.

Specified by:

init in interface MailboxReaderHandler<T>

Overrides:

init in class AbstractMailboxReaderHandler<T>

finish

public void finish(MailboxReader.Context<T> context)

Description copied from interface: MailboxReaderHandler

Called once after iterating finished, regardless of error.

Specified by:

finish in interface MailboxReaderHandler<T>

Overrides:

finish in class AbstractMailboxReaderHandler<T>

onMessage

public void onMessage(jakarta.mail.Message message,
 MailboxReader.Context<T> context)
               throws jakarta.mail.MessagingException

Description copied from interface: MailboxReaderHandler

Called for each message. The MessagingException is wrapped in a MailException to comply to the api of this module. All other execptions are propagated (wrapped in RuntimeException if necessary).

Specified by:

onMessage in interface MailboxReaderHandler<T>

Throws:

jakarta.mail.MessagingException

iterator

public Iterator<MailboxReaderHandler<T>> iterator()

Specified by:

iterator in interface Iterable<T>

copy

public CompositeMailReaderHandler<T> copy()

copyWithProgress

public <R> CompositeMailReaderHandler<T> copyWithProgress(CompositeMailReaderHandler.Progress<R> progress)