[jbosscache-commits] JBoss Cache SVN: r4285 - in core/trunk/migration: examples/cacheloader-migration/data and 4 other directories.
jbosscache-commits at lists.jboss.org
jbosscache-commits at lists.jboss.org
Wed Aug 15 05:25:32 EDT 2007
Author: manik.surtani at jboss.com
Date: 2007-08-15 05:25:32 -0400 (Wed, 15 Aug 2007)
New Revision: 4285
Removed:
core/trunk/migration/examples/cacheloader-migration/build.bat
core/trunk/migration/examples/cacheloader-migration/build.properties
core/trunk/migration/examples/cacheloader-migration/build.sh
core/trunk/migration/examples/cacheloader-migration/build.xml
core/trunk/migration/examples/cacheloader-migration/data/filecacheloader-1x.zip
core/trunk/migration/examples/cacheloader-migration/data/jbossdb-1x.zip
core/trunk/migration/examples/cacheloader-migration/log4j-cache.xml
core/trunk/migration/examples/cacheloader-migration/readme.txt
core/trunk/migration/examples/cacheloader-migration/resources/original-fcl-service.xml
core/trunk/migration/examples/cacheloader-migration/resources/original-jdbccl-service.xml
core/trunk/migration/examples/cacheloader-migration/resources/transform-fcl-service.xml
core/trunk/migration/examples/cacheloader-migration/resources/transform-jdbccl-service.xml
core/trunk/migration/examples/cacheloader-migration/src/examples/TransformStore.java
core/trunk/migration/src/org/jboss/cache/loader/TransformingFileCacheLoader.java
core/trunk/migration/src/org/jboss/cache/loader/TransformingJDBCCacheLoader.java
core/trunk/migration/tests/functional/org/jboss/cache/loader/TransformingCacheLoaderTestBase.java
core/trunk/migration/tests/functional/org/jboss/cache/loader/TransformingFileCacheLoaderTest.java
core/trunk/migration/tests/functional/org/jboss/cache/loader/TransformingJDBCCacheLoaderTest.java
Log:
Deleted: core/trunk/migration/examples/cacheloader-migration/build.bat
===================================================================
--- core/trunk/migration/examples/cacheloader-migration/build.bat 2007-08-15 09:25:11 UTC (rev 4284)
+++ core/trunk/migration/examples/cacheloader-migration/build.bat 2007-08-15 09:25:32 UTC (rev 4285)
@@ -1,4 +0,0 @@
- at echo off
-set ANT_HOME=..\..\ant-dist
-REM java -cp %ANT_HOME%/lib/ant.jar;%ANT_HOME%/lib/optional.jar;%ANT_HOME%/lib/junit.jar;%JAVA_HOME%/lib/tools.jar org.apache.tools.ant.Main %*
-%ANT_HOME%\bin\ant %*
Deleted: core/trunk/migration/examples/cacheloader-migration/build.properties
===================================================================
--- core/trunk/migration/examples/cacheloader-migration/build.properties 2007-08-15 09:25:11 UTC (rev 4284)
+++ core/trunk/migration/examples/cacheloader-migration/build.properties 2007-08-15 09:25:32 UTC (rev 4285)
@@ -1,17 +0,0 @@
-# set up environment
-#
-
-#
-# Below should be transparent to you.
-#
-
-# basedir is a project attribute
-#
-
-# create directory structure
-#
-cache.home=${basedir}/../..
-cache.lib=${cache.home}/lib
-
-#Directory for Junit test result. Subdirectory html contains the result in html format.
-reports=${output}/reports
Deleted: core/trunk/migration/examples/cacheloader-migration/build.sh
===================================================================
--- core/trunk/migration/examples/cacheloader-migration/build.sh 2007-08-15 09:25:11 UTC (rev 4284)
+++ core/trunk/migration/examples/cacheloader-migration/build.sh 2007-08-15 09:25:32 UTC (rev 4285)
@@ -1,26 +0,0 @@
-#!/bin/sh
-
-CACHE_HOME=`dirname $0`
-ANT_HOME=$CACHE_HOME/../../ant-dist
-
-CLASSPATH=$ANT_HOME/lib/ant.jar:$ANT_HOME/lib/optional.jar:$ANT_HOME/lib/junit.jar:$JAVA_HOME/lib/tools.jar
-
-# OS specific support (must be 'true' or 'false').
-cygwin=false;
-case "`uname`" in
- CYGWIN*)
- cygwin=true
- ;;
-esac
-
-if [ $cygwin = "true" ]; then
-# Note that JAVA_HOME evn needs to be set under cygwin explictly,
-# /cygdrive/e:/j2sdkxxx, for this to work correctly. Otherwise,
-# javac can't be located correctly.
- CP=`cygpath -wp $CLASSPATH`
-else
- CP=$CLASSPATH
-fi
-
-#java -cp $CP org.apache.tools.ant.Main "$@"
-$ANT_HOME/bin/ant "$@"
\ No newline at end of file
Deleted: core/trunk/migration/examples/cacheloader-migration/build.xml
===================================================================
--- core/trunk/migration/examples/cacheloader-migration/build.xml 2007-08-15 09:25:11 UTC (rev 4284)
+++ core/trunk/migration/examples/cacheloader-migration/build.xml 2007-08-15 09:25:32 UTC (rev 4285)
@@ -1,91 +0,0 @@
-<?xml version="1.0"?>
-
-<project name="JBossCache examples Cache Loader Migration" default="help">
-
- <property file="./build.properties"/>
-
- <property name="output" value="${basedir}/output"/>
- <property name="source" value="${basedir}/src"/>
- <property name="resources" value="${basedir}/resources"/>
- <property name="data" value="${basedir}/data"/>
- <property name="build" value="${output}/classes"/>
-
- <property name="db.dir" value="jbossdb-1x"/>
- <property name="db.zip" value="jbossdb-1x.zip"/>
-
- <property name="tmp.dir" value="/tmp"/>
- <property name="filestore.dir" value="filecacheloader-1x"/>
- <property name="filestore.zip" value="filecacheloader-1x.zip"/>
-
- <path id="lib.classpath">
- <fileset dir="${cache.lib}">
- <include name="**/*.jar"/>
- </fileset>
- </path>
-
- <path id="user.classpath">
- <pathelement path="${build}"/>
- <path refid="lib.classpath"/>
- </path>
-
- <target name="help" description="help page">
- <echo message="build.sh <command> where command is:"/>
- <echo message=" compile -- compile the examples code"/>
- <echo message=" run.jdbccacheloader.example -- run JDBC store migration example"/>
- <echo message=" run.filecacheloader.example -- run file store migration example"/>
- </target>
-
- <target name="init" description="Prepare to build.">
- <tstamp/>
- <mkdir dir="${build}"/>
- </target>
-
- <target name="clean" description="Clean up compiled classes">
- <delete dir="${output}"/>
- <delete dir="${db.dir}"/>
- </target>
-
- <target name="compile" depends="init" description="Build example">
- <javac srcdir="${source}"
- destdir="${build}"
- includes="**/**"
- debug="true"
- deprecation="true">
- <classpath>
- <path refid="lib.classpath"/>
- </classpath>
- </javac>
-
- <copy todir="${build}">
- <fileset dir="${resources}">
- <include name="**/*"/>
- </fileset>
- </copy>
- </target>
-
- <target name="run.jdbccacheloader.example" depends="compile" description="run JDBC store migration example.">
- <delete dir="${db.dir}"/>
- <unzip src="${data}/${db.zip}" dest="."/>
-
- <java classname="examples.TransformStore" fork="yes">
- <jvmarg value="-Dcacheloader.type=jdbccl"/>
- <jvmarg value="-Dlog4j.configuration=file:${basedir}/log4j-cache.xml"/>
- <classpath refid="lib.classpath"/>
- <classpath path="${build}"/>
- </java>
- </target>
-
- <target name="run.filecacheloader.example" depends="compile" description="run file store migration example.">
- <delete dir="${tmp.dir}/${filestore.dir}"/>
- <mkdir dir="${tmp.dir}"/>
- <unzip src="${data}/${filestore.zip}" dest="${tmp.dir}"/>
-
- <java classname="examples.TransformStore" fork="yes">
- <jvmarg value="-Dcacheloader.type=fcl"/>
- <jvmarg value="-Dlog4j.configuration=file:${basedir}/log4j-cache.xml"/>
- <classpath refid="lib.classpath"/>
- <classpath path="${build}"/>
- </java>
- </target>
-
-</project>
Deleted: core/trunk/migration/examples/cacheloader-migration/data/filecacheloader-1x.zip
===================================================================
(Binary files differ)
Deleted: core/trunk/migration/examples/cacheloader-migration/data/jbossdb-1x.zip
===================================================================
(Binary files differ)
Deleted: core/trunk/migration/examples/cacheloader-migration/log4j-cache.xml
===================================================================
--- core/trunk/migration/examples/cacheloader-migration/log4j-cache.xml 2007-08-15 09:25:11 UTC (rev 4284)
+++ core/trunk/migration/examples/cacheloader-migration/log4j-cache.xml 2007-08-15 09:25:32 UTC (rev 4285)
@@ -1,106 +0,0 @@
-<?xml version="1.0" encoding="UTF-8"?>
-<!DOCTYPE log4j:configuration SYSTEM "log4j.dtd">
-
-<!-- ===================================================================== -->
-<!-- -->
-<!-- Log4j Configuration -->
-<!-- -->
-<!-- ===================================================================== -->
-
-<!-- $Id$ -->
-
-<!--
- | For more configuration infromation and examples see the Jakarta Log4j
- | owebsite: http://jakarta.apache.org/log4j
- -->
-
-<log4j:configuration xmlns:log4j="http://jakarta.apache.org/log4j/" debug="false">
-
- <!-- ================================= -->
- <!-- Preserve messages in a local file -->
- <!-- ================================= -->
-
- <!-- A time/date based rolling appender -->
- <appender name="FILE" class="org.apache.log4j.DailyRollingFileAppender">
- <param name="File" value="/tmp/jbosscache.log"/>
- <param name="Append" value="false"/>
-
- <!-- Rollover at midnight each day -->
- <param name="DatePattern" value="'.'yyyy-MM-dd"/>
-
- <!-- Rollover at the top of each hour
- <param name="DatePattern" value="'.'yyyy-MM-dd-HH"/>
- -->
- <!-- param name="Threshold" value="TRACE"/ -->
-
- <layout class="org.apache.log4j.PatternLayout">
- <!-- The default pattern: Date Priority [Category] Message\n -->
- <param name="ConversionPattern" value="%d %-5p [%c] (%t) %m%n"/>
-
- <!-- The full pattern: Date MS Priority [Category] (Thread:NDC) Message\n
- <param name="ConversionPattern" value="%d %-5r %-5p [%c] (%t:%x) %m%n"/>
- -->
- </layout>
- </appender>
-
- <!-- ============================== -->
- <!-- Append messages to the console -->
- <!-- ============================== -->
-
- <appender name="CONSOLE" class="org.apache.log4j.ConsoleAppender">
- <param name="Threshold" value="DEBUG"/>
- <param name="Target" value="System.out"/>
-
- <layout class="org.apache.log4j.PatternLayout">
- <!-- The default pattern: Date Priority [Category] Message\n -->
- <param name="ConversionPattern" value="%d %-5p [%c{1}] (%t) %m%n"/>
- </layout>
- </appender>
-
-
- <!-- ================ -->
- <!-- Limit categories -->
- <!-- ================ -->
-
- <!-- Limit JBoss categories to INFO
- <category name="org.jboss">
- <priority value="INFO"/>
- </category>
- -->
-
- <!--
- | An example of enabling the custom TRACE level priority that is used
- | by the JBoss internals to diagnose low level details. This example
- | turns on TRACE level msgs for the org.jboss.ejb.plugins package and its
- | subpackages. This will produce A LOT of logging output.
- <category name="org.jboss.system">
- <priority value="TRACE"/>
- </category>
- -->
-
- <category name="org.jboss.cache">
- <priority value="INFO"/>
- </category>
-
- <category name="org.jboss.serial">
- <priority value="INFO"/>
- </category>
-
- <category name="org.jboss.tm">
- <priority value="WARN"/>
- </category>
-
- <category name="org.jgroups">
- <priority value="WARN"/>
- </category>
-
- <!-- ======================= -->
- <!-- Setup the Root category -->
- <!-- ======================= -->
-
- <root>
- <appender-ref ref="CONSOLE"/>
- <appender-ref ref="FILE"/>
- </root>
-
-</log4j:configuration>
Deleted: core/trunk/migration/examples/cacheloader-migration/readme.txt
===================================================================
--- core/trunk/migration/examples/cacheloader-migration/readme.txt 2007-08-15 09:25:11 UTC (rev 4284)
+++ core/trunk/migration/examples/cacheloader-migration/readme.txt 2007-08-15 09:25:32 UTC (rev 4285)
@@ -1,39 +0,0 @@
-This is an example that illustrates how to migrate existing file or jdbc cache
-stores generated with JBoss Cache 1.x to a format that it's readable by JBossCache
-2.x.
-
-Both of the examples rely on zipped cache stores containing the following structure
-stored in it:
-
-/
- /Europe
- /Austria {capital="Vienna",currency="Euro",population=8184691}
- /England {capital="London",currency="British Pound",population=8184691}
- /Albania {capital="Tirana",currency="Lek",population=3563112,area=28748}
- /Hungary {capital="Budapest",currency="Forint",population=10006835,area=93030}
-
-The idea of this example, both for the jdbc and the file versions, is to loop through
-the data stored in 1.x format, and put it back again in the cache store in 2.x format.
-So, in both cases, the example starts creating an instance of a transform*-service.xml
-whose only difference with the original one is that it uses a transforming cache loader
-which reads in 1.x and writes in 2.x format.
-
-Starting from the root node, the example then loops through the whole cache, which will
-delegate the get() calls into the cache store. Each node retrieved is put back into the
-cache, which results on the node being put in the new format. You should see INFO level
-messages indicating the success of the transformation.
-
-At this point, the transforming cache instance is stopped and destroyed, and a new cache
-instance is created with the original cache configuration file, i.e original*-service.xml,
-which specifies the traditional cache loader.
-
-The example now loops through the entire cache again, checking that it can get the newly
-transformed node and prints out its details.
-
-To run the JDBC cache store version:
-- Run "build.bat/sh run.jdbccacheloader.example". It first unzips data/jbossdb-1x.zip into the
-current directory and uses this generated DB (Apache Derby) as store for the example.
-
-- Run "build.bat/sh run.filecacheloader.example". It first unzips data/filecacheloader-1x.zip
-into the /tmp directory (C:\tmp in Windows) and uses this generated file store for the
-example.
\ No newline at end of file
Deleted: core/trunk/migration/examples/cacheloader-migration/resources/original-fcl-service.xml
===================================================================
--- core/trunk/migration/examples/cacheloader-migration/resources/original-fcl-service.xml 2007-08-15 09:25:11 UTC (rev 4284)
+++ core/trunk/migration/examples/cacheloader-migration/resources/original-fcl-service.xml 2007-08-15 09:25:32 UTC (rev 4285)
@@ -1,174 +0,0 @@
-<?xml version="1.0" encoding="UTF-8"?>
-
-<!-- ===================================================================== -->
-<!-- -->
-<!-- Sample TreeCache Service Configuration -->
-<!-- -->
-<!-- ===================================================================== -->
-
-<server>
-
- <classpath codebase="./lib" archives="jboss-cache.jar, jgroups.jar"/>
-
-
- <!-- ==================================================================== -->
- <!-- Defines TreeCache configuration -->
- <!-- ==================================================================== -->
-
- <mbean code="org.jboss.cache.CacheImpl"
- name="jboss.cache:service=TreeCache">
-
- <depends>jboss:service=Naming</depends>
- <depends>jboss:service=TransactionManager</depends>
-
- <!--
- Configure the TransactionManager
- -->
- <attribute name="TransactionManagerLookupClass">org.jboss.cache.transaction.GenericTransactionManagerLookup
- </attribute>
-
- <!--
- Isolation level : SERIALIZABLE
- REPEATABLE_READ (default)
- READ_COMMITTED
- READ_UNCOMMITTED
- NONE
- -->
- <attribute name="IsolationLevel">REPEATABLE_READ</attribute>
-
- <!--
- Valid modes are LOCAL
- REPL_ASYNC
- REPL_SYNC
- INVALIDATION_ASYNC
- INVALIDATION_SYNC
- -->
- <attribute name="CacheMode">LOCAL</attribute>
-
- <!--
- Just used for async repl: use a replication queue
- -->
- <attribute name="UseReplQueue">false</attribute>
-
- <!--
- Replication interval for replication queue (in ms)
- -->
- <attribute name="ReplQueueInterval">0</attribute>
-
- <!--
- Max number of elements which trigger replication
- -->
- <attribute name="ReplQueueMaxElements">0</attribute>
-
- <!-- Name of cluster. Needs to be the same for all TreeCache nodes in a
- cluster in order to find each other.
- -->
- <attribute name="ClusterName">JBossCache-Cluster</attribute>
-
- <!--Uncomment next three statements to enable JGroups multiplexer.
-This configuration is dependent on the JGroups multiplexer being
-registered in an MBean server such as JBossAS. -->
- <!--
- <depends>jgroups.mux:name=Multiplexer</depends>
- <attribute name="MultiplexerService">jgroups.mux:name=Multiplexer</attribute>
- <attribute name="MultiplexerStack">fc-fast-minimalthreads</attribute>
- -->
-
- <!-- JGroups protocol stack properties.
- ClusterConfig isn't used if the multiplexer is enabled and successfully initialized.
- -->
- <attribute name="ClusterConfig">
- <config>
- <!-- UDP: if you have a multihomed machine,
- set the bind_addr attribute to the appropriate NIC IP address -->
- <!-- UDP: On Windows machines, because of the media sense feature
- being broken with multicast (even after disabling media sense)
- set the loopback attribute to true -->
- <UDP mcast_addr="228.1.2.3" mcast_port="48866"
- ip_ttl="64" ip_mcast="true"
- mcast_send_buf_size="150000" mcast_recv_buf_size="80000"
- ucast_send_buf_size="150000" ucast_recv_buf_size="80000"
- loopback="false"/>
- <PING timeout="2000" num_initial_members="3"
- up_thread="false" down_thread="false"/>
- <MERGE2 min_interval="10000" max_interval="20000"/>
- <!-- <FD shun="true" up_thread="true" down_thread="true" />-->
- <FD_SOCK/>
- <VERIFY_SUSPECT timeout="1500"
- up_thread="false" down_thread="false"/>
- <pbcast.NAKACK gc_lag="50" retransmit_timeout="600,1200,2400,4800"
- max_xmit_size="8192" up_thread="false" down_thread="false"/>
- <UNICAST timeout="600,1200,2400" down_thread="false"/>
- <pbcast.STABLE desired_avg_gossip="20000"
- up_thread="false" down_thread="false"/>
- <pbcast.GMS join_timeout="5000" join_retry_timeout="2000"
- shun="true" print_local_addr="true"/>
- <FC max_credits="2000000" down_thread="false" up_thread="false"
- min_threshold="0.20"/>
- <FRAG frag_size="8192" down_thread="false" up_thread="true"/>
- <pbcast.STATE_TRANSFER up_thread="true" down_thread="true"/>
- </config>
- </attribute>
-
-
- <!--
- The max amount of time (in milliseconds) we wait until the
- initial state (ie. the contents of the cache) are retrieved from
- existing members in a clustered environment
- -->
- <attribute name="InitialStateRetrievalTimeout">20000</attribute>
-
- <!--
- Number of milliseconds to wait until all responses for a
- synchronous call have been received.
- -->
- <attribute name="SyncReplTimeout">20000</attribute>
-
- <!-- Max number of milliseconds to wait for a lock acquisition -->
- <attribute name="LockAcquisitionTimeout">15000</attribute>
-
- <!--
- Whether or not to fetch state on joining a cluster
- NOTE this used to be called FetchStateOnStartup and has been renamed to be more descriptive.
- -->
- <attribute name="FetchInMemoryState">false</attribute>
-
- <attribute name="CacheLoaderConfiguration">
- <config>
- <!-- if passivation is true, only the first cache loader is used; the rest are ignored -->
- <passivation>false</passivation>
- <shared>false</shared>
-
- <!-- we can now have multiple cache loaders, which get chained -->
- <cacheloader>
- <class>org.jboss.cache.loader.FileCacheLoader</class>
- <!-- same as the old CacheLoaderConfig attribute -->
- <properties>
- location=/tmp/filecacheloader-1x
- </properties>
- <!-- whether the cache loader writes are asynchronous -->
- <async>false</async>
- <!-- only one cache loader in the chain may set fetchPersistentState to true.
- An exception is thrown if more than one cache loader sets this to true. -->
- <fetchPersistentState>false</fetchPersistentState>
- <!-- determines whether this cache loader ignores writes - defaults to false. -->
- <ignoreModifications>false</ignoreModifications>
- <!-- if set to true, purges the contents of this cache loader when the cache starts up.
- Defaults to false. -->
- <purgeOnStartup>false</purgeOnStartup>
- </cacheloader>
-
- </config>
- </attribute>
-
- </mbean>
-
-
- <!-- Uncomment to get a graphical view of the TreeCache MBean above -->
- <!-- <mbean code="org.jboss.cache.TreeCacheView" name="jboss.cache:service=TreeCacheView">-->
- <!-- <depends>jboss.cache:service=TreeCache</depends>-->
- <!-- <attribute name="CacheService">jboss.cache:service=TreeCache</attribute>-->
- <!-- </mbean>-->
-
-
-</server>
Deleted: core/trunk/migration/examples/cacheloader-migration/resources/original-jdbccl-service.xml
===================================================================
--- core/trunk/migration/examples/cacheloader-migration/resources/original-jdbccl-service.xml 2007-08-15 09:25:11 UTC (rev 4284)
+++ core/trunk/migration/examples/cacheloader-migration/resources/original-jdbccl-service.xml 2007-08-15 09:25:32 UTC (rev 4285)
@@ -1,187 +0,0 @@
-<?xml version="1.0" encoding="UTF-8"?>
-
-<!-- ===================================================================== -->
-<!-- -->
-<!-- Sample TreeCache Service Configuration -->
-<!-- -->
-<!-- ===================================================================== -->
-
-<server>
-
- <classpath codebase="./lib" archives="jboss-cache.jar, jgroups.jar"/>
-
-
- <!-- ==================================================================== -->
- <!-- Defines TreeCache configuration -->
- <!-- ==================================================================== -->
-
- <mbean code="org.jboss.cache.CacheImpl"
- name="jboss.cache:service=TreeCache">
-
- <depends>jboss:service=Naming</depends>
- <depends>jboss:service=TransactionManager</depends>
-
- <!--
- Configure the TransactionManager
- -->
- <attribute name="TransactionManagerLookupClass">org.jboss.cache.transaction.GenericTransactionManagerLookup
- </attribute>
-
- <!--
- Isolation level : SERIALIZABLE
- REPEATABLE_READ (default)
- READ_COMMITTED
- READ_UNCOMMITTED
- NONE
- -->
- <attribute name="IsolationLevel">REPEATABLE_READ</attribute>
-
- <!--
- Valid modes are LOCAL
- REPL_ASYNC
- REPL_SYNC
- INVALIDATION_ASYNC
- INVALIDATION_SYNC
- -->
- <attribute name="CacheMode">LOCAL</attribute>
-
- <!--
- Just used for async repl: use a replication queue
- -->
- <attribute name="UseReplQueue">false</attribute>
-
- <!--
- Replication interval for replication queue (in ms)
- -->
- <attribute name="ReplQueueInterval">0</attribute>
-
- <!--
- Max number of elements which trigger replication
- -->
- <attribute name="ReplQueueMaxElements">0</attribute>
-
- <!-- Name of cluster. Needs to be the same for all TreeCache nodes in a
- cluster in order to find each other.
- -->
- <attribute name="ClusterName">JBossCache-Cluster</attribute>
-
- <!--Uncomment next three statements to enable JGroups multiplexer.
-This configuration is dependent on the JGroups multiplexer being
-registered in an MBean server such as JBossAS. -->
- <!--
- <depends>jgroups.mux:name=Multiplexer</depends>
- <attribute name="MultiplexerService">jgroups.mux:name=Multiplexer</attribute>
- <attribute name="MultiplexerStack">fc-fast-minimalthreads</attribute>
- -->
-
- <!-- JGroups protocol stack properties.
- ClusterConfig isn't used if the multiplexer is enabled and successfully initialized.
- -->
- <attribute name="ClusterConfig">
- <config>
- <!-- UDP: if you have a multihomed machine,
- set the bind_addr attribute to the appropriate NIC IP address -->
- <!-- UDP: On Windows machines, because of the media sense feature
- being broken with multicast (even after disabling media sense)
- set the loopback attribute to true -->
- <UDP mcast_addr="228.1.2.3" mcast_port="48866"
- ip_ttl="64" ip_mcast="true"
- mcast_send_buf_size="150000" mcast_recv_buf_size="80000"
- ucast_send_buf_size="150000" ucast_recv_buf_size="80000"
- loopback="false"/>
- <PING timeout="2000" num_initial_members="3"
- up_thread="false" down_thread="false"/>
- <MERGE2 min_interval="10000" max_interval="20000"/>
- <!-- <FD shun="true" up_thread="true" down_thread="true" />-->
- <FD_SOCK/>
- <VERIFY_SUSPECT timeout="1500"
- up_thread="false" down_thread="false"/>
- <pbcast.NAKACK gc_lag="50" retransmit_timeout="600,1200,2400,4800"
- max_xmit_size="8192" up_thread="false" down_thread="false"/>
- <UNICAST timeout="600,1200,2400" down_thread="false"/>
- <pbcast.STABLE desired_avg_gossip="20000"
- up_thread="false" down_thread="false"/>
- <pbcast.GMS join_timeout="5000" join_retry_timeout="2000"
- shun="true" print_local_addr="true"/>
- <FC max_credits="2000000" down_thread="false" up_thread="false"
- min_threshold="0.20"/>
- <FRAG frag_size="8192" down_thread="false" up_thread="true"/>
- <pbcast.STATE_TRANSFER up_thread="true" down_thread="true"/>
- </config>
- </attribute>
-
-
- <!--
- The max amount of time (in milliseconds) we wait until the
- initial state (ie. the contents of the cache) are retrieved from
- existing members in a clustered environment
- -->
- <attribute name="InitialStateRetrievalTimeout">20000</attribute>
-
- <!--
- Number of milliseconds to wait until all responses for a
- synchronous call have been received.
- -->
- <attribute name="SyncReplTimeout">20000</attribute>
-
- <!-- Max number of milliseconds to wait for a lock acquisition -->
- <attribute name="LockAcquisitionTimeout">15000</attribute>
-
- <!--
- Whether or not to fetch state on joining a cluster
- NOTE this used to be called FetchStateOnStartup and has been renamed to be more descriptive.
- -->
- <attribute name="FetchInMemoryState">false</attribute>
-
- <attribute name="CacheLoaderConfiguration">
- <config>
- <!-- if passivation is true, only the first cache loader is used; the rest are ignored -->
- <passivation>false</passivation>
- <shared>false</shared>
-
- <!-- we can now have multiple cache loaders, which get chained -->
- <cacheloader>
- <class>org.jboss.cache.loader.JDBCCacheLoader</class>
- <!-- same as the old CacheLoaderConfig attribute -->
- <properties>
- cache.jdbc.table.name=jbosscache
- cache.jdbc.table.create=true
- cache.jdbc.table.drop=false
- cache.jdbc.table.primarykey=jbosscache_pk
- cache.jdbc.fqn.column=fqn
- cache.jdbc.fqn.type=varchar(255)
- cache.jdbc.node.column=node
- cache.jdbc.node.type=blob
- cache.jdbc.parent.column=parent
- cache.jdbc.sql-concat=1 || 2
- cache.jdbc.driver = org.apache.derby.jdbc.EmbeddedDriver
- cache.jdbc.url=jdbc:derby:jbossdb-1x;create=true
- cache.jdbc.user=user1
- cache.jdbc.password=user1
- </properties>
- <!-- whether the cache loader writes are asynchronous -->
- <async>false</async>
- <!-- only one cache loader in the chain may set fetchPersistentState to true.
- An exception is thrown if more than one cache loader sets this to true. -->
- <fetchPersistentState>false</fetchPersistentState>
- <!-- determines whether this cache loader ignores writes - defaults to false. -->
- <ignoreModifications>false</ignoreModifications>
- <!-- if set to true, purges the contents of this cache loader when the cache starts up.
- Defaults to false. -->
- <purgeOnStartup>false</purgeOnStartup>
- </cacheloader>
-
- </config>
- </attribute>
-
- </mbean>
-
-
- <!-- Uncomment to get a graphical view of the TreeCache MBean above -->
- <!-- <mbean code="org.jboss.cache.TreeCacheView" name="jboss.cache:service=TreeCacheView">-->
- <!-- <depends>jboss.cache:service=TreeCache</depends>-->
- <!-- <attribute name="CacheService">jboss.cache:service=TreeCache</attribute>-->
- <!-- </mbean>-->
-
-
-</server>
Deleted: core/trunk/migration/examples/cacheloader-migration/resources/transform-fcl-service.xml
===================================================================
--- core/trunk/migration/examples/cacheloader-migration/resources/transform-fcl-service.xml 2007-08-15 09:25:11 UTC (rev 4284)
+++ core/trunk/migration/examples/cacheloader-migration/resources/transform-fcl-service.xml 2007-08-15 09:25:32 UTC (rev 4285)
@@ -1,174 +0,0 @@
-<?xml version="1.0" encoding="UTF-8"?>
-
-<!-- ===================================================================== -->
-<!-- -->
-<!-- Sample TreeCache Service Configuration -->
-<!-- -->
-<!-- ===================================================================== -->
-
-<server>
-
- <classpath codebase="./lib" archives="jboss-cache.jar, jgroups.jar"/>
-
-
- <!-- ==================================================================== -->
- <!-- Defines TreeCache configuration -->
- <!-- ==================================================================== -->
-
- <mbean code="org.jboss.cache.CacheImpl"
- name="jboss.cache:service=TreeCache">
-
- <depends>jboss:service=Naming</depends>
- <depends>jboss:service=TransactionManager</depends>
-
- <!--
- Configure the TransactionManager
- -->
- <attribute name="TransactionManagerLookupClass">org.jboss.cache.transaction.GenericTransactionManagerLookup
- </attribute>
-
- <!--
- Isolation level : SERIALIZABLE
- REPEATABLE_READ (default)
- READ_COMMITTED
- READ_UNCOMMITTED
- NONE
- -->
- <attribute name="IsolationLevel">REPEATABLE_READ</attribute>
-
- <!--
- Valid modes are LOCAL
- REPL_ASYNC
- REPL_SYNC
- INVALIDATION_ASYNC
- INVALIDATION_SYNC
- -->
- <attribute name="CacheMode">LOCAL</attribute>
-
- <!--
- Just used for async repl: use a replication queue
- -->
- <attribute name="UseReplQueue">false</attribute>
-
- <!--
- Replication interval for replication queue (in ms)
- -->
- <attribute name="ReplQueueInterval">0</attribute>
-
- <!--
- Max number of elements which trigger replication
- -->
- <attribute name="ReplQueueMaxElements">0</attribute>
-
- <!-- Name of cluster. Needs to be the same for all TreeCache nodes in a
- cluster in order to find each other.
- -->
- <attribute name="ClusterName">JBossCache-Cluster</attribute>
-
- <!--Uncomment next three statements to enable JGroups multiplexer.
-This configuration is dependent on the JGroups multiplexer being
-registered in an MBean server such as JBossAS. -->
- <!--
- <depends>jgroups.mux:name=Multiplexer</depends>
- <attribute name="MultiplexerService">jgroups.mux:name=Multiplexer</attribute>
- <attribute name="MultiplexerStack">fc-fast-minimalthreads</attribute>
- -->
-
- <!-- JGroups protocol stack properties.
- ClusterConfig isn't used if the multiplexer is enabled and successfully initialized.
- -->
- <attribute name="ClusterConfig">
- <config>
- <!-- UDP: if you have a multihomed machine,
- set the bind_addr attribute to the appropriate NIC IP address -->
- <!-- UDP: On Windows machines, because of the media sense feature
- being broken with multicast (even after disabling media sense)
- set the loopback attribute to true -->
- <UDP mcast_addr="228.1.2.3" mcast_port="48866"
- ip_ttl="64" ip_mcast="true"
- mcast_send_buf_size="150000" mcast_recv_buf_size="80000"
- ucast_send_buf_size="150000" ucast_recv_buf_size="80000"
- loopback="false"/>
- <PING timeout="2000" num_initial_members="3"
- up_thread="false" down_thread="false"/>
- <MERGE2 min_interval="10000" max_interval="20000"/>
- <!-- <FD shun="true" up_thread="true" down_thread="true" />-->
- <FD_SOCK/>
- <VERIFY_SUSPECT timeout="1500"
- up_thread="false" down_thread="false"/>
- <pbcast.NAKACK gc_lag="50" retransmit_timeout="600,1200,2400,4800"
- max_xmit_size="8192" up_thread="false" down_thread="false"/>
- <UNICAST timeout="600,1200,2400" down_thread="false"/>
- <pbcast.STABLE desired_avg_gossip="20000"
- up_thread="false" down_thread="false"/>
- <pbcast.GMS join_timeout="5000" join_retry_timeout="2000"
- shun="true" print_local_addr="true"/>
- <FC max_credits="2000000" down_thread="false" up_thread="false"
- min_threshold="0.20"/>
- <FRAG frag_size="8192" down_thread="false" up_thread="true"/>
- <pbcast.STATE_TRANSFER up_thread="true" down_thread="true"/>
- </config>
- </attribute>
-
-
- <!--
- The max amount of time (in milliseconds) we wait until the
- initial state (ie. the contents of the cache) are retrieved from
- existing members in a clustered environment
- -->
- <attribute name="InitialStateRetrievalTimeout">20000</attribute>
-
- <!--
- Number of milliseconds to wait until all responses for a
- synchronous call have been received.
- -->
- <attribute name="SyncReplTimeout">20000</attribute>
-
- <!-- Max number of milliseconds to wait for a lock acquisition -->
- <attribute name="LockAcquisitionTimeout">15000</attribute>
-
- <!--
- Whether or not to fetch state on joining a cluster
- NOTE this used to be called FetchStateOnStartup and has been renamed to be more descriptive.
- -->
- <attribute name="FetchInMemoryState">false</attribute>
-
- <attribute name="CacheLoaderConfiguration">
- <config>
- <!-- if passivation is true, only the first cache loader is used; the rest are ignored -->
- <passivation>false</passivation>
- <shared>false</shared>
-
- <!-- we can now have multiple cache loaders, which get chained -->
- <cacheloader>
- <class>org.jboss.cache.loader.TransformingFileCacheLoader</class>
- <!-- same as the old CacheLoaderConfig attribute -->
- <properties>
- location=/tmp/filecacheloader-1x
- </properties>
- <!-- whether the cache loader writes are asynchronous -->
- <async>false</async>
- <!-- only one cache loader in the chain may set fetchPersistentState to true.
- An exception is thrown if more than one cache loader sets this to true. -->
- <fetchPersistentState>false</fetchPersistentState>
- <!-- determines whether this cache loader ignores writes - defaults to false. -->
- <ignoreModifications>false</ignoreModifications>
- <!-- if set to true, purges the contents of this cache loader when the cache starts up.
- Defaults to false. -->
- <purgeOnStartup>false</purgeOnStartup>
- </cacheloader>
-
- </config>
- </attribute>
-
- </mbean>
-
-
- <!-- Uncomment to get a graphical view of the TreeCache MBean above -->
- <!-- <mbean code="org.jboss.cache.TreeCacheView" name="jboss.cache:service=TreeCacheView">-->
- <!-- <depends>jboss.cache:service=TreeCache</depends>-->
- <!-- <attribute name="CacheService">jboss.cache:service=TreeCache</attribute>-->
- <!-- </mbean>-->
-
-
-</server>
Deleted: core/trunk/migration/examples/cacheloader-migration/resources/transform-jdbccl-service.xml
===================================================================
--- core/trunk/migration/examples/cacheloader-migration/resources/transform-jdbccl-service.xml 2007-08-15 09:25:11 UTC (rev 4284)
+++ core/trunk/migration/examples/cacheloader-migration/resources/transform-jdbccl-service.xml 2007-08-15 09:25:32 UTC (rev 4285)
@@ -1,187 +0,0 @@
-<?xml version="1.0" encoding="UTF-8"?>
-
-<!-- ===================================================================== -->
-<!-- -->
-<!-- Sample TreeCache Service Configuration -->
-<!-- -->
-<!-- ===================================================================== -->
-
-<server>
-
- <classpath codebase="./lib" archives="jboss-cache.jar, jgroups.jar"/>
-
-
- <!-- ==================================================================== -->
- <!-- Defines TreeCache configuration -->
- <!-- ==================================================================== -->
-
- <mbean code="org.jboss.cache.CacheImpl"
- name="jboss.cache:service=TreeCache">
-
- <depends>jboss:service=Naming</depends>
- <depends>jboss:service=TransactionManager</depends>
-
- <!--
- Configure the TransactionManager
- -->
- <attribute name="TransactionManagerLookupClass">org.jboss.cache.transaction.GenericTransactionManagerLookup
- </attribute>
-
- <!--
- Isolation level : SERIALIZABLE
- REPEATABLE_READ (default)
- READ_COMMITTED
- READ_UNCOMMITTED
- NONE
- -->
- <attribute name="IsolationLevel">REPEATABLE_READ</attribute>
-
- <!--
- Valid modes are LOCAL
- REPL_ASYNC
- REPL_SYNC
- INVALIDATION_ASYNC
- INVALIDATION_SYNC
- -->
- <attribute name="CacheMode">LOCAL</attribute>
-
- <!--
- Just used for async repl: use a replication queue
- -->
- <attribute name="UseReplQueue">false</attribute>
-
- <!--
- Replication interval for replication queue (in ms)
- -->
- <attribute name="ReplQueueInterval">0</attribute>
-
- <!--
- Max number of elements which trigger replication
- -->
- <attribute name="ReplQueueMaxElements">0</attribute>
-
- <!-- Name of cluster. Needs to be the same for all TreeCache nodes in a
- cluster in order to find each other.
- -->
- <attribute name="ClusterName">JBossCache-Cluster</attribute>
-
- <!--Uncomment next three statements to enable JGroups multiplexer.
-This configuration is dependent on the JGroups multiplexer being
-registered in an MBean server such as JBossAS. -->
- <!--
- <depends>jgroups.mux:name=Multiplexer</depends>
- <attribute name="MultiplexerService">jgroups.mux:name=Multiplexer</attribute>
- <attribute name="MultiplexerStack">fc-fast-minimalthreads</attribute>
- -->
-
- <!-- JGroups protocol stack properties.
- ClusterConfig isn't used if the multiplexer is enabled and successfully initialized.
- -->
- <attribute name="ClusterConfig">
- <config>
- <!-- UDP: if you have a multihomed machine,
- set the bind_addr attribute to the appropriate NIC IP address -->
- <!-- UDP: On Windows machines, because of the media sense feature
- being broken with multicast (even after disabling media sense)
- set the loopback attribute to true -->
- <UDP mcast_addr="228.1.2.3" mcast_port="48866"
- ip_ttl="64" ip_mcast="true"
- mcast_send_buf_size="150000" mcast_recv_buf_size="80000"
- ucast_send_buf_size="150000" ucast_recv_buf_size="80000"
- loopback="false"/>
- <PING timeout="2000" num_initial_members="3"
- up_thread="false" down_thread="false"/>
- <MERGE2 min_interval="10000" max_interval="20000"/>
- <!-- <FD shun="true" up_thread="true" down_thread="true" />-->
- <FD_SOCK/>
- <VERIFY_SUSPECT timeout="1500"
- up_thread="false" down_thread="false"/>
- <pbcast.NAKACK gc_lag="50" retransmit_timeout="600,1200,2400,4800"
- max_xmit_size="8192" up_thread="false" down_thread="false"/>
- <UNICAST timeout="600,1200,2400" down_thread="false"/>
- <pbcast.STABLE desired_avg_gossip="20000"
- up_thread="false" down_thread="false"/>
- <pbcast.GMS join_timeout="5000" join_retry_timeout="2000"
- shun="true" print_local_addr="true"/>
- <FC max_credits="2000000" down_thread="false" up_thread="false"
- min_threshold="0.20"/>
- <FRAG frag_size="8192" down_thread="false" up_thread="true"/>
- <pbcast.STATE_TRANSFER up_thread="true" down_thread="true"/>
- </config>
- </attribute>
-
-
- <!--
- The max amount of time (in milliseconds) we wait until the
- initial state (ie. the contents of the cache) are retrieved from
- existing members in a clustered environment
- -->
- <attribute name="InitialStateRetrievalTimeout">20000</attribute>
-
- <!--
- Number of milliseconds to wait until all responses for a
- synchronous call have been received.
- -->
- <attribute name="SyncReplTimeout">20000</attribute>
-
- <!-- Max number of milliseconds to wait for a lock acquisition -->
- <attribute name="LockAcquisitionTimeout">15000</attribute>
-
- <!--
- Whether or not to fetch state on joining a cluster
- NOTE this used to be called FetchStateOnStartup and has been renamed to be more descriptive.
- -->
- <attribute name="FetchInMemoryState">false</attribute>
-
- <attribute name="CacheLoaderConfiguration">
- <config>
- <!-- if passivation is true, only the first cache loader is used; the rest are ignored -->
- <passivation>false</passivation>
- <shared>false</shared>
-
- <!-- we can now have multiple cache loaders, which get chained -->
- <cacheloader>
- <class>org.jboss.cache.loader.TransformingJDBCCacheLoader</class>
- <!-- same as the old CacheLoaderConfig attribute -->
- <properties>
- cache.jdbc.table.name=jbosscache
- cache.jdbc.table.create=true
- cache.jdbc.table.drop=false
- cache.jdbc.table.primarykey=jbosscache_pk
- cache.jdbc.fqn.column=fqn
- cache.jdbc.fqn.type=varchar(255)
- cache.jdbc.node.column=node
- cache.jdbc.node.type=blob
- cache.jdbc.parent.column=parent
- cache.jdbc.sql-concat=1 || 2
- cache.jdbc.driver = org.apache.derby.jdbc.EmbeddedDriver
- cache.jdbc.url=jdbc:derby:jbossdb-1x;create=true
- cache.jdbc.user=user1
- cache.jdbc.password=user1
- </properties>
- <!-- whether the cache loader writes are asynchronous -->
- <async>false</async>
- <!-- only one cache loader in the chain may set fetchPersistentState to true.
- An exception is thrown if more than one cache loader sets this to true. -->
- <fetchPersistentState>false</fetchPersistentState>
- <!-- determines whether this cache loader ignores writes - defaults to false. -->
- <ignoreModifications>false</ignoreModifications>
- <!-- if set to true, purges the contents of this cache loader when the cache starts up.
- Defaults to false. -->
- <purgeOnStartup>false</purgeOnStartup>
- </cacheloader>
-
- </config>
- </attribute>
-
- </mbean>
-
-
- <!-- Uncomment to get a graphical view of the TreeCache MBean above -->
- <!-- <mbean code="org.jboss.cache.TreeCacheView" name="jboss.cache:service=TreeCacheView">-->
- <!-- <depends>jboss.cache:service=TreeCache</depends>-->
- <!-- <attribute name="CacheService">jboss.cache:service=TreeCache</attribute>-->
- <!-- </mbean>-->
-
-
-</server>
Deleted: core/trunk/migration/examples/cacheloader-migration/src/examples/TransformStore.java
===================================================================
--- core/trunk/migration/examples/cacheloader-migration/src/examples/TransformStore.java 2007-08-15 09:25:11 UTC (rev 4284)
+++ core/trunk/migration/examples/cacheloader-migration/src/examples/TransformStore.java 2007-08-15 09:25:32 UTC (rev 4285)
@@ -1,87 +0,0 @@
-/*
- * JBoss, the OpenSource J2EE webOS
- *
- * Distributable under LGPL license.
- * See terms of license at gnu.org.
- */
-package examples;
-
-import org.jboss.cache.DefaultCacheFactory;
-import org.jboss.cache.Cache;
-import org.jboss.cache.Node;
-import org.apache.commons.logging.Log;
-import org.apache.commons.logging.LogFactory;
-
-/**
- * Cache store transforming example
- *
- * @author <a href="mailto:galder.zamarreno at jboss.com">Galder Zamarreno</a>
- */
-public class TransformStore
-{
- /* Type of cache loader, either use "jdbccl" for JDBCCacheLoader or "fcl" for FileCacheLoader */
- public static final String CL_TYPE = System.getProperty("cacheloader.type", "jdbccl");
-
- private static Log log = LogFactory.getLog(TransformStore.class);
-
- public static void main(String[] args) throws Exception
- {
- TransformStore ts = new TransformStore();
-
- String transformConfigName = "transform-" + CL_TYPE + "-service.xml";
- log.info("Transforming configuration file: " + transformConfigName);
- Cache transformingCache = ts.createAndStartCache(transformConfigName);
- ts.transformCacheStore(transformingCache);
- ts.stopAndDestroyCache(transformingCache);
-
- String originalConfigName = "original-" + CL_TYPE + "-service.xml";
- log.info("Original configuration file: " + originalConfigName);
- Cache checkingCache = ts.createAndStartCache(originalConfigName);
- ts.checkCacheStore(checkingCache);
- ts.stopAndDestroyCache(checkingCache);
- }
-
- public Cache createAndStartCache(String configFile)
- {
- return DefaultCacheFactory.getInstance().createCache(configFile, true);
- }
-
- public void stopAndDestroyCache(Cache cache)
- {
- cache.stop();
- cache.destroy();
- }
-
- public void transformCacheStore(Cache cache)
- {
- log.info("Transforming 1.x cache store");
- transformNode(cache, cache.getRoot());
- log.info("Cache store transformed to 2.x format");
- }
-
- public void transformNode(Cache cache, Node<Object, Object> node)
- {
- cache.put(node.getFqn(), node.getData());
- log.info(node.getFqn() + " transformed");
-
- for (Node child : node.getChildren())
- {
- transformNode(cache, child);
- }
- }
-
- public void checkCacheStore(Cache cache)
- {
- checkNode(cache, cache.getRoot());
- }
-
- public void checkNode(Cache cache, Node<Object, Object> node)
- {
- log.info("Node: " + node.getFqn() + " | Data: " + node.getData());
-
- for (Node child : node.getChildren())
- {
- checkNode(cache, child);
- }
- }
-}
Deleted: core/trunk/migration/src/org/jboss/cache/loader/TransformingFileCacheLoader.java
===================================================================
--- core/trunk/migration/src/org/jboss/cache/loader/TransformingFileCacheLoader.java 2007-08-15 09:25:11 UTC (rev 4284)
+++ core/trunk/migration/src/org/jboss/cache/loader/TransformingFileCacheLoader.java 2007-08-15 09:25:32 UTC (rev 4285)
@@ -1,31 +0,0 @@
-/*
- * JBoss, the OpenSource J2EE webOS
- *
- * Distributable under LGPL license.
- * See terms of license at gnu.org.
- */
-package org.jboss.cache.loader;
-
-import org.jboss.util.stream.MarshalledValueInputStream;
-
-import java.io.FileInputStream;
-import java.io.File;
-
-/**
- * Transforming file cache loader. It unmarshalls (read from file store) data in the way
- * JBossCache 1.x did.
- *
- * @author <a href="mailto:galder.zamarreno at jboss.com">Galder Zamarreno</a>
- */
-public class TransformingFileCacheLoader extends FileCacheLoader
-{
- @Override
- protected Object unmarshall(File from) throws Exception
- {
- FileInputStream in = new FileInputStream(from);
- MarshalledValueInputStream input = new MarshalledValueInputStream(in);
- Object unmarshalledObj = input.readObject();
- in.close();
- return unmarshalledObj;
- }
-}
Deleted: core/trunk/migration/src/org/jboss/cache/loader/TransformingJDBCCacheLoader.java
===================================================================
--- core/trunk/migration/src/org/jboss/cache/loader/TransformingJDBCCacheLoader.java 2007-08-15 09:25:11 UTC (rev 4284)
+++ core/trunk/migration/src/org/jboss/cache/loader/TransformingJDBCCacheLoader.java 2007-08-15 09:25:32 UTC (rev 4285)
@@ -1,41 +0,0 @@
-/*
- * JBoss, the OpenSource J2EE webOS
- *
- * Distributable under LGPL license.
- * See terms of license at gnu.org.
- */
-package org.jboss.cache.loader;
-
-import org.jboss.invocation.MarshalledValue;
-
-import java.io.ObjectInputStream;
-import java.io.InputStream;
-import java.rmi.MarshalledObject;
-
-/**
- * Transforming JDBC cache loader. It unmarshalls (read from JDBC db store) data in the way
- * JBossCache 1.x did.
- *
- * @author <a href="mailto:galder.zamarreno at jboss.com">Galder Zamarreno</a>
- */
-public class TransformingJDBCCacheLoader extends JDBCCacheLoader
-{
- @Override
- protected Object unmarshall(InputStream from) throws Exception
- {
- ObjectInputStream ois = new ObjectInputStream(from);
- Object marshalledNode = ois.readObject();
-
- // de-marshall value if possible
- if(marshalledNode instanceof MarshalledValue)
- {
- return ((MarshalledValue) marshalledNode).get();
- }
- else if(marshalledNode instanceof MarshalledObject)
- {
- return ((MarshalledObject) marshalledNode).get();
- }
-
- return null;
- }
-}
Deleted: core/trunk/migration/tests/functional/org/jboss/cache/loader/TransformingCacheLoaderTestBase.java
===================================================================
--- core/trunk/migration/tests/functional/org/jboss/cache/loader/TransformingCacheLoaderTestBase.java 2007-08-15 09:25:11 UTC (rev 4284)
+++ core/trunk/migration/tests/functional/org/jboss/cache/loader/TransformingCacheLoaderTestBase.java 2007-08-15 09:25:32 UTC (rev 4285)
@@ -1,86 +0,0 @@
-/*
- * JBoss, the OpenSource J2EE webOS
- *
- * Distributable under LGPL license.
- * See terms of license at gnu.org.
- */
-package org.jboss.cache.loader;
-
-import org.jboss.cache.CacheImpl;
-import org.jboss.cache.DefaultCacheFactory;
-import org.jboss.cache.config.Configuration;
-
-import java.util.HashMap;
-
-/**
- * Transforming cache loader test base.
- *
- * @author <a href="mailto:galder.zamarreno at jboss.com">Galder Zamarreno</a>
- */
-public class TransformingCacheLoaderTestBase extends AbstractCacheLoaderTestBase
-{
- private static final String CAPITAL = "capital";
- private static final String CURRENCY = "currency";
- private static final String POPULATION = "population";
- private static final String AREA = "area";
- private static final String EUROPE_NODE = "Europe";
-
- protected CacheImpl createCache() throws Exception
- {
- CacheImpl cache = (CacheImpl) DefaultCacheFactory.getInstance().createCache(false);
- Configuration c = new Configuration();
- cache.setConfiguration(c);
- c.setCacheMode(Configuration.CacheMode.LOCAL);
- c.setTransactionManagerLookupClass("org.jboss.cache.transaction.DummyTransactionManagerLookup");
- return cache;
- }
-
- protected void loadCache(CacheImpl cache) throws Exception
- {
- cache.put(EUROPE_NODE, new HashMap());
- cache.put("Europe/Austria", new HashMap());
- cache.put("Europe/Austria", CAPITAL, "Vienna");
- cache.put("Europe/Austria", CURRENCY, "Euro");
- cache.put("Europe/Austria", POPULATION, new Integer(8184691));
-
- cache.put("Europe/England", new HashMap());
- cache.put("Europe/England", CAPITAL, "London");
- cache.put("Europe/England", CURRENCY, "British Pound");
- cache.put("Europe/England", POPULATION, new Integer(60441457));
-
- HashMap albania = new HashMap(4);
- albania.put(CAPITAL, "Tirana");
- albania.put(CURRENCY, "Lek");
- albania.put(POPULATION, new Integer(3563112));
- albania.put(AREA, new Integer(28748));
- cache.put("Europe/Albania", albania);
-
- HashMap hungary = new HashMap(4);
- hungary.put(CAPITAL, "Budapest");
- hungary.put(CURRENCY, "Forint");
- hungary.put(POPULATION, new Integer(10006835));
- hungary.put(AREA, new Integer(93030));
- cache.put("Europe/Hungary", hungary);
- }
-
- protected void checkData(CacheImpl cache) throws Exception
- {
- assertEquals("Vienna", cache.get("Europe/Austria", CAPITAL));
- assertEquals("Euro", cache.get("Europe/Austria", CURRENCY));
- assertEquals(8184691, cache.get("Europe/Austria", POPULATION));
-
- assertEquals("London", cache.get("Europe/England", CAPITAL));
- assertEquals("British Pound", cache.get("Europe/England", CURRENCY));
- assertEquals(60441457, cache.get("Europe/England", POPULATION));
-
- assertEquals("Tirana", cache.get("Europe/Albania", CAPITAL));
- assertEquals("Lek", cache.get("Europe/Albania", CURRENCY));
- assertEquals(3563112, cache.get("Europe/Albania", POPULATION));
- assertEquals(28748, cache.get("Europe/Albania", AREA));
-
- assertEquals("Budapest", cache.get("Europe/Hungary", CAPITAL));
- assertEquals("Forint", cache.get("Europe/Hungary", CURRENCY));
- assertEquals(10006835, cache.get("Europe/Hungary", POPULATION));
- assertEquals(93030, cache.get("Europe/Hungary", AREA));
- }
-}
Deleted: core/trunk/migration/tests/functional/org/jboss/cache/loader/TransformingFileCacheLoaderTest.java
===================================================================
--- core/trunk/migration/tests/functional/org/jboss/cache/loader/TransformingFileCacheLoaderTest.java 2007-08-15 09:25:11 UTC (rev 4284)
+++ core/trunk/migration/tests/functional/org/jboss/cache/loader/TransformingFileCacheLoaderTest.java 2007-08-15 09:25:32 UTC (rev 4285)
@@ -1,83 +0,0 @@
-/*
- * JBoss, the OpenSource J2EE webOS
- *
- * Distributable under LGPL license.
- * See terms of license at gnu.org.
- */
-package org.jboss.cache.loader;
-
-import junit.framework.TestCase;
-
-import java.io.FileOutputStream;
-import java.io.File;
-import java.io.ObjectOutputStream;
-import java.io.IOException;
-import java.io.FileInputStream;
-import java.nio.channels.FileChannel;
-import java.util.HashMap;
-
-import org.jboss.cache.marshall.ObjectSerializationFactory;
-import org.jboss.cache.CacheImpl;
-import org.jboss.cache.DefaultCacheFactory;
-import org.jboss.cache.Fqn;
-import org.jboss.cache.misc.TestingUtil;
-import org.jboss.cache.config.Configuration;
-
-/**
- * Unit tests for TransformingFileCacheLoader
- *
- * @author <a href="mailto:galder.zamarreno at jboss.com">Galder Zamarreno</a>
- */
-public class TransformingFileCacheLoaderTest extends TransformingCacheLoaderTestBase
-{
- private CacheImpl cache;
- private String targetLoc;
-
- @Override
- protected void setUp() throws Exception
- {
- super.setUp(); //To change body of overridden methods use File | Settings | File Templates.
-
- String targetDir = System.getProperty("java.io.tmpdir", "/tmp");
- targetLoc = targetDir + "/filecacheloader-1x";
-
- cache = createCache();
-
- cache.getConfiguration().setCacheLoaderConfig(getSingleCacheLoaderConfig("",
- "org.jboss.cache.loader.TransformingFileCacheLoaderTest$LegacyFileCacheLoader",
- "location=" + targetLoc, false, true, false));
-
- TestingUtil.recursiveFileRemove(targetLoc);
- }
-
- @Override
- protected void tearDown() throws Exception
- {
- cache.stop();
- cache.destroy();
- TestingUtil.recursiveFileRemove(targetLoc);
- }
-
- public void testPutGetData() throws Exception
- {
- cache.start();
-
- loadCache(cache);
-
- cache.evict(Fqn.fromString("/"), true);
-
- checkData(cache);
- }
-
- public static class LegacyFileCacheLoader extends TransformingFileCacheLoader
- {
- @Override
- protected void marshall(Object obj, File to) throws Exception
- {
- FileOutputStream out = new FileOutputStream(to);
- ObjectOutputStream output = new ObjectOutputStream(out);
- output.writeObject(obj);
- out.close();
- }
- }
-}
Deleted: core/trunk/migration/tests/functional/org/jboss/cache/loader/TransformingJDBCCacheLoaderTest.java
===================================================================
--- core/trunk/migration/tests/functional/org/jboss/cache/loader/TransformingJDBCCacheLoaderTest.java 2007-08-15 09:25:11 UTC (rev 4284)
+++ core/trunk/migration/tests/functional/org/jboss/cache/loader/TransformingJDBCCacheLoaderTest.java 2007-08-15 09:25:32 UTC (rev 4285)
@@ -1,99 +0,0 @@
-/*
- * JBoss, the OpenSource J2EE webOS
- *
- * Distributable under LGPL license.
- * See terms of license at gnu.org.
- */
-package org.jboss.cache.loader;
-
-import org.jboss.cache.CacheImpl;
-import org.jboss.cache.Fqn;
-import org.jboss.invocation.MarshalledValue;
-import org.apache.commons.logging.Log;
-import org.apache.commons.logging.LogFactory;
-
-import java.util.Properties;
-import java.io.ByteArrayOutputStream;
-import java.io.ObjectOutputStream;
-
-/**
- * Unit tests for TransformingJDBCCacheLoader
- *
- * @author <a href="mailto:galder.zamarreno at jboss.com">Galder Zamarreno</a>
- */
-public class TransformingJDBCCacheLoaderTest extends TransformingCacheLoaderTestBase
-{
- private CacheImpl cache;
-
- @Override
- protected void setUp() throws Exception
- {
- super.setUp();
-
- cache = createCache();
-
- Properties prop = getProperties();
-
- String cacheJdbcUrl = changeDbName(prop.getProperty("cache.jdbc.url"));
-
- String props = "cache.jdbc.driver =" + prop.getProperty("cache.jdbc.driver") + "\n" +
- "cache.jdbc.url=" + cacheJdbcUrl + "\n" +
- "cache.jdbc.user=" + prop.getProperty("cache.jdbc.user") + "\n" +
- "cache.jdbc.password=" + prop.getProperty("cache.jdbc.password") + "\n" +
- "cache.jdbc.node.type=" + prop.getProperty("cache.jdbc.node.type") + "\n" +
- "cache.jdbc.sql-concat=" + prop.getProperty("cache.jdbc.sql-concat");
-
- cache.getConfiguration().setCacheLoaderConfig(getSingleCacheLoaderConfig("",
- "org.jboss.cache.loader.TransformingJDBCCacheLoaderTest$LegacyJDBCCacheLoader", props, false, true, false));
- }
-
- @Override
- protected void tearDown() throws Exception
- {
- cache.stop();
- cache.destroy();
- }
-
- public void testPutGetData() throws Exception
- {
- cache.start();
-
- loadCache(cache);
-
- cache.evict(Fqn.fromString("/"), true);
-
- checkData(cache);
- }
-
- protected Properties getProperties() throws Exception
- {
- Properties properties = new Properties();
- try
- {
- properties.load(this.getClass().getClassLoader().getResourceAsStream("cache-jdbc.properties"));
- return properties;
- }
- catch (Exception e)
- {
- throw new Exception("Error loading jdbc properties ", e);
- }
- }
-
- private String changeDbName(String url)
- {
- return url.replaceFirst("jbossdb", "jbossdb-1x");
- }
-
- public static class LegacyJDBCCacheLoader extends TransformingJDBCCacheLoader
- {
- @Override
- protected byte[] marshall(Object obj) throws Exception
- {
- Object marshalledNode = new MarshalledValue(obj);
- ByteArrayOutputStream baos = new ByteArrayOutputStream();
- ObjectOutputStream oos = new ObjectOutputStream(baos);
- oos.writeObject(marshalledNode);
- return baos.toByteArray();
- }
- }
-}
More information about the jbosscache-commits
mailing list