svn commit: r437083 - /jakarta/jcs/trunk/src/test/org/apache/jcs/auxiliary/remote/server/BasicRemoteCacheClientServerUnitTest.java

Author: asmuts
Date: Fri Aug 25 21:59:44 2006
New Revision: 437083

URL: http://svn.apache.org/viewvc?rev=437083&view=rev
Log:
adding unit test

Modified:
    
jakarta/jcs/trunk/src/test/org/apache/jcs/auxiliary/remote/server/BasicRemoteCacheClientServerUnitTest.java

Modified: 
jakarta/jcs/trunk/src/test/org/apache/jcs/auxiliary/remote/server/BasicRemoteCacheClientServerUnitTest.java
URL: 
http://svn.apache.org/viewvc/jakarta/jcs/trunk/src/test/org/apache/jcs/auxiliary/remote/server/BasicRemoteCacheClientServerUnitTest.java?rev=437083&r1=437082&r2=437083&view=diff
==============================================================================
--- 
jakarta/jcs/trunk/src/test/org/apache/jcs/auxiliary/remote/server/BasicRemoteCacheClientServerUnitTest.java
 (original)
+++ 
jakarta/jcs/trunk/src/test/org/apache/jcs/auxiliary/remote/server/BasicRemoteCacheClientServerUnitTest.java
 Fri Aug 25 21:59:44 2006
@@ -13,6 +13,7 @@
 
 import org.apache.jcs.auxiliary.AuxiliaryCache;
 import org.apache.jcs.auxiliary.remote.RemoteCacheAttributes;
+import org.apache.jcs.auxiliary.remote.RemoteCacheListenerMockImpl;
 import org.apache.jcs.auxiliary.remote.RemoteCacheManager;
 import org.apache.jcs.engine.CacheElement;
 import org.apache.jcs.engine.behavior.ICacheElement;
@@ -27,6 +28,16 @@
 public class BasicRemoteCacheClientServerUnitTest
     extends TestCase
 {
+    RemoteCacheServer server = null;
+
+    /**
+     * Starts the server. This is not in a setup, since the server is slow to 
kill right now.
+     */
+    public BasicRemoteCacheClientServerUnitTest()
+    {
+        String configFile = "TestRemoteCacheClientServer.ccf";
+        server = RemoteCacheServerStartupUtil.startServerUsingProperties( 
configFile );
+    }
 
     /**
      * Verify that we can start the remote cache server. Send an item to the 
remote. Verify that the
@@ -44,9 +55,6 @@
         throws Exception
     {
         // SETUP
-        String configFile = "TestRemoteCacheClientServer.ccf";
-        RemoteCacheServer server = 
RemoteCacheServerStartupUtil.startServerUsingProperties( configFile );
-
         CompositeCacheManagerMockImpl compositeCacheManager = new 
CompositeCacheManagerMockImpl();
 
         RemoteCacheAttributes attributes = new RemoteCacheAttributes();
@@ -59,19 +67,144 @@
         AuxiliaryCache cache = remoteCacheManager.getCache( regionName );
 
         // DO WORK
+        int numPutsPrior = server.getPutCount();
+        ICacheElement element = new CacheElement( regionName, "key", "value" );
+        cache.update( element );
+        SleepUtil.sleepAtLeast( 50 );
+
+        // VERIFY
+        System.out.println( server.getStats() );
+        assertEquals( "Wrong number of puts", 1, server.getPutCount() - 
numPutsPrior );
+
+        // DO WORK
+        ICacheElement result = cache.get( "key" );
+
+        // VERIFY
+        assertEquals( "Wrong element.", element.getVal(), result.getVal() );
+    }
+
+    /**
+     * Verify that we can remove an item via the remote server.
+     * <p>
+     * @throws Exception
+     */
+    public void testPutRemove()
+        throws Exception
+    {
+        // SETUP
+        CompositeCacheManagerMockImpl compositeCacheManager = new 
CompositeCacheManagerMockImpl();
+
+        RemoteCacheAttributes attributes = new RemoteCacheAttributes();
+        attributes.setRemoteHost( "localhost" );
+        attributes.setLocalPort( 1202 );
+        attributes.setRemotePort( 1101 );
+
+        RemoteCacheManager remoteCacheManager = 
RemoteCacheManager.getInstance( attributes, compositeCacheManager );
+        String regionName = "testPutRemove";
+        AuxiliaryCache cache = remoteCacheManager.getCache( regionName );
+
+        // DO WORK
+        int numPutsPrior = server.getPutCount();
         ICacheElement element = new CacheElement( regionName, "key", "value" );
         cache.update( element );
         SleepUtil.sleepAtLeast( 50 );
 
         // VERIFY
         System.out.println( server.getStats() );
-        assertEquals( "Wrong number of puts", 1, server.getPutCount() );
+        assertEquals( "Wrong number of puts", 1, server.getPutCount() - 
numPutsPrior );
 
         // DO WORK
         ICacheElement result = cache.get( "key" );
 
         // VERIFY
         assertEquals( "Wrong element.", element.getVal(), result.getVal() );
+
+        // DO WORK
+        cache.remove( "key" );
+        SleepUtil.sleepAtLeast( 50 );
+        ICacheElement resultAfterRemote = cache.get( "key" );
+
+        // VERIFY
+        assertNull( "Element resultAfterRemote should be null.", 
resultAfterRemote );
+    }
+
+    /**
+     * Register a listener with the server. Send an update. Verify that the 
listener received it.
+     * @throws Exception
+     */
+    public void testPutAndListen()
+        throws Exception
+    {
+        // SETUP
+        CompositeCacheManagerMockImpl compositeCacheManager = new 
CompositeCacheManagerMockImpl();
+
+        RemoteCacheAttributes attributes = new RemoteCacheAttributes();
+        attributes.setRemoteHost( "localhost" );
+        attributes.setLocalPort( 1202 );
+        attributes.setRemotePort( 1101 );
+
+        RemoteCacheManager remoteCacheManager = 
RemoteCacheManager.getInstance( attributes, compositeCacheManager );
+        String regionName = "testPutAndListen";
+        AuxiliaryCache cache = remoteCacheManager.getCache( regionName );
+
+        RemoteCacheListenerMockImpl listener = new 
RemoteCacheListenerMockImpl();
+        server.addCacheListener( regionName, listener );
+
+        // DO WORK
+        int numPutsPrior = server.getPutCount();
+        ICacheElement element = new CacheElement( regionName, "key", "value" );
+        cache.update( element );
+        SleepUtil.sleepAtLeast( 50 );
+
+        // VERIFY
+        try
+        {
+            System.out.println( server.getStats() );
+            assertEquals( "Wrong number of puts", 1, server.getPutCount() - 
numPutsPrior );
+            assertEquals( "Wrong number of puts to listener.", 1, 
listener.putCount );
+        }
+        finally
+        {
+            // remove from all regions.
+            server.removeCacheListener( listener );
+        }
     }
 
+    /**
+     * Register a listener with the server. Send an update. Verify that the 
listener received it.
+     * @throws Exception
+     */
+    public void testPutaMultipleAndListen()
+        throws Exception
+    {
+        // SETUP
+        CompositeCacheManagerMockImpl compositeCacheManager = new 
CompositeCacheManagerMockImpl();
+
+        RemoteCacheAttributes attributes = new RemoteCacheAttributes();
+        attributes.setRemoteHost( "localhost" );
+        attributes.setLocalPort( 1202 );
+        attributes.setRemotePort( 1101 );
+
+        RemoteCacheManager remoteCacheManager = 
RemoteCacheManager.getInstance( attributes, compositeCacheManager );
+        String regionName = "testPutAndListen";
+        AuxiliaryCache cache = remoteCacheManager.getCache( regionName );
+
+        RemoteCacheListenerMockImpl listener = new 
RemoteCacheListenerMockImpl();
+        server.addCacheListener( regionName, listener );
+
+        // DO WORK
+        int numPutsPrior = server.getPutCount();
+        int numToPut = 100;
+        for ( int i = 0; i < numToPut; i++ )
+        {
+            ICacheElement element = new CacheElement( regionName, "key" + 1, 
"value" + i );
+            cache.update( element );
+        }
+        SleepUtil.sleepAtLeast( 500 );
+
+        // VERIFY
+        System.out.println( server.getStats() );
+        assertEquals( "Wrong number of puts", numToPut, server.getPutCount() - 
numPutsPrior );
+        assertEquals( "Wrong number of puts to listener.", numToPut, 
listener.putCount );
+    }
 }