ActiveMQ example source code file (StoreTest.java)

This example ActiveMQ source code file (StoreTest.java) is included in the DevDaily.com "Java Source Code Warehouse" project. The intent of this project is to help you "Learn Java by Example" ^TM.

Java - ActiveMQ tags/keywords

exception, exception, io, ioexception, iterator, listcontainer, listcontainer, mapcontainer, object, object, store, storetest, string, string, testcase, util

The ActiveMQ StoreTest.java source code

/**
 * 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.
 */
package org.apache.activemq.kaha;

import java.io.IOException;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.Iterator;
import java.util.List;
import java.util.Map;

import junit.framework.TestCase;
import org.apache.activemq.kaha.impl.StoreLockedExcpetion;

/**
 * Store test
 * 
 * 
 */
public class StoreTest extends TestCase {

    protected String name;
    protected Store store;

    /*
     * Test method for 'org.apache.activemq.kaha.Store.close()'
     */
    public void testClose() throws Exception {
        store.close();
        try {
            // access should throw an exception
            store.getListContainer("fred");
            assertTrue("Should have got a enception", false);
        } catch (Exception e) {

        }
    }

    /*
     * Test method for 'org.apache.activemq.kaha.Store.clear()'
     */
    public void testClear() throws Exception {
        int count = 100;
        ListContainer list = store.getListContainer("testClear");
        list.load();
        for (int i = 0; i < count; i++) {
            list.add("test " + i);
        }
        assertEquals(count, list.size());
        store.clear();
        assertTrue(list.isEmpty());
    }

    /*
     * Test method for 'org.apache.activemq.kaha.Store.getMapContainer(Object)'
     */
    public void testGetMapContainer() throws Exception {
        String containerId = "test";
        MapContainer<Object, String> container = store.getMapContainer(containerId);
        container.load();
        assertNotNull(container);
        store.close();
        store = getStore();
        container = store.getMapContainer(containerId);
        assertNotNull(container);

    }

    /*
     * Test method for
     * 'org.apache.activemq.kaha.Store.deleteMapContainer(Object)'
     */
    public void testDeleteMapContainer() throws Exception {
        String containerId = "test";
        MapContainer<Object, String> container = store.getMapContainer(containerId);
        assertNotNull(container);
        store.deleteMapContainer(containerId);
        assertFalse(store.doesMapContainerExist(containerId));
        store.close();
        store = getStore();
        assertFalse(store.doesMapContainerExist(containerId));
    }

    /*
     * Test method for 'org.apache.activemq.kaha.Store.getListContainer(Object)'
     */
    public void testGetListContainer() throws Exception {
        String containerId = "test";
        ListContainer container = store.getListContainer(containerId);
        assertNotNull(container);
        store.close();
        store = getStore();
        container = store.getListContainer(containerId);
        assertNotNull(container);
    }

    /*
     * Test method for
     * 'org.apache.activemq.kaha.Store.deleteListContainer(Object)'
     */
    public void testDeleteListContainer() throws Exception {
        String containerId = "test";
        ListContainer container = store.getListContainer(containerId);
        assertNotNull(container);
        store.deleteListContainer(containerId);
        assertFalse(store.doesListContainerExist(containerId));
        store.close();
        store = getStore();
        assertFalse(store.doesListContainerExist(containerId));
    }

    public void testBasicAllocations() throws Exception {
        Map<Object, String> testMap = new HashMap();
        int count = 1000;
        for (int i = 0; i < count; i++) {
            String key = "key:" + i;
            String value = "value:" + i;
            testMap.put(key, value);
        }
        List testList = new ArrayList();
        for (int i = 0; i < count; i++) {
            testList.add("value:" + i);
        }
        String listId = "testList";
        String mapId1 = "testMap";
        String mapId2 = "testMap2";
        MapContainer<Object, String> mapContainer1 = store.getMapContainer(mapId1);
        mapContainer1.load();
        mapContainer1.putAll(testMap);

        MapContainer<Object, String> mapContainer2 = store.getMapContainer(mapId2, mapId2);
        mapContainer2.load();
        mapContainer2.putAll(testMap);

        ListContainer listContainer = store.getListContainer(listId);
        listContainer.load();

        listContainer.addAll(testList);
        store.close();
        store = getStore();
        mapContainer1 = store.getMapContainer(mapId1);
        mapContainer1.load();
        mapContainer2 = store.getMapContainer(mapId2, mapId2);
        mapContainer2.load();
        listContainer = store.getListContainer(listId);
        listContainer.load();
        for (Iterator<Object> i = testMap.keySet().iterator(); i.hasNext();) {
            Object key = i.next();
            Object value = testMap.get(key);
            assertTrue(mapContainer1.containsKey(key));
            assertEquals(value, mapContainer1.get(key));
        }
        for (Iterator<Object> i = testMap.keySet().iterator(); i.hasNext();) {
            Object key = i.next();
            Object value = testMap.get(key);
            assertTrue(mapContainer2.containsKey(key));
            assertEquals(value, mapContainer2.get(key));
        }
        assertEquals(testList.size(), listContainer.size());
        Iterator j = listContainer.iterator();
        for (Iterator i = testList.iterator(); i.hasNext();) {
            assertEquals(i.next(), j.next());
        }
    }

    public void testLock() throws Exception {
        store.doesListContainerExist("fred");
        Store s = getStore();
        try {
            s.doesListContainerExist("fred");
        } catch (StoreLockedExcpetion e) {
            return;
        } finally {
            s.close();
        }
        fail("Expected to catch an exception");
    }

    protected Store getStore() throws IOException {
        return StoreFactory.open(name, "rw");
    }

    protected void setUp() throws Exception {
        super.setUp();
        name = System.getProperty("basedir", ".") + "/target/activemq-data/store-test.db";
        store = getStore();
    }

    protected void tearDown() throws Exception {
        super.tearDown();
        if (store != null) {
            store.close();
            store = null;
        }
        boolean rc = StoreFactory.delete(name);
        assertTrue(rc);
    }
}