I
- Email RequestO
- Email Responsepublic abstract class AbstractTransactionalEmailSender<I,O> extends java.lang.Object implements AsyncTransactionalEmailSender<I,O>, TransactionalEmailSender<I,O>
TransactionalEmailSender
and AsyncTransactionalEmailSender
.
It provides an implemeentation of AsyncTransactionalEmailSender.sendAsync(Email, Consumer)
by subscribing on an IO scheduler.Constructor and Description |
---|
AbstractTransactionalEmailSender(java.util.concurrent.ExecutorService executorService) |
Modifier and Type | Method and Description |
---|---|
org.reactivestreams.Publisher<O> |
sendAsync(@NotNull Email email,
@NotNull java.util.function.Consumer<I> emailRequest)
Sends an email.
|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
sendAsync
send, send
public AbstractTransactionalEmailSender(@Named(value="io") java.util.concurrent.ExecutorService executorService)
executorService
- Executor service@NonNull @SingleResult public org.reactivestreams.Publisher<O> sendAsync(@NonNull @NotNull @NotNull Email email, @NonNull @NotNull @NotNull java.util.function.Consumer<I> emailRequest) throws EmailException
AsyncTransactionalEmailSender
sendAsync
in interface AsyncTransactionalEmailSender<I,O>
email
- EmailemailRequest
- Email Request ConsumerEmailException
- Wrapper of any exception thrown while sending email