[jboss-cvs] JBossRemoting/src/tests/org/jboss/test/remoting/transporter/proxy/local ...
Tom Elrod
tom.elrod at jboss.com
Fri Aug 11 16:31:13 EDT 2006
User: telrod
Date: 06/08/11 16:31:13
Added: src/tests/org/jboss/test/remoting/transporter/proxy/local
Client.java DateConsumer.java DateConsumerImpl.java
DateProcessor.java DateProcessorImpl.java
Server.java TransporterProxyLocalTestCase.java
Log:
JBREM-575 - adding test case for sending transporter client (even when is local remote client) to server to be called upon.
Revision Changes Path
1.1 date: 2006/08/11 20:31:13; author: telrod; state: Exp;JBossRemoting/src/tests/org/jboss/test/remoting/transporter/proxy/local/Client.java
Index: Client.java
===================================================================
/***************************************
* *
* JBoss: The OpenSource J2EE WebOS *
* *
* Distributable under LGPL license. *
* See terms of license at gnu.org. *
* *
***************************************/
package org.jboss.test.remoting.transporter.proxy.local;
import junit.framework.TestCase;
import org.jboss.remoting.transporter.TransporterClient;
import org.jboss.remoting.transporter.TransporterServer;
/**
* @author <a href="mailto:tom at jboss.org">Tom Elrod</a>
*/
public class Client extends TestCase
{
private TransporterServer server;
private DateProcessor dateProcessor;
public void setUp() throws Exception
{
server = TransporterServer.createTransporterServer("socket://localhost:5400", new DateProcessorImpl(), DateProcessor.class.getName());
dateProcessor = (DateProcessor) TransporterClient.createTransporterClient("socket://localhost:5400", DateProcessor.class);
}
public void testDateFormatting() throws Exception
{
DateConsumer consumer = (DateConsumer) TransporterClient.createTransporterClient("socket://localhost:5401", DateConsumer.class);
String response = consumer.consumeDate(dateProcessor);
System.out.println("Response from date consumer is " + response);
assertTrue("The DateProcessor within this jvm should have been called to format date and was not.", DateProcessorImpl.formatDateCalled);
}
public void tearDown()
{
if (dateProcessor != null)
{
TransporterClient.destroyTransporterClient(dateProcessor);
}
if (server != null)
{
server.stop();
}
}
public static void main(String[] args)
{
try
{
Client client = new Client();
client.setUp();
client.testDateFormatting();
client.tearDown();
}
catch (Exception e)
{
e.printStackTrace();
}
}
}
1.1 date: 2006/08/11 20:31:13; author: telrod; state: Exp;JBossRemoting/src/tests/org/jboss/test/remoting/transporter/proxy/local/DateConsumer.java
Index: DateConsumer.java
===================================================================
/***************************************
* *
* JBoss: The OpenSource J2EE WebOS *
* *
* Distributable under LGPL license. *
* See terms of license at gnu.org. *
* *
***************************************/
package org.jboss.test.remoting.transporter.proxy.local;
/**
* @author <a href="mailto:tom at jboss.org">Tom Elrod</a>
*/
public interface DateConsumer
{
public String consumeDate(DateProcessor dateProcessor);
}
1.1 date: 2006/08/11 20:31:13; author: telrod; state: Exp;JBossRemoting/src/tests/org/jboss/test/remoting/transporter/proxy/local/DateConsumerImpl.java
Index: DateConsumerImpl.java
===================================================================
/***************************************
* *
* JBoss: The OpenSource J2EE WebOS *
* *
* Distributable under LGPL license. *
* See terms of license at gnu.org. *
* *
***************************************/
package org.jboss.test.remoting.transporter.proxy.local;
import java.util.Date;
/**
* @author <a href="mailto:tom at jboss.org">Tom Elrod</a>
*/
public class DateConsumerImpl implements DateConsumer
{
public String consumeDate(DateProcessor dateProcessor)
{
Date currentDate = new Date();
String formattedDate = dateProcessor.formatDate(currentDate);
System.out.println("called on date processor to format date. response is " + formattedDate);
return formattedDate;
}
}
1.1 date: 2006/08/11 20:31:13; author: telrod; state: Exp;JBossRemoting/src/tests/org/jboss/test/remoting/transporter/proxy/local/DateProcessor.java
Index: DateProcessor.java
===================================================================
/***************************************
* *
* JBoss: The OpenSource J2EE WebOS *
* *
* Distributable under LGPL license. *
* See terms of license at gnu.org. *
* *
***************************************/
package org.jboss.test.remoting.transporter.proxy.local;
import java.util.Date;
/**
* @author <a href="mailto:telrod at e2technologies.net">Tom Elrod</a>
*/
public interface DateProcessor
{
public String formatDate(Date dateToConvert);
}
1.1 date: 2006/08/11 20:31:13; author: telrod; state: Exp;JBossRemoting/src/tests/org/jboss/test/remoting/transporter/proxy/local/DateProcessorImpl.java
Index: DateProcessorImpl.java
===================================================================
/***************************************
* *
* JBoss: The OpenSource J2EE WebOS *
* *
* Distributable under LGPL license. *
* See terms of license at gnu.org. *
* *
***************************************/
package org.jboss.test.remoting.transporter.proxy.local;
import java.text.DateFormat;
import java.util.Date;
/**
* @author <a href="mailto:tom at jboss.org">Tom Elrod</a>
*/
public class DateProcessorImpl
{
public static boolean formatDateCalled = false;
public String formatDate(Date dateToConvert)
{
DateFormat dateFormat = DateFormat.getDateInstance(DateFormat.MEDIUM);
System.out.println("Sending back to caller formated date of " + dateFormat);
formatDateCalled = true;
return dateFormat.format(dateToConvert);
}
}
1.1 date: 2006/08/11 20:31:13; author: telrod; state: Exp;JBossRemoting/src/tests/org/jboss/test/remoting/transporter/proxy/local/Server.java
Index: Server.java
===================================================================
/***************************************
* *
* JBoss: The OpenSource J2EE WebOS *
* *
* Distributable under LGPL license. *
* See terms of license at gnu.org. *
* *
***************************************/
package org.jboss.test.remoting.transporter.proxy.local;
import org.jboss.jrunit.extensions.ServerTestCase;
import org.jboss.remoting.transporter.TransporterServer;
/**
* @author <a href="mailto:tom at jboss.org">Tom Elrod</a>
*/
public class Server extends ServerTestCase
{
private TransporterServer server;
public void setUp() throws Exception
{
server = TransporterServer.createTransporterServer("socket://localhost:5401", new DateConsumerImpl(), DateConsumer.class.getName());
}
public void tearDown()
{
if (server != null)
{
server.stop();
}
}
public static void main(String[] args)
{
Server svr = new Server();
try
{
svr.setUp();
Thread.currentThread().sleep(6000000);
svr.tearDown();
}
catch (Exception e)
{
e.printStackTrace();
}
}
}
1.1 date: 2006/08/11 20:31:13; author: telrod; state: Exp;JBossRemoting/src/tests/org/jboss/test/remoting/transporter/proxy/local/TransporterProxyLocalTestCase.java
Index: TransporterProxyLocalTestCase.java
===================================================================
/***************************************
* *
* JBoss: The OpenSource J2EE WebOS *
* *
* Distributable under LGPL license. *
* See terms of license at gnu.org. *
* *
***************************************/
package org.jboss.test.remoting.transporter.proxy.local;
import org.jboss.jrunit.harness.TestDriver;
/**
* @author <a href="mailto:tom at jboss.org">Tom Elrod</a>
*/
public class TransporterProxyLocalTestCase extends TestDriver
{
public void declareTestClasses()
{
addTestClasses(Client.class.getName(),
1,
Server.class.getName());
}
}
More information about the jboss-cvs-commits
mailing list