Rename EndToEnd tests to comply with naming requirements; add stream as a test dependency to ivy.xml

This commit is contained in:
Gary Russell
2010-02-12 21:13:37 +00:00
parent e6d1b2f9c3
commit ed94631288
3 changed files with 11 additions and 10 deletions

View File

@@ -47,7 +47,7 @@ import org.springframework.integration.message.StringMessage;
* @author Gary Russell
* @since 2.0
*/
public class TestIpMulticastEndToEnd implements Runnable {
public class UdpMulticastEndToEndTests implements Runnable {
private String testingIpText;
@@ -67,12 +67,12 @@ public class TestIpMulticastEndToEnd implements Runnable {
@Test
@Ignore
public void runIt() throws Exception {
TestIpMulticastEndToEnd launcher = new TestIpMulticastEndToEnd();
UdpMulticastEndToEndTests launcher = new UdpMulticastEndToEndTests();
Thread t = new Thread(launcher);
t.start(); // launch the receiver
AbstractApplicationContext applicationContext = new ClassPathXmlApplicationContext(
"testIp-out-multicast-context.xml",
TestIpMulticastEndToEnd.class);
UdpMulticastEndToEndTests.class);
launcher.launchSender(applicationContext);
applicationContext.stop();
}
@@ -113,7 +113,7 @@ public class TestIpMulticastEndToEnd implements Runnable {
public void run() {
AbstractApplicationContext ctx = new ClassPathXmlApplicationContext(
"testIp-in-multicast-context.xml",
TestIpMulticastEndToEnd.class);
UdpMulticastEndToEndTests.class);
while (okToRun) {
try {
sentFirst.await();
@@ -139,7 +139,7 @@ public class TestIpMulticastEndToEnd implements Runnable {
public static void main(String[] args) throws Exception {
hangAroundFor = 120000;
new TestIpMulticastEndToEnd().runIt();
new UdpMulticastEndToEndTests().runIt();
}
}

View File

@@ -47,7 +47,7 @@ import org.springframework.integration.message.StringMessage;
* @author Gary Russell
* @since 2.0
*/
public class TestIpEndToEnd implements Runnable {
public class UdpUnicastEndToEndTests implements Runnable {
private String testingIpText;
@@ -66,10 +66,10 @@ public class TestIpEndToEnd implements Runnable {
@Test
public void runIt() throws Exception {
TestIpEndToEnd launcher = new TestIpEndToEnd();
UdpUnicastEndToEndTests launcher = new UdpUnicastEndToEndTests();
Thread t = new Thread(launcher);
t.start(); // launch the receiver
AbstractApplicationContext applicationContext = new ClassPathXmlApplicationContext("testIp-out-context.xml", TestIpEndToEnd.class);
AbstractApplicationContext applicationContext = new ClassPathXmlApplicationContext("testIp-out-context.xml", UdpUnicastEndToEndTests.class);
launcher.launchSender(applicationContext);
applicationContext.stop();
}
@@ -108,7 +108,7 @@ public class TestIpEndToEnd implements Runnable {
* Instantiate the receiving context
*/
public void run() {
AbstractApplicationContext ctx = new ClassPathXmlApplicationContext("testIp-in-context.xml", TestIpEndToEnd.class);
AbstractApplicationContext ctx = new ClassPathXmlApplicationContext("testIp-in-context.xml", UdpUnicastEndToEndTests.class);
while (okToRun) {
try {
sentFirst.await();
@@ -134,7 +134,7 @@ public class TestIpEndToEnd implements Runnable {
public static void main(String[] args) throws Exception {
hangAroundFor = 120000;
new TestIpEndToEnd().runIt();
new UdpUnicastEndToEndTests().runIt();
}
}