root
/
spring-boot
mirror of https://github.com/spring-projects/spring-boot.git
1
0
Fork 0
Code Issues Actions 12 Packages Projects Releases Wiki Activity

Avoid duplicate script 

This commit avoids a script duplication: the integration test runs the
sample instead of a copy of it in the repro directory.

Also switched the sample from ActiveMQ to HornetQ as #323 revealed
some locking on CI. Hopefully that should fix it as HornetQ is non
persistent and can be embedded several times in the same VM.

Fixes gh-1456
This commit is contained in:
Stephane Nicoll 2014-08-29 10:26:29 +02:00
parent 0dc389f5b3
commit 85c95744f9
4 changed files with 10 additions and 44 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
spring-boot-cli/samples/jms.groovy
View File

@ -1,10 +1,12 @@
package org.test
@Grab("org.apache.activemq:activemq-all:5.4.0")
@Grab("activemq-pool")
@Grab("spring-boot-starter-hornetq")
@Grab("hornetq-jms-server")
import java.util.concurrent.CountDownLatch
import org.hornetq.jms.server.config.impl.JMSQueueConfigurationImpl
@Log
@Configuration
@EnableJms
class JmsExample implements CommandLineRunner {
@ -15,7 +17,7 @@ class JmsExample implements CommandLineRunner {
void run(String... args) {
def messageCreator = { session ->
session.createObjectMessage("Greetings from Spring Boot via ActiveMQ")
session.createObjectMessage("Greetings from Spring Boot via HornetQ")
} as MessageCreator
log.info "Sending JMS message..."
jmsTemplate.send("spring-boot", messageCreator)
@ -29,4 +31,8 @@ class JmsExample implements CommandLineRunner {
latch.countDown()
}
@Bean JMSQueueConfigurationImpl springBootQueue() {
new JMSQueueConfigurationImpl('spring-boot', null, false)
}
}

5
spring-boot-cli/src/test/java/org/springframework/boot/cli/ReproIntegrationTests.java
View File

@ -73,10 +73,5 @@ public class ReproIntegrationTests {
this.cli.jar("secure.groovy", "crsh.groovy");
}
@Test
public void jmsListener() throws Exception {
this.cli.run("jms.groovy");
assertThat(this.cli.getOutput(), containsString("Hello World"));
}
}

4
spring-boot-cli/src/test/java/org/springframework/boot/cli/SampleIntegrationTests.java
View File

@ -136,12 +136,10 @@ public class SampleIntegrationTests {
}
@Test
@Ignore("Intermittent failure on CI. See #323")
public void jmsSample() throws Exception {
String output = this.cli.run("jms.groovy");
assertTrue("Wrong output: " + output,
output.contains("Received Greetings from Spring Boot via ActiveMQ"));
FileUtils.deleteDirectory(new File("activemq-data"));// cleanup ActiveMQ cruft
output.contains("Received Greetings from Spring Boot via HornetQ"));
}
@Test

33
spring-boot-cli/src/test/resources/repro-samples/jms.groovy
View File

@ -1,33 +0,0 @@
package org.test
@Grab("org.apache.activemq:activemq-all:5.4.0")
@Grab("activemq-pool")
import java.util.concurrent.CountDownLatch
@Log
@EnableJms
class SampleJmsListener implements CommandLineRunner {
private CountDownLatch latch = new CountDownLatch(1)
@Autowired
JmsTemplate jmsTemplate
void run(String... args) {
def messageCreator = { session ->
session.createObjectMessage("Hello World")
} as MessageCreator
log.info "Sending JMS message..."
jmsTemplate.send("testQueue", messageCreator)
log.info "Sent JMS message, waiting..."
latch.await()
}
@JmsListener(destination = 'testQueue')
def receive(String message) {
log.info "Received ${message}"
latch.countDown()
}
}