File tree Expand file tree Collapse file tree 3 files changed +3
-13
lines changed
main/java/xpadro/spring/jms
test/java/xpadro/spring/jms Expand file tree Collapse file tree 3 files changed +3
-13
lines changed Original file line number Diff line number Diff line change 11package xpadro .spring .jms ;
22
3- import javax .jms .ConnectionFactory ;
4-
5- import org .apache .activemq .ActiveMQConnectionFactory ;
63import org .springframework .boot .SpringApplication ;
74import org .springframework .boot .autoconfigure .SpringBootApplication ;
8- import org .springframework .context .annotation .Bean ;
95
106@ SpringBootApplication
117public class JmsJavaconfigApplication {
12- private static final String JMS_BROKER_URL = "vm://embedded?broker.persistent=false,useShutdownHook=false" ;
13-
14- @ Bean
15- public ConnectionFactory connectionFactory () {
16- return new ActiveMQConnectionFactory (JMS_BROKER_URL );
17- }
188
199 public static void main (String [] args ) {
2010 SpringApplication .run (JmsJavaconfigApplication .class , args );
Original file line number Diff line number Diff line change 1010import org .springframework .boot .test .SpringApplicationConfiguration ;
1111import org .springframework .test .context .junit4 .SpringJUnit4ClassRunner ;
1212
13- import xpadro .spring .jms .JmsJavaconfigApplication ;
1413import xpadro .spring .jms .model .Order ;
1514import xpadro .spring .jms .service .ClientService ;
1615import xpadro .spring .jms .service .RegisterService ;
Original file line number Diff line number Diff line change 1010import org .springframework .boot .test .SpringApplicationConfiguration ;
1111import org .springframework .test .context .junit4 .SpringJUnit4ClassRunner ;
1212
13- import xpadro .spring .jms .JmsJavaconfigApplication ;
1413import xpadro .spring .jms .model .Order ;
1514import xpadro .spring .jms .service .ClientService ;
1615import xpadro .spring .jms .service .StoreService ;
1716
17+
1818@ RunWith (SpringJUnit4ClassRunner .class )
1919@ SpringApplicationConfiguration (classes = JmsJavaconfigApplication .class )
2020public class SimpleListenerTest {
@@ -26,8 +26,9 @@ public class SimpleListenerTest {
2626 private StoreService storeService ;
2727
2828 @ Test
29- public void sendSimpleMessage () {
29+ public void sendSimpleMessage () throws InterruptedException {
3030 clientService .addOrder (new Order ("order1" ));
31+ Thread .sleep (500 );
3132
3233 Optional <Order > storedOrder = storeService .getReceivedOrder ("order1" );
3334 Assert .assertTrue (storedOrder .isPresent ());
You can’t perform that action at this time.
0 commit comments