1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19 package com.hack23.cia.service.component.agent.impl.common.jms;
20
21 import java.io.Serializable;
22
23 import javax.jms.Destination;
24 import javax.jms.JMSException;
25
26 import org.springframework.beans.factory.annotation.Autowired;
27 import org.springframework.jms.core.JmsTemplate;
28 import org.springframework.stereotype.Service;
29 import org.springframework.transaction.annotation.Propagation;
30 import org.springframework.transaction.annotation.Transactional;
31
32
33
34
35 @Service
36 @Transactional(propagation = Propagation.REQUIRED)
37 final class JmsSenderImpl implements JmsSender {
38
39
40 @Autowired
41 private JmsTemplate jmsTemplate;
42
43 @Override
44 public void send(final Destination destination, final Serializable msg) throws JMSException {
45 jmsTemplate.send(destination, new ProducerMessageFactory(msg));
46
47 }
48
49 }