package org.apache.directmemory.tests.osgi.cache;
/*
* Licensed to the Apache Software Foundation (ASF) under one
* or more contributor license agreements. See the NOTICE file
* distributed with this work for additional information
* regarding copyright ownership. The ASF licenses this file
* to you under the Apache License, Version 2.0 (the
* "License"); you may not use this file except in compliance
* with the License. You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing,
* software distributed under the License is distributed on an
* "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
* KIND, either express or implied. See the License for the
* specific language governing permissions and limitations
* under the License.
*/
import org.apache.directmemory.cache.CacheService;
import org.apache.directmemory.measures.Every;
import org.apache.directmemory.measures.Monitor;
import org.apache.directmemory.memory.Pointer;
import org.apache.directmemory.tests.osgi.DirectMemoryOsgiTestSupport;
import org.junit.Test;
import org.junit.runner.RunWith;
import org.ops4j.pax.exam.Customizer;
import org.ops4j.pax.exam.Option;
import org.ops4j.pax.exam.junit.Configuration;
import org.ops4j.pax.exam.junit.JUnit4TestRunner;
import org.osgi.framework.Constants;
import java.io.IOException;
import java.io.InputStream;
import static org.junit.Assert.assertEquals;
import static org.junit.Assert.assertNotNull;
import static org.ops4j.pax.exam.CoreOptions.equinox;
import static org.ops4j.pax.exam.CoreOptions.felix;
import static org.ops4j.pax.exam.OptionUtils.combine;
import static org.ops4j.pax.swissbox.tinybundles.core.TinyBundles.modifyBundle;
import static org.ops4j.pax.swissbox.tinybundles.core.TinyBundles.newBundle;
@RunWith( JUnit4TestRunner.class )
public class CacheServiceTest
extends DirectMemoryOsgiTestSupport
{
/**
* This tests basic cache operations(put,retrieve) inside OSGi
*/
@Test
public void testCacheService()
{
String key = "2";
String obj = "Simple String Object";
CacheService cacheService = getOsgiService( CacheService.class );
//Test retrieving an object added by an other bundle.
Object result = cacheService.retrieve( "1" );
assertNotNull( result );
cacheService.scheduleDisposalEvery( Every.seconds( 1 ) );
cacheService.dump();
Monitor.dump( "cache" );
Pointer p = cacheService.put( "2", obj );
result = cacheService.retrieve( "2" );
cacheService.dump();
assertEquals( obj, result );
}
/**
* This test basic cache operations(put,retrieve) inside OSGi using an object of an imported class (provided by an other bundle).
*/
@Test
public void testCacheServiceWithImportedObject()
{
SimpleObject obj1 = new SimpleObject( "2", "Object Two" );
SimpleObject obj2 = new SimpleObject( "3", "Object Three" );
CacheService cacheService = getOsgiService( CacheService.class );
cacheService.scheduleDisposalEvery( Every.seconds( 1 ) );
cacheService.dump();
Pointer p1 = cacheService.put( "2", obj1 );
Pointer p2 = cacheService.put( "3", obj2 );
Object result1 = cacheService.retrieve( "2" );
Object result2 = cacheService.retrieve( "3" );
cacheService.dump();
Monitor.dump( "cache" );
assertEquals( obj1, result1 );
assertEquals( obj2, result2 );
}
@Configuration
public Option[] configure()
throws IOException
{
return combine( getDynamicMemoryOptions(),
bundle( newBundle().add( SimpleObject.class ).add( CacheServiceExportingActivator.class ).set(
Constants.BUNDLE_ACTIVATOR, CacheServiceExportingActivator.class.getCanonicalName() ).set(
Constants.BUNDLE_SYMBOLICNAME,
"org.apache.directmemory.tests.osgi.cacheservice.exporter" ).set( Constants.BUNDLE_VERSION,
"1.0.0" ).set(
Constants.DYNAMICIMPORT_PACKAGE, "*" ).build() ).start(),
new Customizer()
{
@Override
public InputStream customizeTestProbe( InputStream testProbe )
{
return modifyBundle( testProbe ).set( Constants.DYNAMICIMPORT_PACKAGE, "*" ).build();
}
},
//Uncomment the line below to debug test
//enabledDebuggingOnPort(5005,true),
felix(), equinox() );
}
}