package com.atlassian.cache.ehcache;
   
   import net.sf.ehcache.distribution.RMIAsynchronousCacheReplicator;
   import net.sf.ehcache.event.CacheEventListener;
   import net.sf.ehcache.event.CacheEventListenerFactory;
   import org.junit.Before;
   import org.junit.Test;
   
   import java.util.Properties;
  
  import static com.atlassian.cache.ehcache.RMICacheReplicatorFactory.REPLICATE_ASYNCHRONOUSLY;
  import static org.junit.Assert.assertEquals;
  import static org.mockito.Mockito.mock;
  import static org.mockito.Mockito.when;
  
  public class RMICacheReplicatorFactoryTest
  {
      private CacheEventListenerFactory factory;
  
      @Before
      public void setUp() throws Exception
      {
          factory = new RMICacheReplicatorFactory();
      }
  
      @Test
      public void replicationShouldBeAsynchronousByDefault() throws Exception
      {
          // Set up
          final Properties mockProperties = mock(Properties.class);
  
          // Invoke
          final CacheEventListener listener = factory.createCacheEventListener(mockProperties);
  
          // Check
          assertEquals(RMIAsynchronousCacheReplicator.class, listener.getClass());
      }
  
      @Test
      public void replicationShouldBeAsynchronousWhenExplicitlySet() throws Exception
      {
          // Set up
          final Properties mockProperties = mock(Properties.class);
          when(mockProperties.get(REPLICATE_ASYNCHRONOUSLY)).thenReturn("TRUE");
          when(mockProperties.size()).thenReturn(1);
  
          // Invoke
          final CacheEventListener listener = factory.createCacheEventListener(mockProperties);
  
          // Check
          assertEquals(RMIAsynchronousCacheReplicator.class, listener.getClass());
      }
  
      @Test
      public void replicationShouldBeSynchronousWhenExplicitlySet() throws Exception
      {
          // Set up
          final Properties mockProperties = mock(Properties.class);
          when(mockProperties.get(REPLICATE_ASYNCHRONOUSLY)).thenReturn("FALSE");
          when(mockProperties.size()).thenReturn(1);
  
          // Invoke
          final CacheEventListener listener = factory.createCacheEventListener(mockProperties);
  
          // Check
          assertEquals(RMISynchronousCacheReplicator.class, listener.getClass());
      }
  }