ProducerTemplate. Camel. How to add attachment-CodePudding

Can someone tell me how to add an attachment using ProducerTemplate? I have been searching but I can not find an answer to my case.

I am using Camen 2.1 and I have these three clases:

MailSender2.java


import java.util.HashMap;
import java.util.Map;
import java.util.ResourceBundle;

import org.apache.camel.Exchange;
import org.apache.camel.ExchangePattern;
import org.apache.camel.ProducerTemplate;

public class MailSender2 extends TypeMail{

    private static final ResourceBundle RES = ResourceBundle.getBundle("mail");
    protected static final String MAIL_NOTIFICATION_ENDPOINT=RES.getString("mail.host.location").trim() ":" RES.getString("mail.port").trim();

    private Map<String, Object> header;

    public MailSender2() {
        this.header=new HashMap<>();
    }

    public void send(ProducerTemplate template) {
        this.header.put("From", this.getT_from());
        this.header.put("To", this.getT_to());
        this.header.put("Subject", this.getT_subject());
        this.header.put(Exchange.CONTENT_TYPE, "text/html; charset=UTF-8");

        //this.getF_ficher() <-- I have here the file to attach
        //this.getT_ficnon() <-- I have here the name ot the file
        //this.getT_ficext() <-- I have here the extension ot the file

        template.sendBodyAndHeaders(MAIL_NOTIFICATION_ENDPOINT, this.getT_mensaje(), header);
    }

}

TypeMail.java:


public class TypeMail {


    private String t_id;
    private String t_from;
    private String t_to;
    private String t_subject;
    private String t_mensaje;
    private byte[] f_ficher;
    private String t_ficnon;
    private String t_ficext;

    public String getT_id() {
        return t_id;
    }

    public void setT_id(String t_id) {
        this.t_id = t_id;
    }

    public String getT_from() {
        return t_from;
    }

    public void setT_from(String t_from) {
        this.t_from = t_from;
    }

    public String getT_to() {
        return t_to;
    }

    public void setT_to(String t_to) {
        this.t_to = t_to;
    }

    public String getT_subject() {
        return t_subject;
    }

    public void setT_subject(String t_subject) {
        this.t_subject = t_subject;
    }

    public String getT_mensaje() {
        return t_mensaje;
    }

    public void setT_mensaje(String t_mensaje) {
        this.t_mensaje = t_mensaje;
    }

    public byte[] getF_ficher() {
        return f_ficher;
    }

    public void setF_ficher(byte[] f_ficher) {
        this.f_ficher = f_ficher;
    }

    public String getT_ficnon() {
        return t_ficnon;
    }

    public void setT_ficnon(String t_ficnon) {
        this.t_ficnon = t_ficnon;
    }

    public String getT_ficext() {
        return t_ficext;
    }

    public void setT_ficext(String t_ficext) {
        this.t_ficext = t_ficext;
    }
}

MailCommunicationTransformer.java:


import org.apache.camel.CamelContext;
import org.apache.camel.Exchange;
import org.apache.camel.ProducerTemplate;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.ws.soap.client.SoapFaultClientException;

public class MailCommunicationTransformer {

    MailSender2 mailSender = null;

    static Logger logger = LoggerFactory.getLogger(MailCommunicationTransformer.class);


    public MailCommunicationTransformer()
    {
    }

    public MailLog transform(Object actualMessage, Exchange exchange, CamelContext context)
    {

        mailSender = exchange.getIn().getBody(MailSender2.class);
        try {
            MailSenderDAO mailSenderDAO = (MailSenderDAO)context.getRegistry().lookup("MailSenderDAO");
            mailSenderDAO.validarInput(mailSender);

            if (mailSender!=null) {
                ProducerTemplate template=exchange.getContext().createProducerTemplate();
                try {
                    mailSender.send(template);
                }
                catch (Throwable ex) {
                    ex.printStackTrace();
                    exchange.setProperty(Exchange.EXCEPTION_CAUGHT,ex);
                }
            }
        }catch (MailException me) {
            me.printStackTrace();
            exchange.setProperty(Exchange.EXCEPTION_CAUGHT,me);
        }

        Throwable e = exchange.getProperty(Exchange.EXCEPTION_CAUGHT,
                Throwable.class);
        String response = "OK";
        if (e != null) {
            StringBuffer mensaje = new StringBuffer();
            if (e instanceof SoapFaultClientException) {
                mensaje.append("MAIL fault exception: CLIENT. ");
            } else {
                mensaje.append("MAIL fault exception: MAIL. ");
            }
            logger.info("MailCommunicationTransformer",e);
            while (e != null) {
                e.printStackTrace();
                mensaje.append(e.getMessage());
                e = e.getCause();
            }
            response = mensaje.toString();
        }

        MailLog log = new MailLog(mailSender, response); //, protocolo
        return log;
    }
}

In TypeMail I have the file in f_ficher, and the fileName (t_ficnon) and extension (t_ficext), but I can not find how to attach this file in MailSender2 before template.sendBodyAndHeaders(.....)

Any help would be very appreciated. Regards.

CodePudding user response：

Perhaps I don't fully understand your question, but the ProducerTemplate don't know about the message type.

You just send a body and perhaps also headers to an endpoint.

Therefore the body just needs to be a fully constructed MimeMessage object as documented in the Camel Mail docs.

You can simply construct the mail message with Java and then use the object with the ProducerTemplate (what you already do).

template.sendBodyAndHeaders("your-smtp-endpoint", yourMimeMessageInstance, yourHeaderMap);

CodePudding user response：

Thanks for the answer!

But, finally, I could do it this way:

new class EmailProcessor.java

import java.io.File;
import java.io.IOException;
import java.net.URL;
import java.nio.file.Files;
import java.util.Objects;
import java.util.ResourceBundle;

import javax.activation.DataHandler;

import org.apache.camel.Exchange;
import org.apache.camel.Message;
import org.apache.camel.Processor;
import org.apache.commons.codec.binary.Base64;

public class EmailProcessor implements Processor {

    // Atributos de la clase
    private TypeMail typeMail;

    public EmailProcessor(TypeMail typeMail) {
        this.typeMail = typeMail;

    }

    @Override
    public void process(Exchange exchange) throws Exception {

        Message ms = exchange.getIn();
        ms.setHeader("From", this.typeMail.getT_from());
        ms.setHeader("To", this.typeMail.getT_to());
        ms.setHeader("Subject", this.typeMail.getT_subject());
        ms.setHeader(Exchange.CONTENT_TYPE, "text/html; charset=UTF-8");

        ms.setBody("<p style='font-family: Calibri;'>"   this.typeMail.getT_mensaje()   "</p>");

        if (this.typeMail.getF_ficher() != null) {
            String mimeType = "application/pdf";
            if ("zip".equals(typeMail.getT_ficext())) {
                mimeType = "application/zip";
            }
            ms.addAttachment(typeMail.getT_ficnom()   "."   typeMail.getT_ficext(), new DataHandler(typeMail.getF_ficher(), mimeType));
        }
    }

}

MailSender.java:

import java.util.ResourceBundle;

import org.apache.camel.ExchangePattern;
import org.apache.camel.ProducerTemplate;

public class MailSender extends TypeMail{

    private static final ResourceBundle RES = ResourceBundle.getBundle("mail");
    protected static final String MAIL_NOTIFICATION_ENDPOINT=RES.getString("mail.host.location").trim() ":" RES.getString("mail.port").trim();

    public MailSender() {
    }

    public void send(ProducerTemplate template) {

        template.send(MAIL_NOTIFICATION_ENDPOINT, ExchangePattern.InOnly, new EmailProcessor(this));
    }

}