Package io.jmix.email.impl

Class EmailDataProviderImpl

java.lang.Object

io.jmix.email.impl.EmailDataProviderImpl

All Implemented Interfaces:

EmailDataProvider

@Component("email_EmailDataProvider")
public class EmailDataProviderImpl
extends Object
implements EmailDataProvider

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
protected static class	EmailDataProviderImpl.MessagePersistingContext

Field Summary

Fields

Modifier and Type	Field	Description
protected static final String	BODY_FILE_EXTENSION
protected DataManager	dataManager
protected EmailerProperties	emailerProperties
protected javax.persistence.EntityManager	entityManager
protected FetchPlanRepository	fetchPlanRepository
protected FileStorage	fileStorage
protected FileStorageLocator	fileStorageLocator
protected TimeSource	timeSource
protected org.springframework.transaction.support.TransactionTemplate	transaction

Constructor Summary

Constructors

Constructor	Description
EmailDataProviderImpl()

Method Summary

Modifier and Type	Method	Description
protected String	bodyTextFromByteArray(byte[] bodyContent)
protected byte[]	bodyTextToBytes(SendingMessage message)
protected String	buildErrorMessage(SendingStatus status)
protected FileRef	createContentFile(EmailDataProviderImpl.MessagePersistingContext context, byte[] bodyBytes, String fileName)
protected String	getFileName(SendingMessage msg)
protected FileStorage	getFileStorage()
protected void	loadBodyAndAttachments(SendingMessage message)
String	loadContentText(SendingMessage sendingMessage)	Loads content text for given message.
List<SendingMessage>	loadEmailsToSend()	Loads email messages to be sent.
protected void	migrateAttachment(SendingAttachment attachment)
void	migrateAttachmentsToFileStorage(List<SendingAttachment> attachments)	Migrate list of existing email attachments to be stored in file storage, in a single transaction.
void	migrateEmailsToFileStorage(List<SendingMessage> messages)	Migrate list of existing messages to be stored in file storage, in a single transaction.
protected void	migrateMessage(SendingMessage msg)
void	persistMessage(SendingMessage sendingMessage, SendingStatus status)	Stores given message with specified status.
protected void	persistSendingMessage(SendingMessage message, EmailDataProviderImpl.MessagePersistingContext context)
protected void	removeOrphanFiles(EmailDataProviderImpl.MessagePersistingContext context)
protected void	setTransactionManager(org.springframework.transaction.PlatformTransactionManager transactionManager)
protected boolean	shouldMarkNotSent(SendingMessage sendingMessage)
void	updateStatus(SendingMessage sendingMessage, SendingStatus status)	Update status for specified message.

Methods inherited from class java.lang.Object

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

Field Details

BODY_FILE_EXTENSION

protected static final String BODY_FILE_EXTENSION

See Also:

• Constant Field Values

emailerProperties

@Autowired
protected EmailerProperties emailerProperties

timeSource

@Autowired
protected TimeSource timeSource

entityManager

protected javax.persistence.EntityManager entityManager

fetchPlanRepository

@Autowired
protected FetchPlanRepository fetchPlanRepository

transaction

protected org.springframework.transaction.support.TransactionTemplate transaction

fileStorage

protected FileStorage fileStorage

dataManager

@Autowired
protected DataManager dataManager

fileStorageLocator

@Autowired
protected FileStorageLocator fileStorageLocator

Constructor Details

EmailDataProviderImpl

public EmailDataProviderImpl()

Method Details

setTransactionManager

@Autowired
protected void setTransactionManager(org.springframework.transaction.PlatformTransactionManager transactionManager)

loadEmailsToSend

public List<SendingMessage> loadEmailsToSend()

Description copied from interface: EmailDataProvider

Loads email messages to be sent.

Specified by:

loadEmailsToSend in interface EmailDataProvider

updateStatus

public void updateStatus(SendingMessage sendingMessage,
 SendingStatus status)

Description copied from interface: EmailDataProvider

Update status for specified message.

Specified by:

updateStatus in interface EmailDataProvider

Parameters:

sendingMessage - message

status - new status

loadContentText

public String loadContentText(SendingMessage sendingMessage)

Description copied from interface: EmailDataProvider

Loads content text for given message.

Specified by:

loadContentText in interface EmailDataProvider

Returns:

email content text

persistMessage

public void persistMessage(SendingMessage sendingMessage,
 SendingStatus status)

Description copied from interface: EmailDataProvider

Stores given message with specified status.

Specified by:

persistMessage in interface EmailDataProvider

migrateEmailsToFileStorage

public void migrateEmailsToFileStorage(List<SendingMessage> messages)

Description copied from interface: EmailDataProvider

Migrate list of existing messages to be stored in file storage, in a single transaction.

Specified by:

migrateEmailsToFileStorage in interface EmailDataProvider

migrateAttachmentsToFileStorage

public void migrateAttachmentsToFileStorage(List<SendingAttachment> attachments)

Description copied from interface: EmailDataProvider

Migrate list of existing email attachments to be stored in file storage, in a single transaction.

Specified by:

migrateAttachmentsToFileStorage in interface EmailDataProvider

buildErrorMessage

protected String buildErrorMessage(SendingStatus status)

migrateMessage

protected void migrateMessage(SendingMessage msg)

migrateAttachment

protected void migrateAttachment(SendingAttachment attachment)

shouldMarkNotSent

protected boolean shouldMarkNotSent(SendingMessage sendingMessage)

loadBodyAndAttachments

protected void loadBodyAndAttachments(SendingMessage message)

persistSendingMessage

protected void persistSendingMessage(SendingMessage message,
 EmailDataProviderImpl.MessagePersistingContext context)

createContentFile

protected FileRef createContentFile(@Nullable
 EmailDataProviderImpl.MessagePersistingContext context,
 byte[] bodyBytes,
 String fileName)

getFileName

protected String getFileName(SendingMessage msg)

bodyTextFromByteArray

protected String bodyTextFromByteArray(byte[] bodyContent)

bodyTextToBytes

protected byte[] bodyTextToBytes(SendingMessage message)

removeOrphanFiles

protected void removeOrphanFiles(EmailDataProviderImpl.MessagePersistingContext context)

getFileStorage

protected FileStorage getFileStorage()