Spring integration DSL在Java1.7中创建邮件出站通道适配器

Question

@MessagingGateway
interface MailGateWay{
@Gateway(requestChannel = "fromChannel")
public void sendMail(MessageDto msgDto) ;
}

@Bean
public QueueChannel fromChannel(){
    return new QueueChannel();
}

@Bean
public JavaMailSenderImpl mailSender() {
    JavaMailSenderImpl mail = new JavaMailSenderImpl();
    Properties javaMailProperties = new Properties();
    mail.setHost(host);
    mail.setPort(port);
    mail.setUsername(username);
    mail.setPassword(password);
    mail.setDefaultEncoding("UTF-8");
    javaMailProperties.setProperty("mail.transport.protocol", "smtp");
    javaMailProperties.setProperty("mail.smtp.auth", String.valueOf(true));
    javaMailProperties.setProperty("mail.smtp.starttls.enable", String.valueOf(false));
    javaMailProperties.setProperty("mail.debug", String.valueOf(true));
    mail.setJavaMailProperties(javaMailProperties);
    return mail;
}

Now my Transfrmer looks loke this, I have created a transformer bean in my dsl

@Bean
@Scope("prototype")
public MailMessageTransformer mailTransformer(){
    return new MailMessageTransformer();
}

@Bean
public QueueChannel outboundMailChannel(){
    return new QueueChannel();
}

public class MailMessageTransformer {

@Autowired
private JavaMailSender mailSender;

public MimeMessage transform(final MessageDto mailDto) {        

    if (mailDto == null) {
        return null;
    }

    if (mailDto.getEncoding() == null) {
        mailDto.setEncoding(IMailConstants.DEFAULT_ENCODING);
    }       

    mailDto.setText(mailDto.getText().replaceAll(System.lineSeparator(), IMailConstants.HTML_NEW_LINE));

    MimeMessage mimeMessage = null;
    try {
        mimeMessage = mailSender.createMimeMessage();
        MimeMessageHelper message = new MimeMessageHelper(mimeMessage);
        message.setTo(mailDto.getTo());
        message.setFrom(mailDto.getFrom());
        message.setSubject(mailDto.getSubject());
        message.setText(getMailContent(mailDto), IMailConstants.TRUE);
        message.setSentDate(new Date(System.currentTimeMillis()));


        if (null != mailDto.getBcc()) {
            message.setBcc(mailDto.getBcc());
        }
        if (null != mailDto.getBcc()) {
            message.setCc(mailDto.getCc());
        }
        if (null != mailDto.getReplyTo() && !mailDto.getReplyTo().isEmpty()) {
            message.setReplyTo(mailDto.getReplyTo());
        }

    }
    catch (MessagingException msgex) {
        LOG.error("MailMessageTransformer.transformMime.Exception::: MessagingException", msgex);

    }
     catch (MailException mailex) {
            LOG.error("MailMessageTransformer.transformMime.Exception::: MailException ", mailex);

        }

    catch (Exception ex) {
        LOG.error("MailMessageTransformer.transformMime.Exception::: Exception", ex);

    }

    LOG.debug("MailMessageTransformer.transformMime.mimeMessage:::" + mimeMessage);
    return mimeMessage;
}
}

<int:transformer input-channel="fromChannel"
output-channel="outboundMailChannel" ref="mailTransformer" method="transform">
<int:poller fixed-rate="6000" max-messages-per-poll="10" />

<int-mail:outbound-channel-adapter
    channel="outboundMailChannel" mail-sender="mailSender" />

流是Gateway-->RequsetChannel-->Transform-->OutboundMailChannl-->MailSender（MailAdapter）

Answer 1

对不起，你的问题不是很清楚。更重要的是，您没有显示流定义。加上你的自定义变压器。

另一方面，您总是可以将.transform()用于任何自定义转换器实现，该实现指定为@bean，甚至类似于private方法来返回其实例。DSL将关注CTX中的bean种群。

请注意，DSL提供了邮件通信所需的一切。

还有一点。不要忘记，您甚至可以用@requestmapping标记@gateway方法，以绕过controller级别。

对不起，我真的不知道该怎么帮你...

更新

查看您的代码，我真的没有看到任何问题，除非我没有看到在MailMessageTransformer@bean中使用@scope（“prototype”）的原因。

@Bean
public IntegrationFlow emailFlow() {
    return IntegrationFlows
            .from(fromChannel())
            .transform(mailTransformer(),
                new Consumer<GenericEndpointSpec<MessageTransformingHandler>>() {

                    @Override
                    public void accept(GenericEndpointSpec<MessageTransformingHandler> spec) {
                        spec.poller(Pollers.fixedRate(6000).maxMessagesPerPoll(10));
                    }

            })
            .handle(new MailSendingMessageHandler(this.mailSender))
            .get();
    }