Apache
/
activemq
mirror of https://github.com/apache/activemq.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

remove println 

git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@560700 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Robert Davies 2007-07-29 08:59:46 +00:00
parent 13729a3690
commit eeb8d5bafc
1 changed files with 1 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
activemq-core/src/test/java/org/apache/activemq/network/SimpleNetworkTest.java
View File

@ -61,7 +61,6 @@ public class SimpleNetworkTest extends TestCase{
public void testRequestReply() throws Exception{ public void testRequestReply() throws Exception{
System.err.println("START TEST!");
final MessageProducer remoteProducer=remoteSession.createProducer(null); final MessageProducer remoteProducer=remoteSession.createProducer(null);
MessageConsumer remoteConsumer=remoteSession.createConsumer(included); MessageConsumer remoteConsumer=remoteSession.createConsumer(included);
remoteConsumer.setMessageListener(new MessageListener(){ remoteConsumer.setMessageListener(new MessageListener(){
@ -82,14 +81,13 @@ public class SimpleNetworkTest extends TestCase{
}); });
TopicRequestor requestor=new TopicRequestor((TopicSession) localSession,included); TopicRequestor requestor=new TopicRequestor((TopicSession) localSession,included);
Thread.sleep(2000);//alow for consumer infos to perculate arround Thread.sleep(2000);//allow for consumer infos to perculate arround
for (int i =0;i < MESSAGE_COUNT; i++){ for (int i =0;i < MESSAGE_COUNT; i++){
TextMessage msg = localSession.createTextMessage("test msg: " +i); TextMessage msg = localSession.createTextMessage("test msg: " +i);
TextMessage result = (TextMessage) requestor.request(msg); TextMessage result = (TextMessage) requestor.request(msg);
assertNotNull(result); assertNotNull(result);
log.info(result.getText()); log.info(result.getText());
} }
System.err.println("FIN TEST!");
} }
public void XtestFiltering() throws Exception{ public void XtestFiltering() throws Exception{
@ -104,7 +102,6 @@ public class SimpleNetworkTest extends TestCase{
excludedProducer.send(test); excludedProducer.send(test);
assertNull(excludedConsumer.receive(500)); assertNull(excludedConsumer.receive(500));
assertNotNull(includedConsumer.receive(500)); assertNotNull(includedConsumer.receive(500));
System.err.println("FIN TEST!");
} }
public void XtestConduitBridge() throws Exception{ public void XtestConduitBridge() throws Exception{