iSharkFly-Docs/java-tutorials
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Fix spring-jms

Browse Source
This commit is contained in:
Grzegorz Piwowarek 2016-10-11 09:54:18 +02:00
parent ea37b3e51a
commit e7ea2e1d2b
2 changed files with 9 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
spring-jms/src/main/java/com/baeldung/spring/jms/SampleJmsMessageSender.java
View File

@ -24,6 +24,10 @@ public class SampleJmsMessageSender {
} }
public void sendMessage(final Employee employee) { public void sendMessage(final Employee employee) {
System.out.println("Jms Message Sender : " + employee);
Map<String, Object> map = new HashMap<>();
map.put("name", employee.getName());
map.put("age", employee.getAge());
this.jmsTemplate.convertAndSend(map); this.jmsTemplate.convertAndSend(map);
} }
} }

13
spring-jms/src/main/resources/EmbeddedActiveMQ.xml
View File

@ -1,15 +1,12 @@
<?xml version="1.0" encoding="UTF-8"?> <?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans" <beans xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:p="http://www.springframework.org/schema/p" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:p="http://www.springframework.org/schema/p"
xmlns:aop="http://www.springframework.org/schema/aop" xmlns:context="http://www.springframework.org/schema/context" xmlns:amq="http://activemq.apache.org/schema/core"
xmlns:jee="http://www.springframework.org/schema/jee" xmlns:tx="http://www.springframework.org/schema/tx" xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd http://activemq.apache.org/schema/core
xmlns:util="http://www.springframework.org/schema/util" xmlns:task="http://www.springframework.org/schema/task" http://activemq.apache.org/schema/core/activemq-core-5.2.0.xsd">
xmlns:amq="http://activemq.apache.org/schema/core"
xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop.xsd http://activemq.apache.org/schema/core
http://activemq.apache.org/schema/core/activemq-core-5.2.0.xsd http://www.springframework.org/schema/util http://www.springframework.org/schema/util/spring-util.xsd">
<!-- Embedded ActiveMQ Broker --> <!-- Embedded ActiveMQ Broker -->
<amq:broker id="broker" useJmx="false" persistent="false" useShutdownHook="false"> <amq:broker id="broker" useJmx="false" persistent="false">
<amq:transportConnectors> <amq:transportConnectors>
<amq:transportConnector uri="tcp://localhost:61616" /> <amq:transportConnector uri="tcp://localhost:61616" />
</amq:transportConnectors> </amq:transportConnectors>