Versand von E-Mails mit Spring Batch

1<bean id="mailSender" class="org.springframework.mail.javamail.JavaMailSenderImpl">
2    <property name="host" value="smtp.yourEmailDomain.de"/>
3    <property name="port" value="25"/>
4    <property name="username" value="yourUserName"/>
5    <property name="password" value="yourPassword"/>
6    <property name="javaMailProperties">
7        <props>
8            <prop key="mail.smtp.auth">true</prop>
9        </props>
10    </property>
11</bean>

1<bean id="sendMailTasklet">
2    <property name="mailSender" ref="mailSender"/>
3    <property name="sendMailService" ref="sendMailService"/>
4    <property name="senderAddress" value="sender@emailaddress.de"/>
5    <property name="recipient" value="recipient@emailaddress.de"/>
6    <property name="attachmentFilePath" value="/path/to/attachment/file/"/>
7</bean>

1package de.batch.tasklets;
2 
3import org.apache.commons.logging.Log;
4import org.apache.commons.logging.LogFactory;
5import org.springframework.batch.core.StepContribution;
6import org.springframework.batch.core.scope.context.ChunkContext;
7import org.springframework.batch.core.step.tasklet.Tasklet;
8import org.springframework.batch.repeat.RepeatStatus;
9import org.springframework.mail.javamail.JavaMailSender;
10 
11import de.batch.mail.SendMailService;
12 
13public class SendMailTasklet implements Tasklet {
14    private static final Log log = LogFactory.getLog(SendMailTasklet.class);
15    private SendMailService sendMailService;
16    private JavaMailSender mailSender;
17    private String senderAddress;
18    private String recipient;
19    private String attachmentFilePath;
20 
21    public void setMailSender(JavaMailSender mailSender) {
22       this.mailSender = mailSender;
23    }
24    public void setSenderAddress(String senderAddress) {
25        this.senderAddress = senderAddress;
26    }
27 
28    public void setRecipient(String recipient) {
29        this.recipient = recipient;
30    }
31 
32    public void setAttachmentFilePath(String attachmentFilePath) {
33        this.attachmentFilePath = attachmentFilePath;
34    }
35 
36    public void setSendMailService(SendMailService sendMailService) {
37        this.sendMailService = sendMailService;
38    }
39 
40    @Override
41    public RepeatStatus execute(StepContribution contribution, ChunkContext chunkContext) throws Exception {
42        log.debug("execute(StepContribution contribution, ChunkContext chunkContext) begin");
43        sendMailService.setFields(mailSender, senderAddress, recipient, attachmentFilePath);
44        sendMailService.sendMail();
45        log.debug("execute(StepContribution contribution, ChunkContext chunkContext) end");
46        return RepeatStatus.FINISHED;
47    }
48}

1<bean id="sendMailService" class="de.batch.mail.SendMailService" />

1package de.batch.mail;
2 
3import java.io.File;
4import javax.ejb.Stateless;
5import javax.mail.Message;
6import javax.mail.internet.InternetAddress;
7import javax.mail.internet.MimeMessage;
8 
9import org.apache.commons.logging.Log;
10import org.apache.commons.logging.LogFactory;
11import org.jboss.seam.annotations.Name;
12import org.springframework.core.io.FileSystemResource;
13import org.springframework.mail.MailException;
14import org.springframework.mail.javamail.JavaMailSender;
15import org.springframework.mail.javamail.MimeMessageHelper;
16import org.springframework.mail.javamail.MimeMessagePreparator;
17 
18public class SendMailService {
19 
20    private static final Log log = LogFactory.getLog(SendMailService.class);
21    private JavaMailSender mailSender;
22    private String senderAddress;
23    private String recipient;
24    private String attachmentFilePath;
25 
26    // set the fields
27    public void setFields(JavaMailSender mailSender, String senderAddress, String recipient, String attachmentFilePath) {
28 
29        this.mailSender = mailSender;
30        this.senderAddress = senderAddress;
31        this.recipient = recipient;
32        this.attachmentFilePath = attachmentFilePath;
33    }
34 
35    public void sendMail() {
36        log.debug("send Email started");
37        // read directory
38        File directory = new File(attachmentFilePath);
39        // get file from directory
40        final File file = directory.listFiles(FILE_FILTER)[0];
41 
42        MimeMessagePreparator preparator = new MimeMessagePreparator() {
43            public void prepare(MimeMessage mimeMessage) throws Exception {
44                mimeMessage.setRecipient(Message.RecipientType.TO, new InternetAddress(recipient));
45                mimeMessage.setFrom(new InternetAddress(senderAddress));
46                mimeMessage.setSubject("Neuer Report");
47                // MimeMessagesHelper is needed for the attachment. The Boolean value in
48                // constructor is for multipart/data = true
49                MimeMessageHelper helper = new MimeMessageHelper(mimeMessage, true);
50                helper.addAttachment(file.getName(), new FileSystemResource(file));
51                helper.setText("Text in Email Body");
52            }
53        };
54        try {
55            this.mailSender.send(preparator);
56            log.debug("send Email completed");
57        } catch (MailException ex) {
58            log.debug("send Email failed", ex);
59        }
60    }
61 
62    public static FileFilter FILE_FILTER = new FileFilter() {
63        public boolean accept(File file) {
64            return !file.isDirectory();
65        }
66    };
67 }

1<batch:job id="sendMailJob" restartable="false">
2  <batch:step id="sendMailStep">
3    <batch:tasklet ref="sendMailTasklet" />
4  </batch:step>
5</batch:job>