2016-09-17 9 views
1

Ich benutze activemq und spring jms. Ich habe ein Problem.Spring jms activemq

Das ist mein EmailSender

@Service 
@PropertySource("classpath:/properties/dev/application.properties") 
public class EmailSenderImpl implements EmailSender { 
    private static final Logger LOGGER = LoggerFactory.getLogger(EmailSenderImpl.class); 

    @Autowired 
    private JmsTemplate jmsTemplate; 

    @Autowired 
    private Environment env; 

    @Override 
    public void sendEmail(final Users user, EmailCauses emailCause) { 
     LOGGER.debug("Sending email to user with id {} with cause {}", user.getId(), emailCause); 

     //Retrieve User profile which defined with lazy fetch type. 
     //It prevents org.hibernate.LazyInitializationException in jms message receiver method 
     user.getUserProfile(); 

     jmsTemplate.send(env.getProperty(emailCause.getEmailQueueName()), 
       new MessageCreator() { 

        @Override 
        public Message createMessage(Session session) throws JMSException { 
         return session.createObjectMessage(user); 
        } 
       } 
     ); 
    } 

Das ist mein EmailHandler ist.

@Service 
public class EmailHandler { 
    private static final Logger LOGGER = LoggerFactory.getLogger(EmailHandler.class); 

    private JavaMailSender mailSender; 
    private VelocityEngine velocityEngine; 
    private MessageSource messageSource; 


    @Autowired 
    public EmailHandler (JavaMailSender mailSender, VelocityEngine velocityEngine, MessageSource messageSource) { 

     this.mailSender = mailSender; 
     this.velocityEngine = velocityEngine; 
     this.messageSource = messageSource; 
    } 


    //TODO - refactor method, add reserve server 
    @Transactional 
    public void processEmailNotifications (Users user) throws MessagingException, UnsupportedEncodingException { 
     LOGGER.debug("Preparing to send greeting email to user {}", user); 

     UserProfiles userProfile = user.getUserProfile(); 

     Map <String, Object> model = new HashMap <>(); 
     model.put("name", userProfile.getName()); 
     model.put("patronymic", userProfile.getPatronymic()); 
     model.put("token", UriUtils.encode(user.getConfirmationToken(), "UTF8")); 

     String email = user.getUserProfile().getEmail(); 
     sendEmail(email, "email.wellcome.subject", model, "wellcome_email.vm"); 

    } 
    private void sendEmail (String emailTo, String subjectMessage, Map<String, Object> model, String templateName) { 
     LOGGER.debug("Sending email to {} with subject message {}", emailTo, subjectMessage); 

     try { 

      MimeMessage message = mailSender.createMimeMessage(); 
      MimeMessageHelper helper = new MimeMessageHelper (message, true, "UTF-8"); 

      helper.setTo(emailTo); 
      helper.setSubject(messageSource.getMessage(subjectMessage, null, Locale.getDefault())); 

      String emailText = VelocityEngineUtils.mergeTemplateIntoString(velocityEngine, templateName, "UTF-8", model); 
      helper.setText(emailText, true); 

      mailSender.send(message); 
      LOGGER.info("Email to address {} with subject {} was sent successfully", emailTo, subjectMessage); 

     } catch (MessagingException me) { 
      LOGGER.error("Email to address {} was not sent", emailTo, me); 

     } 

    } 

Es gibt folgende Anmeldung in meinem Stack-Trace. Ich verstehe nicht, warum es nicht funktioniert.

osjms.core.JmsTemplate - Executing Rückruf bei JMS Session: ActiveMQSession {id = ID: igor-Aspire-5820TG-33061-1474030841626-1: 7: 1, gestartet = false} 2016- 09-16 16: 02: 40.871 - [http-bio-8080-exec-6] [DEBUG] osjms.core.JmsTemplate - Senden einer erstellten Nachricht: ActiveMQTextMessage {commandId = 0, responseRequired = false, messageId = null , originalDestination = null, originalTransactionId = null, producerId = null, destination = null, transactionId = null, expiration = 0, timestamp = 0, ankunft = 0, brokerInTime = 0, brokerOutTime = 0, correlationId = null, replyTo = null, persistent = false, typ = null, priorität = 0, groupID = null, groupSequence = 0, targetConsumerId = null, komprimiert = false, benutzerID = null, content = null, marshalledProperties = null , Datenstruktur = null, redeliveryCounter = 0, size = 0, Eigenschaften = null, readOnlyProperties = false, readOnlyBody = false, abwerfbaren = false, text = xDDD}

Antwort

0

können Sie andere Protokolle und JmsTemplate Setup Config schreiben Da die Sitzung nicht auf Ihren Protokollen und Producer, MessageID und Ziel gestartet wird ... sind die Informationen Null

Verwandte Themen