Move Qi4j related projects in a `qi4j/` subfolder
Project: http://git-wip-us.apache.org/repos/asf/zest-sandbox/repo Commit: http://git-wip-us.apache.org/repos/asf/zest-sandbox/commit/d4dd9c17 Tree: http://git-wip-us.apache.org/repos/asf/zest-sandbox/tree/d4dd9c17 Diff: http://git-wip-us.apache.org/repos/asf/zest-sandbox/diff/d4dd9c17 Branch: refs/heads/develop Commit: d4dd9c17609e75d1e65b44e7044f20b861cc13b7 Parents: 707b73f Author: Paul Merlin <[email protected]> Authored: Tue Apr 21 13:48:59 2015 +0200 Committer: Paul Merlin <[email protected]> Committed: Tue Apr 21 13:48:59 2015 +0200 ---------------------------------------------------------------------- .gitignore | 59 +-- etc/codestyle-idea.jar | Bin 1753 -> 0 bytes extensions/entitystore-cassandra/LICENSE | 177 ------- extensions/entitystore-cassandra/NOTICE | 19 - extensions/entitystore-cassandra/dev-status.xml | 16 - extensions/entitystore-cassandra/pom.xml | 111 ----- .../cassandra/CassandraConfiguration.java | 23 - .../cassandra/CassandraEntityStoreService.java | 32 -- .../cassandra/CassandraMapEntityStoreMixin.java | 200 -------- .../CassandraConfigurationService.java | 57 --- .../cassandra/CassandraEntityStoreTest.java | 46 -- .../src/test/resources/log4j.properties | 7 - .../src/test/resources/storage-conf.xml | 347 -------------- extensions/entitystore-coherence/.gitignore | 1 - extensions/entitystore-coherence/osgi.bundle | 285 ----------- extensions/entitystore-coherence/pom.xml | 45 -- .../coherence/CoherenceConfiguration.java | 27 -- .../CoherenceEntityStoreAssembler.java | 46 -- .../coherence/CoherenceEntityStoreMixin.java | 216 --------- .../coherence/CoherenceEntityStoreService.java | 39 -- .../entitystore/coherence/DatabaseExport.java | 34 -- .../entitystore/coherence/DatabaseImport.java | 34 -- .../coherence/CoherenceEntityStoreTest.java | 66 --- .../CoherenceEntityStoreService.properties | 4 - extensions/entitystore-jgroups/LICENSE | 177 ------- extensions/entitystore-jgroups/NOTICE | 23 - .../licenses/commons-logging.license | 177 ------- .../licenses/jgroups.license | 458 ------------------ extensions/entitystore-jgroups/osgi.bundle | 59 --- extensions/entitystore-jgroups/pom.xml | 61 --- .../jgroups/JGroupsEntityStoreMixin.java | 148 ------ .../jgroups/JGroupsEntityStoreService.java | 39 -- .../jgroups/JGroupsEntityStoreTest.java | 252 ---------- extensions/entitystore-jndi/.gitignore | 1 - extensions/entitystore-jndi/osgi.bundle | 30 -- extensions/entitystore-jndi/pom.xml | 50 -- .../entitystore/jndi/JndiConfiguration.java | 284 ----------- .../qi4j/entitystore/jndi/JndiEntityState.java | 157 ------ .../jndi/JndiEntityStoreAssembler.java | 44 -- .../entitystore/jndi/JndiEntityStoreMixin.java | 129 ----- .../jndi/JndiEntityStoreService.java | 33 -- .../org/qi4j/entitystore/jndi/JndiSetup.java | 32 -- .../java/org/qi4j/entitystore/jndi/JndiUow.java | 239 --------- .../java/org/qi4j/entitystore/jndi/Group.java | 26 - .../org/qi4j/entitystore/jndi/GroupEntity.java | 24 - .../jndi/JndiReadEntityStoreTest.java | 82 ---- .../java/org/qi4j/entitystore/jndi/User.java | 27 -- .../org/qi4j/entitystore/jndi/UserEntity.java | 24 - .../jndi/JndiEntityStoreService.properties | 59 --- extensions/entitystore-rmi/dev-status.xml | 14 - extensions/entitystore-rmi/osgi.bundle | 26 - extensions/entitystore-rmi/pom.xml | 44 -- .../rmi/ClientRmiEntityStoreMixin.java | 77 --- .../rmi/ClientRmiEntityStoreService.java | 32 -- .../entitystore/rmi/RegistryConfiguration.java | 13 - .../org/qi4j/entitystore/rmi/RegistryMixin.java | 53 -- .../qi4j/entitystore/rmi/RegistryService.java | 15 - .../qi4j/entitystore/rmi/RemoteEntityStore.java | 20 - .../rmi/ServerRemoteEntityStoreMixin.java | 216 --------- .../rmi/ServerRmiEntityStoreService.java | 31 -- .../entitystore/rmi/RegistryService.properties | 1 - extensions/entitystore-s3/.gitignore | 1 - extensions/entitystore-s3/LICENSE | 177 ------- extensions/entitystore-s3/NOTICE | 22 - extensions/entitystore-s3/dev-status.xml | 14 - .../licenses/commons-logging.license | 177 ------- .../entitystore-s3/licenses/jets3t.license | 177 ------- extensions/entitystore-s3/osgi.bundle | 28 -- extensions/entitystore-s3/pom.xml | 45 -- .../qi4j/entitystore/s3/S3Configuration.java | 15 - .../entitystore/s3/S3EntityStoreService.java | 33 -- .../s3/S3SerializationStoreMixin.java | 109 ----- .../qi4j/entitystore/s3/S3EntityStoreTest.java | 47 -- .../s3/S3EntityStoreComposite.properties | 2 - extensions/entitystore-swift/osgi.bundle | 33 -- extensions/entitystore-swift/pom.xml | 48 -- .../qi4j/entitystore/swift/BucketManager.java | 142 ------ .../org/qi4j/entitystore/swift/DataBlock.java | 121 ----- .../org/qi4j/entitystore/swift/DataStore.java | 480 ------------------- .../org/qi4j/entitystore/swift/FileUtils.java | 41 -- .../org/qi4j/entitystore/swift/HeapDump.java | 91 ---- .../qi4j/entitystore/swift/IdentityFile.java | 302 ------------ .../swift/IdentityFileClosedException.java | 24 - .../swift/IdentityTooLongException.java | 30 -- .../MalformedIdentityDirectoryException.java | 35 -- .../qi4j/entitystore/swift/RecordManager.java | 197 -------- .../qi4j/entitystore/swift/StoreIterator.java | 106 ---- .../entitystore/swift/SwiftConfiguration.java | 32 -- .../swift/SwiftEntityStoreAssembler.java | 42 -- .../swift/SwiftEntityStoreMixin.java | 162 ------- .../swift/SwiftEntityStoreService.java | 35 -- .../org/qi4j/entitystore/swift/UndoCommand.java | 28 -- .../entitystore/swift/UndoDeleteCommand.java | 73 --- .../swift/UndoDropIdentityCommand.java | 56 --- .../entitystore/swift/UndoExtendCommand.java | 68 --- .../org/qi4j/entitystore/swift/UndoManager.java | 23 - .../entitystore/swift/UndoModifyCommand.java | 81 ---- .../swift/UndoNewIdentityCommand.java | 53 -- .../quick/QuickEntityStoreService.properties | 17 - .../qi4j/entitystore/swift/DataFileTest.java | 184 ------- .../entitystore/swift/IdentityFileTest.java | 196 -------- .../entitystore/swift/SwiftEntityStoreTest.java | 43 -- .../swift/SwiftStorePerformanceTest.java | 37 -- .../swift/SwiftEntityStoreService.properties | 1 - extensions/pom.xml | 25 - libraries/beans/dev-status.xml | 14 - libraries/beans/pom.xml | 41 -- .../qi4j/library/beans/properties/Getters.java | 21 - .../library/beans/properties/Iterables.java | 40 -- .../beans/properties/MethodPrefixFilter.java | 47 -- .../beans/properties/OrAppliesToFilter.java | 40 -- .../library/beans/properties/Properties.java | 108 ----- .../beans/properties/PropertiesMixin.java | 142 ------ .../beans/properties/PropertyNameExtractor.java | 18 - .../qi4j/library/beans/properties/Setters.java | 21 - .../beans/support/DelegatingIterator.java | 53 -- .../beans/support/DelegatingListIterator.java | 83 ---- .../beans/support/JavabeanAssociation.java | 97 ---- .../beans/support/JavabeanManyAssociation.java | 202 -------- .../library/beans/support/JavabeanMixin.java | 139 ------ .../library/beans/support/JavabeanProperty.java | 123 ----- .../library/beans/support/JavabeanSupport.java | 33 -- .../org/qi4j/library/beans/support/Wrapper.java | 47 -- .../beans/properties/PropertiesMixinTest.java | 229 --------- .../beans/support/JavabeanBackedTest.java | 214 --------- libraries/entityproxy/pom.xml | 45 -- .../qi4j/library/entityproxy/EntityProxy.java | 84 ---- .../library/entityproxy/EntityProxyHelper.java | 66 --- .../qi4j/library/entityproxy/MutualType.java | 28 -- .../NoCommonClassFoundException.java | 28 -- .../library/entityproxy/ProxyableEntity.java | 143 ------ .../assembling/EntityProxyAssembler.java | 43 -- .../entityproxy/internal/EntityProxyCache.java | 110 ----- .../internal/EntityProxyCacheService.java | 31 -- .../library/entityproxy/EntityProxyTest.java | 130 ----- .../entityproxy/EntityWithMutualType.java | 41 -- .../entityproxy/MissingMutualTypeEntity.java | 39 -- .../org/qi4j/library/entityproxy/SomeRole.java | 84 ---- libraries/exception/dev-status.xml | 14 - libraries/exception/licenses/.svn/all-wcprops | 5 - libraries/exception/licenses/.svn/entries | 28 -- libraries/exception/licenses/.svn/format | 1 - libraries/exception/pom.xml | 37 -- libraries/exception/src/.svn/all-wcprops | 5 - libraries/exception/src/.svn/entries | 34 -- libraries/exception/src/.svn/format | 1 - libraries/exception/src/main/.svn/all-wcprops | 5 - libraries/exception/src/main/.svn/entries | 31 -- libraries/exception/src/main/.svn/format | 1 - .../exception/src/main/java/.svn/all-wcprops | 5 - libraries/exception/src/main/java/.svn/entries | 31 -- libraries/exception/src/main/java/.svn/format | 1 - .../src/main/java/org/.svn/all-wcprops | 5 - .../exception/src/main/java/org/.svn/entries | 31 -- .../exception/src/main/java/org/.svn/format | 1 - .../src/main/java/org/qi4j/.svn/all-wcprops | 5 - .../src/main/java/org/qi4j/.svn/entries | 31 -- .../src/main/java/org/qi4j/.svn/format | 1 - .../main/java/org/qi4j/library/.svn/all-wcprops | 5 - .../src/main/java/org/qi4j/library/.svn/entries | 31 -- .../src/main/java/org/qi4j/library/.svn/format | 1 - .../org/qi4j/library/exception/.svn/all-wcprops | 65 --- .../org/qi4j/library/exception/.svn/entries | 158 ------ .../java/org/qi4j/library/exception/.svn/format | 1 - .../DelegatingExceptionObserver.java.svn-base | 5 - .../prop-base/ExceptionHandling.java.svn-base | 5 - ...ionHandlingNotificationConcern.java.svn-base | 5 - .../prop-base/ExceptionObservable.java.svn-base | 5 - .../ExceptionObservableMixin.java.svn-base | 5 - .../prop-base/ExceptionObserver.java.svn-base | 5 - .../NullExceptionHandling.java.svn-base | 5 - ...rvableExceptionHandlingService.java.svn-base | 5 - ...SimpleExceptionHandlingService.java.svn-base | 5 - ...ystemErrExceptionHandlingMixin.java.svn-base | 5 - .../DelegatingExceptionObserver.java.svn-base | 85 ---- .../text-base/ExceptionHandling.java.svn-base | 23 - ...ionHandlingNotificationConcern.java.svn-base | 41 -- .../text-base/ExceptionObservable.java.svn-base | 25 - .../ExceptionObservableMixin.java.svn-base | 64 --- .../text-base/ExceptionObserver.java.svn-base | 23 - .../NullExceptionHandling.java.svn-base | 27 -- ...rvableExceptionHandlingService.java.svn-base | 29 -- ...SimpleExceptionHandlingService.java.svn-base | 26 - ...ystemErrExceptionHandlingMixin.java.svn-base | 29 -- .../exception/DelegatingExceptionObserver.java | 85 ---- .../library/exception/ExceptionHandling.java | 23 - .../ExceptionHandlingNotificationConcern.java | 41 -- .../library/exception/ExceptionObservable.java | 25 - .../exception/ExceptionObservableMixin.java | 64 --- .../library/exception/ExceptionObserver.java | 23 - .../exception/NullExceptionHandling.java | 27 -- .../ObservableExceptionHandlingService.java | 29 -- .../SimpleExceptionHandlingService.java | 26 - .../SystemErrExceptionHandlingMixin.java | 29 -- libraries/exception/src/test/.svn/all-wcprops | 5 - libraries/exception/src/test/.svn/entries | 31 -- libraries/exception/src/test/.svn/format | 1 - .../exception/src/test/java/.svn/all-wcprops | 5 - libraries/exception/src/test/java/.svn/entries | 31 -- libraries/exception/src/test/java/.svn/format | 1 - .../src/test/java/org/.svn/all-wcprops | 5 - .../exception/src/test/java/org/.svn/entries | 31 -- .../exception/src/test/java/org/.svn/format | 1 - .../src/test/java/org/qi4j/.svn/all-wcprops | 5 - .../src/test/java/org/qi4j/.svn/entries | 31 -- .../src/test/java/org/qi4j/.svn/format | 1 - .../test/java/org/qi4j/library/.svn/all-wcprops | 5 - .../src/test/java/org/qi4j/library/.svn/entries | 31 -- .../src/test/java/org/qi4j/library/.svn/format | 1 - .../org/qi4j/library/exception/.svn/all-wcprops | 5 - .../org/qi4j/library/exception/.svn/entries | 28 -- .../java/org/qi4j/library/exception/.svn/format | 1 - libraries/executor/dev-status.xml | 14 - libraries/executor/pom.xml | 38 -- .../qi4j/library/executor/ExecuteService.java | 28 -- .../library/executor/ExecuteSideEffect.java | 30 -- .../qi4j/library/executor/ExecutorMixin.java | 45 -- .../library/executor/ExecutorSideEffect.java | 94 ---- .../executor/ExecuteSideEffectTest.java | 75 --- libraries/ldap/client/pom.xml | 19 - libraries/ldap/pom.xml | 19 - libraries/ldap/server/pom.xml | 40 -- .../server/ApacheDirectoryServiceMixin.java | 142 ------ .../java/org/qi4j/library/ldap/server/Ldap.java | 24 - .../library/ldap/server/LdapConfiguration.java | 32 -- .../qi4j/library/ldap/server/LdapService.java | 27 -- .../library/ldap/server/LdapServerTest.java | 51 -- .../library/ldap/server/LdapService.properties | 2 - libraries/observations/pom.xml | 24 - .../library/observations/MulticastObserver.java | 99 ---- .../qi4j/library/observations/Observable.java | 29 -- .../library/observations/ObservableMixin.java | 99 ---- .../qi4j/library/observations/Observation.java | 22 - .../org/qi4j/library/observations/Observer.java | 23 - libraries/pom.xml | 26 - libraries/registry/dev-status.xml | 14 - libraries/registry/pom.xml | 24 - .../org/qi4j/library/registry/Registry.java | 31 -- .../library/registry/RegistryAssembler.java | 32 -- .../qi4j/library/registry/RegistryMixin.java | 121 ----- .../qi4j/library/registry/RegistryObserver.java | 26 - .../qi4j/library/registry/RegistryService.java | 26 - libraries/rmi/dev-status.xml | 14 - libraries/rmi/pom.xml | 42 -- .../java/org/qi4j/library/rmi/RMIMixin.java | 51 -- .../java/org/qi4j/library/rmi/RMIMixinTest.java | 67 --- .../library/rmi/remote/RemoteInterface.java | 28 -- .../rmi/remote/RemoteInterfaceComposite.java | 30 -- .../library/rmi/remote/RemoteInterfaceImpl.java | 37 -- libraries/thread/dev-status.xml | 14 - libraries/thread/pom.xml | 43 -- .../library/thread/MaximumThreadsException.java | 34 -- .../thread/NewThreadServiceComposite.java | 26 - .../library/thread/NewThreadServiceMixin.java | 72 --- .../thread/PooledThreadServiceComposite.java | 26 - .../thread/PooledThreadServiceMixin.java | 154 ------ .../thread/ThreadGroupConfiguration.java | 28 -- .../thread/ThreadGroupConfigurationEntity.java | 24 - .../qi4j/library/thread/ThreadGroupService.java | 23 - .../thread/ThreadGroupServiceComposite.java | 26 - .../library/thread/ThreadGroupServiceMixin.java | 54 --- .../org/qi4j/library/thread/ThreadService.java | 25 - .../thread/ThreadServiceConfiguration.java | 35 -- .../ThreadServiceConfigurationEntity.java | 24 - .../assembly/NewThreadServiceAssembler.java | 40 -- .../assembly/PooledThreadServiceAssembler.java | 41 -- .../thread/NewThreadServiceComposite.properties | 10 - .../PooledThreadServiceComposite.properties | 9 - .../ThreadGroupServiceComposite.properties | 2 - .../library/thread/NewThreadServiceTest.java | 115 ----- .../library/thread/PooledThreadServiceTest.java | 152 ------ libraries/unitofwork/dev-status.xml | 14 - libraries/unitofwork/pom.xml | 23 - .../library/unitofwork/UnitOfWorkConcern.java | 199 -------- .../library/unitofwork/UnitOfWorkDiscardOn.java | 54 --- .../unitofwork/UnitOfWorkNoDiscardOn.java | 59 --- .../unitofwork/UnitOfWorkPropagation.java | 98 ---- .../UnitOfWorkPropagationException.java | 26 - .../library/unitofwork/PropagationTest.java | 41 -- .../library/unitofwork/TransactionalTest.java | 38 -- libraries/validation/dev-status.xml | 14 - libraries/validation/pom.xml | 19 - .../validation/AbstractValidatableConcern.java | 39 -- .../library/validation/AppliesToAnnotation.java | 13 - .../validation/ChangeValidationConcern.java | 71 --- .../validation/LifecycleValidationConcern.java | 43 -- .../validation/UoWCallbackValidatableMixin.java | 43 -- .../qi4j/library/validation/Validatable.java | 30 -- .../ValidatableAbstractComposite.java | 15 - .../validation/ValidatableMessagesConcern.java | 24 - .../library/validation/ValidatableMixin.java | 42 -- .../library/validation/ValidationException.java | 62 --- .../library/validation/ValidationMessage.java | 106 ---- .../library/validation/ValidationMessages.java | 17 - .../validation/ValidationMessagesMixin.java | 34 -- .../org/qi4j/library/validation/Validator.java | 42 -- pom.xml | 87 ---- qi4j/etc/codestyle-idea.jar | Bin 0 -> 1753 bytes qi4j/extensions/entitystore-cassandra/LICENSE | 177 +++++++ qi4j/extensions/entitystore-cassandra/NOTICE | 19 + .../entitystore-cassandra/dev-status.xml | 16 + qi4j/extensions/entitystore-cassandra/pom.xml | 111 +++++ .../cassandra/CassandraConfiguration.java | 23 + .../cassandra/CassandraEntityStoreService.java | 32 ++ .../cassandra/CassandraMapEntityStoreMixin.java | 200 ++++++++ .../CassandraConfigurationService.java | 57 +++ .../cassandra/CassandraEntityStoreTest.java | 46 ++ .../src/test/resources/log4j.properties | 7 + .../src/test/resources/storage-conf.xml | 347 ++++++++++++++ .../extensions/entitystore-coherence/.gitignore | 1 + .../entitystore-coherence/osgi.bundle | 285 +++++++++++ qi4j/extensions/entitystore-coherence/pom.xml | 45 ++ .../coherence/CoherenceConfiguration.java | 27 ++ .../CoherenceEntityStoreAssembler.java | 46 ++ .../coherence/CoherenceEntityStoreMixin.java | 216 +++++++++ .../coherence/CoherenceEntityStoreService.java | 39 ++ .../entitystore/coherence/DatabaseExport.java | 34 ++ .../entitystore/coherence/DatabaseImport.java | 34 ++ .../coherence/CoherenceEntityStoreTest.java | 66 +++ .../CoherenceEntityStoreService.properties | 4 + qi4j/extensions/entitystore-jgroups/LICENSE | 177 +++++++ qi4j/extensions/entitystore-jgroups/NOTICE | 23 + .../licenses/commons-logging.license | 177 +++++++ .../licenses/jgroups.license | 458 ++++++++++++++++++ qi4j/extensions/entitystore-jgroups/osgi.bundle | 59 +++ qi4j/extensions/entitystore-jgroups/pom.xml | 61 +++ .../jgroups/JGroupsEntityStoreMixin.java | 148 ++++++ .../jgroups/JGroupsEntityStoreService.java | 39 ++ .../jgroups/JGroupsEntityStoreTest.java | 252 ++++++++++ qi4j/extensions/entitystore-jndi/.gitignore | 1 + qi4j/extensions/entitystore-jndi/osgi.bundle | 30 ++ qi4j/extensions/entitystore-jndi/pom.xml | 50 ++ .../entitystore/jndi/JndiConfiguration.java | 284 +++++++++++ .../qi4j/entitystore/jndi/JndiEntityState.java | 157 ++++++ .../jndi/JndiEntityStoreAssembler.java | 44 ++ .../entitystore/jndi/JndiEntityStoreMixin.java | 129 +++++ .../jndi/JndiEntityStoreService.java | 33 ++ .../org/qi4j/entitystore/jndi/JndiSetup.java | 32 ++ .../java/org/qi4j/entitystore/jndi/JndiUow.java | 239 +++++++++ .../java/org/qi4j/entitystore/jndi/Group.java | 26 + .../org/qi4j/entitystore/jndi/GroupEntity.java | 24 + .../jndi/JndiReadEntityStoreTest.java | 82 ++++ .../java/org/qi4j/entitystore/jndi/User.java | 27 ++ .../org/qi4j/entitystore/jndi/UserEntity.java | 24 + .../jndi/JndiEntityStoreService.properties | 59 +++ qi4j/extensions/entitystore-rmi/dev-status.xml | 14 + qi4j/extensions/entitystore-rmi/osgi.bundle | 26 + qi4j/extensions/entitystore-rmi/pom.xml | 44 ++ .../rmi/ClientRmiEntityStoreMixin.java | 77 +++ .../rmi/ClientRmiEntityStoreService.java | 32 ++ .../entitystore/rmi/RegistryConfiguration.java | 13 + .../org/qi4j/entitystore/rmi/RegistryMixin.java | 53 ++ .../qi4j/entitystore/rmi/RegistryService.java | 15 + .../qi4j/entitystore/rmi/RemoteEntityStore.java | 20 + .../rmi/ServerRemoteEntityStoreMixin.java | 216 +++++++++ .../rmi/ServerRmiEntityStoreService.java | 31 ++ .../entitystore/rmi/RegistryService.properties | 1 + qi4j/extensions/entitystore-s3/.gitignore | 1 + qi4j/extensions/entitystore-s3/LICENSE | 177 +++++++ qi4j/extensions/entitystore-s3/NOTICE | 22 + qi4j/extensions/entitystore-s3/dev-status.xml | 14 + .../licenses/commons-logging.license | 177 +++++++ .../entitystore-s3/licenses/jets3t.license | 177 +++++++ qi4j/extensions/entitystore-s3/osgi.bundle | 28 ++ qi4j/extensions/entitystore-s3/pom.xml | 45 ++ .../qi4j/entitystore/s3/S3Configuration.java | 15 + .../entitystore/s3/S3EntityStoreService.java | 33 ++ .../s3/S3SerializationStoreMixin.java | 109 +++++ .../qi4j/entitystore/s3/S3EntityStoreTest.java | 47 ++ .../s3/S3EntityStoreComposite.properties | 2 + qi4j/extensions/entitystore-swift/osgi.bundle | 33 ++ qi4j/extensions/entitystore-swift/pom.xml | 48 ++ .../qi4j/entitystore/swift/BucketManager.java | 142 ++++++ .../org/qi4j/entitystore/swift/DataBlock.java | 121 +++++ .../org/qi4j/entitystore/swift/DataStore.java | 480 +++++++++++++++++++ .../org/qi4j/entitystore/swift/FileUtils.java | 41 ++ .../org/qi4j/entitystore/swift/HeapDump.java | 91 ++++ .../qi4j/entitystore/swift/IdentityFile.java | 302 ++++++++++++ .../swift/IdentityFileClosedException.java | 24 + .../swift/IdentityTooLongException.java | 30 ++ .../MalformedIdentityDirectoryException.java | 35 ++ .../qi4j/entitystore/swift/RecordManager.java | 197 ++++++++ .../qi4j/entitystore/swift/StoreIterator.java | 106 ++++ .../entitystore/swift/SwiftConfiguration.java | 32 ++ .../swift/SwiftEntityStoreAssembler.java | 42 ++ .../swift/SwiftEntityStoreMixin.java | 162 +++++++ .../swift/SwiftEntityStoreService.java | 35 ++ .../org/qi4j/entitystore/swift/UndoCommand.java | 28 ++ .../entitystore/swift/UndoDeleteCommand.java | 73 +++ .../swift/UndoDropIdentityCommand.java | 56 +++ .../entitystore/swift/UndoExtendCommand.java | 68 +++ .../org/qi4j/entitystore/swift/UndoManager.java | 23 + .../entitystore/swift/UndoModifyCommand.java | 81 ++++ .../swift/UndoNewIdentityCommand.java | 53 ++ .../quick/QuickEntityStoreService.properties | 17 + .../qi4j/entitystore/swift/DataFileTest.java | 184 +++++++ .../entitystore/swift/IdentityFileTest.java | 196 ++++++++ .../entitystore/swift/SwiftEntityStoreTest.java | 43 ++ .../swift/SwiftStorePerformanceTest.java | 37 ++ .../swift/SwiftEntityStoreService.properties | 1 + qi4j/extensions/pom.xml | 25 + qi4j/libraries/beans/dev-status.xml | 14 + qi4j/libraries/beans/pom.xml | 41 ++ .../qi4j/library/beans/properties/Getters.java | 21 + .../library/beans/properties/Iterables.java | 40 ++ .../beans/properties/MethodPrefixFilter.java | 47 ++ .../beans/properties/OrAppliesToFilter.java | 40 ++ .../library/beans/properties/Properties.java | 108 +++++ .../beans/properties/PropertiesMixin.java | 142 ++++++ .../beans/properties/PropertyNameExtractor.java | 18 + .../qi4j/library/beans/properties/Setters.java | 21 + .../beans/support/DelegatingIterator.java | 53 ++ .../beans/support/DelegatingListIterator.java | 83 ++++ .../beans/support/JavabeanAssociation.java | 97 ++++ .../beans/support/JavabeanManyAssociation.java | 202 ++++++++ .../library/beans/support/JavabeanMixin.java | 139 ++++++ .../library/beans/support/JavabeanProperty.java | 123 +++++ .../library/beans/support/JavabeanSupport.java | 33 ++ .../org/qi4j/library/beans/support/Wrapper.java | 47 ++ .../beans/properties/PropertiesMixinTest.java | 229 +++++++++ .../beans/support/JavabeanBackedTest.java | 214 +++++++++ qi4j/libraries/entityproxy/pom.xml | 45 ++ .../qi4j/library/entityproxy/EntityProxy.java | 84 ++++ .../library/entityproxy/EntityProxyHelper.java | 66 +++ .../qi4j/library/entityproxy/MutualType.java | 28 ++ .../NoCommonClassFoundException.java | 28 ++ .../library/entityproxy/ProxyableEntity.java | 143 ++++++ .../assembling/EntityProxyAssembler.java | 43 ++ .../entityproxy/internal/EntityProxyCache.java | 110 +++++ .../internal/EntityProxyCacheService.java | 31 ++ .../library/entityproxy/EntityProxyTest.java | 130 +++++ .../entityproxy/EntityWithMutualType.java | 41 ++ .../entityproxy/MissingMutualTypeEntity.java | 39 ++ .../org/qi4j/library/entityproxy/SomeRole.java | 84 ++++ qi4j/libraries/exception/dev-status.xml | 14 + .../exception/licenses/.svn/all-wcprops | 5 + qi4j/libraries/exception/licenses/.svn/entries | 28 ++ qi4j/libraries/exception/licenses/.svn/format | 1 + qi4j/libraries/exception/pom.xml | 37 ++ qi4j/libraries/exception/src/.svn/all-wcprops | 5 + qi4j/libraries/exception/src/.svn/entries | 34 ++ qi4j/libraries/exception/src/.svn/format | 1 + .../exception/src/main/.svn/all-wcprops | 5 + qi4j/libraries/exception/src/main/.svn/entries | 31 ++ qi4j/libraries/exception/src/main/.svn/format | 1 + .../exception/src/main/java/.svn/all-wcprops | 5 + .../exception/src/main/java/.svn/entries | 31 ++ .../exception/src/main/java/.svn/format | 1 + .../src/main/java/org/.svn/all-wcprops | 5 + .../exception/src/main/java/org/.svn/entries | 31 ++ .../exception/src/main/java/org/.svn/format | 1 + .../src/main/java/org/qi4j/.svn/all-wcprops | 5 + .../src/main/java/org/qi4j/.svn/entries | 31 ++ .../src/main/java/org/qi4j/.svn/format | 1 + .../main/java/org/qi4j/library/.svn/all-wcprops | 5 + .../src/main/java/org/qi4j/library/.svn/entries | 31 ++ .../src/main/java/org/qi4j/library/.svn/format | 1 + .../org/qi4j/library/exception/.svn/all-wcprops | 65 +++ .../org/qi4j/library/exception/.svn/entries | 158 ++++++ .../java/org/qi4j/library/exception/.svn/format | 1 + .../DelegatingExceptionObserver.java.svn-base | 5 + .../prop-base/ExceptionHandling.java.svn-base | 5 + ...ionHandlingNotificationConcern.java.svn-base | 5 + .../prop-base/ExceptionObservable.java.svn-base | 5 + .../ExceptionObservableMixin.java.svn-base | 5 + .../prop-base/ExceptionObserver.java.svn-base | 5 + .../NullExceptionHandling.java.svn-base | 5 + ...rvableExceptionHandlingService.java.svn-base | 5 + ...SimpleExceptionHandlingService.java.svn-base | 5 + ...ystemErrExceptionHandlingMixin.java.svn-base | 5 + .../DelegatingExceptionObserver.java.svn-base | 85 ++++ .../text-base/ExceptionHandling.java.svn-base | 23 + ...ionHandlingNotificationConcern.java.svn-base | 41 ++ .../text-base/ExceptionObservable.java.svn-base | 25 + .../ExceptionObservableMixin.java.svn-base | 64 +++ .../text-base/ExceptionObserver.java.svn-base | 23 + .../NullExceptionHandling.java.svn-base | 27 ++ ...rvableExceptionHandlingService.java.svn-base | 29 ++ ...SimpleExceptionHandlingService.java.svn-base | 26 + ...ystemErrExceptionHandlingMixin.java.svn-base | 29 ++ .../exception/DelegatingExceptionObserver.java | 85 ++++ .../library/exception/ExceptionHandling.java | 23 + .../ExceptionHandlingNotificationConcern.java | 41 ++ .../library/exception/ExceptionObservable.java | 25 + .../exception/ExceptionObservableMixin.java | 64 +++ .../library/exception/ExceptionObserver.java | 23 + .../exception/NullExceptionHandling.java | 27 ++ .../ObservableExceptionHandlingService.java | 29 ++ .../SimpleExceptionHandlingService.java | 26 + .../SystemErrExceptionHandlingMixin.java | 29 ++ .../exception/src/test/.svn/all-wcprops | 5 + qi4j/libraries/exception/src/test/.svn/entries | 31 ++ qi4j/libraries/exception/src/test/.svn/format | 1 + .../exception/src/test/java/.svn/all-wcprops | 5 + .../exception/src/test/java/.svn/entries | 31 ++ .../exception/src/test/java/.svn/format | 1 + .../src/test/java/org/.svn/all-wcprops | 5 + .../exception/src/test/java/org/.svn/entries | 31 ++ .../exception/src/test/java/org/.svn/format | 1 + .../src/test/java/org/qi4j/.svn/all-wcprops | 5 + .../src/test/java/org/qi4j/.svn/entries | 31 ++ .../src/test/java/org/qi4j/.svn/format | 1 + .../test/java/org/qi4j/library/.svn/all-wcprops | 5 + .../src/test/java/org/qi4j/library/.svn/entries | 31 ++ .../src/test/java/org/qi4j/library/.svn/format | 1 + .../org/qi4j/library/exception/.svn/all-wcprops | 5 + .../org/qi4j/library/exception/.svn/entries | 28 ++ .../java/org/qi4j/library/exception/.svn/format | 1 + qi4j/libraries/executor/dev-status.xml | 14 + qi4j/libraries/executor/pom.xml | 38 ++ .../qi4j/library/executor/ExecuteService.java | 28 ++ .../library/executor/ExecuteSideEffect.java | 30 ++ .../qi4j/library/executor/ExecutorMixin.java | 45 ++ .../library/executor/ExecutorSideEffect.java | 94 ++++ .../executor/ExecuteSideEffectTest.java | 75 +++ qi4j/libraries/ldap/client/pom.xml | 19 + qi4j/libraries/ldap/pom.xml | 19 + qi4j/libraries/ldap/server/pom.xml | 40 ++ .../server/ApacheDirectoryServiceMixin.java | 142 ++++++ .../java/org/qi4j/library/ldap/server/Ldap.java | 24 + .../library/ldap/server/LdapConfiguration.java | 32 ++ .../qi4j/library/ldap/server/LdapService.java | 27 ++ .../library/ldap/server/LdapServerTest.java | 51 ++ .../library/ldap/server/LdapService.properties | 2 + qi4j/libraries/observations/pom.xml | 24 + .../library/observations/MulticastObserver.java | 99 ++++ .../qi4j/library/observations/Observable.java | 29 ++ .../library/observations/ObservableMixin.java | 99 ++++ .../qi4j/library/observations/Observation.java | 22 + .../org/qi4j/library/observations/Observer.java | 23 + qi4j/libraries/pom.xml | 26 + qi4j/libraries/registry/dev-status.xml | 14 + qi4j/libraries/registry/pom.xml | 24 + .../org/qi4j/library/registry/Registry.java | 31 ++ .../library/registry/RegistryAssembler.java | 32 ++ .../qi4j/library/registry/RegistryMixin.java | 121 +++++ .../qi4j/library/registry/RegistryObserver.java | 26 + .../qi4j/library/registry/RegistryService.java | 26 + qi4j/libraries/rmi/dev-status.xml | 14 + qi4j/libraries/rmi/pom.xml | 42 ++ .../java/org/qi4j/library/rmi/RMIMixin.java | 51 ++ .../java/org/qi4j/library/rmi/RMIMixinTest.java | 67 +++ .../library/rmi/remote/RemoteInterface.java | 28 ++ .../rmi/remote/RemoteInterfaceComposite.java | 30 ++ .../library/rmi/remote/RemoteInterfaceImpl.java | 37 ++ qi4j/libraries/thread/dev-status.xml | 14 + qi4j/libraries/thread/pom.xml | 43 ++ .../library/thread/MaximumThreadsException.java | 34 ++ .../thread/NewThreadServiceComposite.java | 26 + .../library/thread/NewThreadServiceMixin.java | 72 +++ .../thread/PooledThreadServiceComposite.java | 26 + .../thread/PooledThreadServiceMixin.java | 154 ++++++ .../thread/ThreadGroupConfiguration.java | 28 ++ .../thread/ThreadGroupConfigurationEntity.java | 24 + .../qi4j/library/thread/ThreadGroupService.java | 23 + .../thread/ThreadGroupServiceComposite.java | 26 + .../library/thread/ThreadGroupServiceMixin.java | 54 +++ .../org/qi4j/library/thread/ThreadService.java | 25 + .../thread/ThreadServiceConfiguration.java | 35 ++ .../ThreadServiceConfigurationEntity.java | 24 + .../assembly/NewThreadServiceAssembler.java | 40 ++ .../assembly/PooledThreadServiceAssembler.java | 41 ++ .../thread/NewThreadServiceComposite.properties | 10 + .../PooledThreadServiceComposite.properties | 9 + .../ThreadGroupServiceComposite.properties | 2 + .../library/thread/NewThreadServiceTest.java | 115 +++++ .../library/thread/PooledThreadServiceTest.java | 152 ++++++ qi4j/libraries/unitofwork/dev-status.xml | 14 + qi4j/libraries/unitofwork/pom.xml | 23 + .../library/unitofwork/UnitOfWorkConcern.java | 199 ++++++++ .../library/unitofwork/UnitOfWorkDiscardOn.java | 54 +++ .../unitofwork/UnitOfWorkNoDiscardOn.java | 59 +++ .../unitofwork/UnitOfWorkPropagation.java | 98 ++++ .../UnitOfWorkPropagationException.java | 26 + .../library/unitofwork/PropagationTest.java | 41 ++ .../library/unitofwork/TransactionalTest.java | 38 ++ qi4j/libraries/validation/dev-status.xml | 14 + qi4j/libraries/validation/pom.xml | 19 + .../validation/AbstractValidatableConcern.java | 39 ++ .../library/validation/AppliesToAnnotation.java | 13 + .../validation/ChangeValidationConcern.java | 71 +++ .../validation/LifecycleValidationConcern.java | 43 ++ .../validation/UoWCallbackValidatableMixin.java | 43 ++ .../qi4j/library/validation/Validatable.java | 30 ++ .../ValidatableAbstractComposite.java | 15 + .../validation/ValidatableMessagesConcern.java | 24 + .../library/validation/ValidatableMixin.java | 42 ++ .../library/validation/ValidationException.java | 62 +++ .../library/validation/ValidationMessage.java | 106 ++++ .../library/validation/ValidationMessages.java | 17 + .../validation/ValidationMessagesMixin.java | 34 ++ .../org/qi4j/library/validation/Validator.java | 42 ++ qi4j/pom.xml | 87 ++++ 593 files changed, 16569 insertions(+), 16626 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/zest-sandbox/blob/d4dd9c17/.gitignore ---------------------------------------------------------------------- diff --git a/.gitignore b/.gitignore index 156be9b..42e473f 100644 --- a/.gitignore +++ b/.gitignore @@ -1,63 +1,6 @@ target/ -qi4jtemp/ .idea/* -.idea/copyright/* -.idea/libraries/* *.iws *.ipr *.iml -libraries/beans/target/ -libraries/executor/target/ -libraries/jini/importer/target/ -libraries/jini/javaspaces/qi4jtemp/ -libraries/jini/javaspaces/target/ -libraries/jini/lookup/qi4jtemp/ -libraries/jini/lookup/target/ -libraries/jini/transaction/qi4jtemp/ -libraries/jini/transaction/target/ -libraries/registry/target/ -libraries/rmi/target/ -libraries/thread/target/ -libraries/transaction/target/ -libraries/validation/target/ -extensions/entitystore-javaspaces/target/ -extensions/entitystore-jgroups/target/ -extensions/entitystore-swift/target/ -libraries/spaces/api/target/ -libraries/spaces/bootstrap/target/ -libraries/spaces/javaspaces/target/ -libraries/spaces/tests/target/ -libraries/exception/target/ -libraries/ldap/client/target/ -libraries/ldap/server/target/ -libraries/observations/target/ -extensions/entitystore-coherence/qi4j-entitystore-coherence.iml -extensions/entitystore-javaspaces/qi4j-entitystore-javaspaces.iml -extensions/entitystore-jgroups/qi4j-entitystore-jgroups.iml -extensions/entitystore-jndi/qi4j-entitystore-jndi.iml -extensions/entitystore-rmi/qi4j-entitystore-rmi.iml -extensions/entitystore-s3/qi4j-entitystore-s3.iml -extensions/entitystore-s3-jclouds/entitystore-s3-jclouds.iml -extensions/entitystore-jclouds/target -extensions/entitystore-swift/qi4j-entitystore-swift.iml -extensions/sb-extensions-root.iml -libraries/beans/qi4j-lib-beans.iml -libraries/exception/qi4j-lib-exception.iml -libraries/executor/qi4j-lib-executor.iml -libraries/jini/importer/qi4j-lib-jini-importer.iml -libraries/jini/javaspaces/qi4j-lib-jini-javaspaces.iml -libraries/jini/lookup/qi4j-lib-jini-lookup.iml -libraries/jini/qi4j-lib-jini.iml -libraries/jini/transaction/qi4j-lib-jini-transaction.iml -libraries/ldap/client/qi4j-lib-ldap-client.iml -libraries/ldap/qi4j-lib-ldap.iml -libraries/ldap/server/qi4j-lib-ldap-server.iml -libraries/observations/qi4j-lib-observations.iml -libraries/registry/qi4j-lib-registry.iml -libraries/rmi/qi4j-lib-rmi.iml -libraries/sb-libraries-root.iml -libraries/thread/qi4j-lib-thread.iml -libraries/unitofwork/qi4j-lib-unitofwork.iml -libraries/validation/qi4j-lib-validation.iml -qi4j-sandbox.iml -libraries/scheduler/target +qi4j/extensions/entitystore-cassandra/tmp/ http://git-wip-us.apache.org/repos/asf/zest-sandbox/blob/d4dd9c17/etc/codestyle-idea.jar ---------------------------------------------------------------------- diff --git a/etc/codestyle-idea.jar b/etc/codestyle-idea.jar deleted file mode 100644 index 2211df1..0000000 Binary files a/etc/codestyle-idea.jar and /dev/null differ http://git-wip-us.apache.org/repos/asf/zest-sandbox/blob/d4dd9c17/extensions/entitystore-cassandra/LICENSE ---------------------------------------------------------------------- diff --git a/extensions/entitystore-cassandra/LICENSE b/extensions/entitystore-cassandra/LICENSE deleted file mode 100644 index f433b1a..0000000 --- a/extensions/entitystore-cassandra/LICENSE +++ /dev/null @@ -1,177 +0,0 @@ - - Apache License - Version 2.0, January 2004 - http://www.apache.org/licenses/ - - TERMS AND CONDITIONS FOR USE, REPRODUCTION, AND DISTRIBUTION - - 1. Definitions. - - "License" shall mean the terms and conditions for use, reproduction, - and distribution as defined by Sections 1 through 9 of this document. - - "Licensor" shall mean the copyright owner or entity authorized by - the copyright owner that is granting the License. - - "Legal Entity" shall mean the union of the acting entity and all - other entities that control, are controlled by, or are under common - control with that entity. For the purposes of this definition, - "control" means (i) the power, direct or indirect, to cause the - direction or management of such entity, whether by contract or - otherwise, or (ii) ownership of fifty percent (50%) or more of the - outstanding shares, or (iii) beneficial ownership of such entity. - - "You" (or "Your") shall mean an individual or Legal Entity - exercising permissions granted by this License. - - "Source" form shall mean the preferred form for making modifications, - including but not limited to software source code, documentation - source, and configuration files. - - "Object" form shall mean any form resulting from mechanical - transformation or translation of a Source form, including but - not limited to compiled object code, generated documentation, - and conversions to other media types. - - "Work" shall mean the work of authorship, whether in Source or - Object form, made available under the License, as indicated by a - copyright notice that is included in or attached to the work - (an example is provided in the Appendix below). - - "Derivative Works" shall mean any work, whether in Source or Object - form, that is based on (or derived from) the Work and for which the - editorial revisions, annotations, elaborations, or other modifications - represent, as a whole, an original work of authorship. For the purposes - of this License, Derivative Works shall not include works that remain - separable from, or merely link (or bind by name) to the interfaces of, - the Work and Derivative Works thereof. - - "Contribution" shall mean any work of authorship, including - the original version of the Work and any modifications or additions - to that Work or Derivative Works thereof, that is intentionally - submitted to Licensor for inclusion in the Work by the copyright owner - or by an individual or Legal Entity authorized to submit on behalf of - the copyright owner. For the purposes of this definition, "submitted" - means any form of electronic, verbal, or written communication sent - to the Licensor or its representatives, including but not limited to - communication on electronic mailing lists, source code control systems, - and issue tracking systems that are managed by, or on behalf of, the - Licensor for the purpose of discussing and improving the Work, but - excluding communication that is conspicuously marked or otherwise - designated in writing by the copyright owner as "Not a Contribution." - - "Contributor" shall mean Licensor and any individual or Legal Entity - on behalf of whom a Contribution has been received by Licensor and - subsequently incorporated within the Work. - - 2. Grant of Copyright License. Subject to the terms and conditions of - this License, each Contributor hereby grants to You a perpetual, - worldwide, non-exclusive, no-charge, royalty-free, irrevocable - copyright license to reproduce, prepare Derivative Works of, - publicly display, publicly perform, sublicense, and distribute the - Work and such Derivative Works in Source or Object form. - - 3. Grant of Patent License. Subject to the terms and conditions of - this License, each Contributor hereby grants to You a perpetual, - worldwide, non-exclusive, no-charge, royalty-free, irrevocable - (except as stated in this section) patent license to make, have made, - use, offer to sell, sell, import, and otherwise transfer the Work, - where such license applies only to those patent claims licensable - by such Contributor that are necessarily infringed by their - Contribution(s) alone or by combination of their Contribution(s) - with the Work to which such Contribution(s) was submitted. If You - institute patent litigation against any entity (including a - cross-claim or counterclaim in a lawsuit) alleging that the Work - or a Contribution incorporated within the Work constitutes direct - or contributory patent infringement, then any patent licenses - granted to You under this License for that Work shall terminate - as of the date such litigation is filed. - - 4. Redistribution. You may reproduce and distribute copies of the - Work or Derivative Works thereof in any medium, with or without - modifications, and in Source or Object form, provided that You - meet the following conditions: - - (a) You must give any other recipients of the Work or - Derivative Works a copy of this License; and - - (b) You must cause any modified files to carry prominent notices - stating that You changed the files; and - - (c) You must retain, in the Source form of any Derivative Works - that You distribute, all copyright, patent, trademark, and - attribution notices from the Source form of the Work, - excluding those notices that do not pertain to any part of - the Derivative Works; and - - (d) If the Work includes a "NOTICE" text file as part of its - distribution, then any Derivative Works that You distribute must - include a readable copy of the attribution notices contained - within such NOTICE file, excluding those notices that do not - pertain to any part of the Derivative Works, in at least one - of the following places: within a NOTICE text file distributed - as part of the Derivative Works; within the Source form or - documentation, if provided along with the Derivative Works; or, - within a display generated by the Derivative Works, if and - wherever such third-party notices normally appear. The contents - of the NOTICE file are for informational purposes only and - do not modify the License. You may add Your own attribution - notices within Derivative Works that You distribute, alongside - or as an addendum to the NOTICE text from the Work, provided - that such additional attribution notices cannot be construed - as modifying the License. - - You may add Your own copyright statement to Your modifications and - may provide additional or different license terms and conditions - for use, reproduction, or distribution of Your modifications, or - for any such Derivative Works as a whole, provided Your use, - reproduction, and distribution of the Work otherwise complies with - the conditions stated in this License. - - 5. Submission of Contributions. Unless You explicitly state otherwise, - any Contribution intentionally submitted for inclusion in the Work - by You to the Licensor shall be under the terms and conditions of - this License, without any additional terms or conditions. - Notwithstanding the above, nothing herein shall supersede or modify - the terms of any separate license agreement you may have executed - with Licensor regarding such Contributions. - - 6. Trademarks. This License does not grant permission to use the trade - names, trademarks, service marks, or product names of the Licensor, - except as required for reasonable and customary use in describing the - origin of the Work and reproducing the content of the NOTICE file. - - 7. Disclaimer of Warranty. Unless required by applicable law or - agreed to in writing, Licensor provides the Work (and each - Contributor provides its Contributions) on an "AS IS" BASIS, - WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or - implied, including, without limitation, any warranties or conditions - of TITLE, NON-INFRINGEMENT, MERCHANTABILITY, or FITNESS FOR A - PARTICULAR PURPOSE. You are solely responsible for determining the - appropriateness of using or redistributing the Work and assume any - risks associated with Your exercise of permissions under this License. - - 8. Limitation of Liability. In no event and under no legal theory, - whether in tort (including negligence), contract, or otherwise, - unless required by applicable law (such as deliberate and grossly - negligent acts) or agreed to in writing, shall any Contributor be - liable to You for damages, including any direct, indirect, special, - incidental, or consequential damages of any character arising as a - result of this License or out of the use or inability to use the - Work (including but not limited to damages for loss of goodwill, - work stoppage, computer failure or malfunction, or any and all - other commercial damages or losses), even if such Contributor - has been advised of the possibility of such damages. - - 9. Accepting Warranty or Additional Liability. While redistributing - the Work or Derivative Works thereof, You may choose to offer, - and charge a fee for, acceptance of support, warranty, indemnity, - or other liability obligations and/or rights consistent with this - License. However, in accepting such obligations, You may act only - on Your own behalf and on Your sole responsibility, not on behalf - of any other Contributor, and only if You agree to indemnify, - defend, and hold each Contributor harmless for any liability - incurred by, or claims asserted against, such Contributor by reason - of your accepting any such warranty or additional liability. - - END OF TERMS AND CONDITIONS http://git-wip-us.apache.org/repos/asf/zest-sandbox/blob/d4dd9c17/extensions/entitystore-cassandra/NOTICE ---------------------------------------------------------------------- diff --git a/extensions/entitystore-cassandra/NOTICE b/extensions/entitystore-cassandra/NOTICE deleted file mode 100644 index 42bca47..0000000 --- a/extensions/entitystore-cassandra/NOTICE +++ /dev/null @@ -1,19 +0,0 @@ -Qi4j Cassandra Entity Store -Copyright 2007-2010, The Qi4j Development Team of individuals. - -See http://www.qi4j.org/contributors.html for list of of individuals. -Also see each file for additional information of Copyright claims. - -Qi4j is a community aggregated works under Copyright law. -All parts of the original works at Qi4j is licensed under the -Apache License ver 2.0 http://www.apache.org/licenses - -Below follows a list of binary dependencies and their licenses; ----------------------------------------------------------------- - -<TODO> - -<NONE> - - -END OF NOTICE \ No newline at end of file http://git-wip-us.apache.org/repos/asf/zest-sandbox/blob/d4dd9c17/extensions/entitystore-cassandra/dev-status.xml ---------------------------------------------------------------------- diff --git a/extensions/entitystore-cassandra/dev-status.xml b/extensions/entitystore-cassandra/dev-status.xml deleted file mode 100644 index 5b74162..0000000 --- a/extensions/entitystore-cassandra/dev-status.xml +++ /dev/null @@ -1,16 +0,0 @@ -<?xml version="1.0" encoding="UTF-8" ?> -<module xmlns="http://www.qi4j.org/schemas/2008/dev-status/1";> - <status> - <!--none,early,beta,stable,mature--> - <codebase>early</codebase> - - <!-- none, brief, good, complete --> - <documentation>none</documentation> - - <!-- none, some, good, complete --> - <unittests>some</unittests> - </status> - <licenses> - <license>ALv2</license> - </licenses> -</module> \ No newline at end of file http://git-wip-us.apache.org/repos/asf/zest-sandbox/blob/d4dd9c17/extensions/entitystore-cassandra/pom.xml ---------------------------------------------------------------------- diff --git a/extensions/entitystore-cassandra/pom.xml b/extensions/entitystore-cassandra/pom.xml deleted file mode 100644 index e017f29..0000000 --- a/extensions/entitystore-cassandra/pom.xml +++ /dev/null @@ -1,111 +0,0 @@ -<project xmlns="http://maven.apache.org/POM/4.0.0"; xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"; - xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/maven-v4_0_0.xsd";> - <parent> - <groupId>org.qi4j.sandbox</groupId> - <artifactId>qi4j-sandbox-extensions</artifactId> - <version>0-SNAPSHOT</version> - </parent> - <modelVersion>4.0.0</modelVersion> - <groupId>org.qi4j.extension</groupId> - <artifactId>qi4j-entitystore-cassandra</artifactId> - <name>Qi4j Extension - EntityStore - Cassandra</name> - <packaging>jar</packaging> - - <repositories> - <repository> - <id>riptano</id> - <name>riptano</name> - <url>http://mvn.riptano.com/content/repositories/public/</url> - </repository> - </repositories> - - - <dependencies> - <dependency> - <groupId>org.qi4j.core</groupId> - <artifactId>org.qi4j.core.spi</artifactId> - </dependency> - <dependency> - <groupId>org.qi4j.core</groupId> - <artifactId>org.qi4j.core.bootstrap</artifactId> - </dependency> - <dependency> - <groupId>org.qi4j.library</groupId> - <artifactId>org.qi4j.library.locking</artifactId> - </dependency> - <dependency> - <groupId>org.qi4j.core</groupId> - <artifactId>org.qi4j.core.runtime</artifactId> - <scope>test</scope> - </dependency> - <dependency> - <groupId>org.qi4j.core</groupId> - <artifactId>org.qi4j.core.testsupport</artifactId> - <scope>test</scope> - </dependency> - <dependency> - <artifactId>slf4j-log4j12</artifactId> - <groupId>org.slf4j</groupId> - <version>1.6.1</version> - </dependency> - <dependency> - <artifactId>slf4j-api</artifactId> - <groupId>org.slf4j</groupId> - </dependency> - - <dependency> - <groupId>org.apache.cassandra</groupId> - <artifactId>apache-cassandra</artifactId> - <version>0.6.8</version> - </dependency> - <dependency> - <groupId>org.apache.commons</groupId> - <artifactId>commons-compress</artifactId> - <version>1.1</version> - </dependency> - - <dependency> - <groupId>commons-collections</groupId> - <artifactId>commons-collections</artifactId> - <version>3.2.1</version> - </dependency> - - <dependency> - <groupId>org.cliffc.high_scale_lib</groupId> - <artifactId>high-scale-lib</artifactId> - <version>1.0</version> - </dependency> - - <dependency> - <groupId>com.reardencommerce</groupId> - <artifactId>clhm-production</artifactId> - <version>1.0</version> - </dependency> - - - <dependency> - <groupId>me.prettyprint</groupId> - <artifactId>hector</artifactId> - <version>0.6.0-20</version> - <exclusions> - <exclusion> - <artifactId>properties-maven-plugin</artifactId> - <groupId>org.codehaus.mojo</groupId> - </exclusion> - <exclusion> - <artifactId>apache-cassandra</artifactId> - <groupId>org.apache.cassandra</groupId> - </exclusion> - <exclusion> - <artifactId>slf4j-api</artifactId> - <groupId>org.slf4j</groupId> - </exclusion> - <exclusion> - <artifactId>slf4j-log4j12</artifactId> - <groupId>org.slf4j</groupId> - </exclusion> - - </exclusions> - </dependency> - </dependencies> -</project> http://git-wip-us.apache.org/repos/asf/zest-sandbox/blob/d4dd9c17/extensions/entitystore-cassandra/src/main/java/org/qi4j/entitystore/cassandra/CassandraConfiguration.java ---------------------------------------------------------------------- diff --git a/extensions/entitystore-cassandra/src/main/java/org/qi4j/entitystore/cassandra/CassandraConfiguration.java b/extensions/entitystore-cassandra/src/main/java/org/qi4j/entitystore/cassandra/CassandraConfiguration.java deleted file mode 100644 index 7aecba5..0000000 --- a/extensions/entitystore-cassandra/src/main/java/org/qi4j/entitystore/cassandra/CassandraConfiguration.java +++ /dev/null @@ -1,23 +0,0 @@ -package org.qi4j.entitystore.cassandra; - - -public interface CassandraConfiguration { - boolean gzipCompress(); - - boolean checkAbsentBeforeCreate(); - - boolean checkPresentBeforeDelete(); - - boolean checkPresentBeforeUpdate(); - - boolean readOnly(); - - - String getHost(); - - String getLogin(); - - String getPassword(); - - int getPort(); -} http://git-wip-us.apache.org/repos/asf/zest-sandbox/blob/d4dd9c17/extensions/entitystore-cassandra/src/main/java/org/qi4j/entitystore/cassandra/CassandraEntityStoreService.java ---------------------------------------------------------------------- diff --git a/extensions/entitystore-cassandra/src/main/java/org/qi4j/entitystore/cassandra/CassandraEntityStoreService.java b/extensions/entitystore-cassandra/src/main/java/org/qi4j/entitystore/cassandra/CassandraEntityStoreService.java deleted file mode 100644 index b183d75..0000000 --- a/extensions/entitystore-cassandra/src/main/java/org/qi4j/entitystore/cassandra/CassandraEntityStoreService.java +++ /dev/null @@ -1,32 +0,0 @@ -/* - * Copyright (c) 2007, Rickard Ãberg. All Rights Reserved. - * - * Licensed 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.qi4j.entitystore.cassandra; - -import org.qi4j.api.concern.Concerns; -import org.qi4j.api.mixin.Mixins; -import org.qi4j.api.service.ServiceActivation; -import org.qi4j.spi.entitystore.ConcurrentModificationCheckConcern; -import org.qi4j.spi.entitystore.EntityStateVersions; -import org.qi4j.spi.entitystore.EntityStore; -import org.qi4j.spi.entitystore.StateChangeNotificationConcern; -import org.qi4j.spi.entitystore.helpers.MapEntityStoreMixin; - -@Concerns({StateChangeNotificationConcern.class, - ConcurrentModificationCheckConcern.class}) -@Mixins({MapEntityStoreMixin.class, CassandraMapEntityStoreMixin.class}) -public interface CassandraEntityStoreService extends EntityStateVersions, - EntityStore, ServiceActivation { - -} http://git-wip-us.apache.org/repos/asf/zest-sandbox/blob/d4dd9c17/extensions/entitystore-cassandra/src/main/java/org/qi4j/entitystore/cassandra/CassandraMapEntityStoreMixin.java ---------------------------------------------------------------------- diff --git a/extensions/entitystore-cassandra/src/main/java/org/qi4j/entitystore/cassandra/CassandraMapEntityStoreMixin.java b/extensions/entitystore-cassandra/src/main/java/org/qi4j/entitystore/cassandra/CassandraMapEntityStoreMixin.java deleted file mode 100644 index eb6a214..0000000 --- a/extensions/entitystore-cassandra/src/main/java/org/qi4j/entitystore/cassandra/CassandraMapEntityStoreMixin.java +++ /dev/null @@ -1,200 +0,0 @@ -package org.qi4j.entitystore.cassandra; - -import me.prettyprint.cassandra.serializers.BytesSerializer; -import me.prettyprint.cassandra.serializers.StringSerializer; -import me.prettyprint.hector.api.Cluster; -import me.prettyprint.hector.api.Keyspace; -import me.prettyprint.hector.api.beans.HColumn; -import me.prettyprint.hector.api.factory.HFactory; -import me.prettyprint.hector.api.mutation.MutationResult; -import me.prettyprint.hector.api.query.ColumnQuery; -import me.prettyprint.hector.api.query.QueryResult; -import org.qi4j.api.entity.EntityReference; -import org.qi4j.api.injection.scope.Service; -import org.qi4j.api.entity.EntityDescriptor; -import org.qi4j.api.service.ServiceActivation; -import org.qi4j.io.Input; -import org.qi4j.spi.entitystore.helpers.MapEntityStore; -import org.qi4j.spi.entitystore.EntityAlreadyExistsException; -import org.qi4j.spi.entitystore.EntityNotFoundException; -import org.qi4j.spi.entitystore.EntityStoreException; -import org.slf4j.Logger; -import org.slf4j.LoggerFactory; - -import java.io.ByteArrayInputStream; -import java.io.ByteArrayOutputStream; -import java.io.IOException; -import java.io.InputStream; -import java.io.InputStreamReader; -import java.io.OutputStream; -import java.io.OutputStreamWriter; -import java.io.Reader; -import java.io.Writer; -import java.util.zip.GZIPInputStream; -import java.util.zip.GZIPOutputStream; - -import static me.prettyprint.hector.api.factory.HFactory.*; - -/** - * // TODO: Document this - * - * @author pvdyck - * @since 4.0 - */ -public class CassandraMapEntityStoreMixin implements MapEntityStore, ServiceActivation { - private static final String COLUMN_NAME = "entry"; - private final Logger logger = LoggerFactory.getLogger(CassandraMapEntityStoreMixin.class); - - private static final String keySpace = "Qi4j"; - static final String cf = "Qi4jEntries"; - - static final int BYTE_ARRAY_BUFFER_INITIAL_SIZE = 512; - - Cluster c; - Keyspace ko; - - - private static final StringSerializer se = new StringSerializer(); - private static final BytesSerializer bs = new BytesSerializer(); - - - @Service - private - CassandraConfiguration conf; - - public void activateService() throws Exception { - c = HFactory.getOrCreateCluster("Qi4jCluster", conf.getHost() + ":" + conf.getPort()); - ko = HFactory.createKeyspace(keySpace, c); - logger.info("started cassandra store"); - } - - - public void passivateService() throws Exception { - logger.info("shutting down cassandra"); - } - - - public void applyChanges(final MapChanges changes) throws IOException { - if (conf.readOnly()) { - throw new EntityStoreException("Read-only Entity Store"); - } - - try { - final MapUpdater changer = new MapUpdater(); - changes.visitMap(changer); - - MutationResult result = changer.m.execute(); - - logger.info("applying changes to cassandra store " + result.getExecutionTimeMicro() + " / " + result.getHostUsed()); - - } catch (Throwable e) { - throw new EntityStoreException("Exception during cassandra batch " - + " - ", e); - } - } - - boolean contains(EntityReference ref) throws EntityStoreException { - try { - //TODO optimise this... no need to fetch everything - get(ref); - return true; - } catch (final EntityNotFoundException e1) { - return false; - } catch (final Exception e1) { - throw new EntityStoreException(e1); - } - } - - public Reader get(final EntityReference ref) { - //TODO .. should be able to use only one ColumnQuery ... btw .. is it thread-safe ? - ColumnQuery<String, byte[]> q = createColumnQuery(ko, se, bs); - q.setName(COLUMN_NAME).setColumnFamily(cf); - QueryResult<HColumn<String, byte[]>> r; - try { - r = q.setKey(ref.toString()).execute(); - } catch (Exception e) { - throw new EntityStoreException(e); - } - if (r.get() == null) throw new EntityNotFoundException(ref); - - try { - return createReader(new ByteArrayInputStream(r.get().getValue())); - } catch (IOException e) { - throw new EntityStoreException(e); - } - } - - - public Input<Reader, IOException> entityStates() { - throw new UnsupportedOperationException("Not implemented yet"); - } - - - Writer createWriter(OutputStream out) throws IOException { - if (conf.gzipCompress()) - return new OutputStreamWriter(new GZIPOutputStream(out)); - return new OutputStreamWriter(out); - } - - private Reader createReader(InputStream in) throws IOException { - if (conf.gzipCompress()) - return new InputStreamReader(new GZIPInputStream(in)); - return new InputStreamReader(in); - } - - void checkAbsentBeforeCreate(EntityReference ref) { - if (!conf.checkAbsentBeforeCreate()) - return; - if (contains(ref)) - throw new EntityAlreadyExistsException(ref); - } - - void checkPresentBeforeDelete(EntityReference ref) { - if (!conf.checkPresentBeforeDelete()) - return; - if (!contains(ref)) - throw new EntityNotFoundException(ref); - } - - void checkPresentBeforeUpdate(EntityReference ref) { - if (!conf.checkPresentBeforeUpdate()) - return; - if (!contains(ref)) - throw new EntityNotFoundException(ref); - } - - class MapUpdater implements MapEntityStore.MapChanger { - me.prettyprint.hector.api.mutation.Mutator m = createMutator(ko); - - public Writer newEntity(final EntityReference ref, EntityDescriptor entityDescriptor) { - checkAbsentBeforeCreate(ref); - return getWriter(ref); - } - - public Writer updateEntity(final EntityReference ref, EntityDescriptor entityDescriptor) - throws IOException { - checkPresentBeforeUpdate(ref); - return getWriter(ref); - } - - public void removeEntity(EntityReference ref, EntityDescriptor entityDescriptor) - throws EntityNotFoundException { - checkPresentBeforeDelete(ref); - m.addDeletion(ref.identity(), cf, COLUMN_NAME, se); - } - - private Writer getWriter(final EntityReference ref) { - try { - return createWriter(new ByteArrayOutputStream(CassandraMapEntityStoreMixin.BYTE_ARRAY_BUFFER_INITIAL_SIZE) { - @Override - public void close() throws IOException { - super.close(); - m.addInsertion(ref.identity(), cf, createColumn(COLUMN_NAME, toByteArray(), se, bs)); - } - }); - } catch (final Exception e) { - throw new EntityStoreException(e); - } - } - } -} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/zest-sandbox/blob/d4dd9c17/extensions/entitystore-cassandra/src/test/java/org/qi4j/entitystore/cassandra/CassandraConfigurationService.java ---------------------------------------------------------------------- diff --git a/extensions/entitystore-cassandra/src/test/java/org/qi4j/entitystore/cassandra/CassandraConfigurationService.java b/extensions/entitystore-cassandra/src/test/java/org/qi4j/entitystore/cassandra/CassandraConfigurationService.java deleted file mode 100644 index 93bed0d..0000000 --- a/extensions/entitystore-cassandra/src/test/java/org/qi4j/entitystore/cassandra/CassandraConfigurationService.java +++ /dev/null @@ -1,57 +0,0 @@ -package org.qi4j.entitystore.cassandra; - -import org.qi4j.api.mixin.Mixins; -import org.qi4j.api.service.ServiceComposite; - -@Mixins(CassandraConfigurationService.CassandraConfigurationMixin.class) -public interface CassandraConfigurationService extends ServiceComposite, - CassandraConfiguration { - public class CassandraConfigurationMixin implements CassandraConfiguration { - private final boolean gzipCompress = true; - private final boolean checkAbsentBeforeCreate = false; - private final boolean checkPresentBeforeDelete = false; - private final boolean checkPresentBeforeUpdate = false; - - private final String NULL = null; - private final String LOCALHOST = "localhost"; - - public boolean checkAbsentBeforeCreate() { - return checkAbsentBeforeCreate; - } - - public boolean checkPresentBeforeDelete() { - return checkPresentBeforeDelete; - } - - public boolean checkPresentBeforeUpdate() { - return checkPresentBeforeUpdate; - } - - public boolean gzipCompress() { - return gzipCompress; - } - - - public boolean readOnly() { - return false; - } - - public String getHost() { - return LOCALHOST; - } - - public String getLogin() { - return NULL; - } - - public String getPassword() { - return NULL; - } - - public int getPort() { - return 9160; - } - - - } -} http://git-wip-us.apache.org/repos/asf/zest-sandbox/blob/d4dd9c17/extensions/entitystore-cassandra/src/test/java/org/qi4j/entitystore/cassandra/CassandraEntityStoreTest.java ---------------------------------------------------------------------- diff --git a/extensions/entitystore-cassandra/src/test/java/org/qi4j/entitystore/cassandra/CassandraEntityStoreTest.java b/extensions/entitystore-cassandra/src/test/java/org/qi4j/entitystore/cassandra/CassandraEntityStoreTest.java deleted file mode 100644 index d018404..0000000 --- a/extensions/entitystore-cassandra/src/test/java/org/qi4j/entitystore/cassandra/CassandraEntityStoreTest.java +++ /dev/null @@ -1,46 +0,0 @@ -package org.qi4j.entitystore.cassandra; - -import org.apache.cassandra.contrib.utils.service.CassandraServiceDataCleaner; -import org.apache.cassandra.service.EmbeddedCassandraService; -import org.apache.thrift.transport.TTransportException; -import org.junit.BeforeClass; -import org.qi4j.bootstrap.AssemblyException; -import org.qi4j.bootstrap.ModuleAssembly; -import org.qi4j.test.entity.AbstractEntityStoreTest; - -import java.io.IOException; -import org.qi4j.api.value.ValueSerialization; -import org.qi4j.valueserialization.orgjson.OrgJsonValueSerializationService; - - -//need to launch a cassandra instance b4 running this test... -//waiting for Hector version of the ES -public class CassandraEntityStoreTest extends AbstractEntityStoreTest { - - private static EmbeddedCassandraService cassandra; - private static Thread t; - - @Override - public void assemble(ModuleAssembly module) throws AssemblyException { - super.assemble(module); - module.addServices(CassandraEntityStoreService.class, - CassandraConfigurationService.class); - module.services( OrgJsonValueSerializationService.class ).taggedWith( ValueSerialization.Formats.JSON ); - } - - @BeforeClass - public static void setup() throws TTransportException, IOException, - InterruptedException { - // Tell cassandra where the configuration files are. - // Use the test configuration file. - - System.setProperty("storage-config", "src/test/resources"); - - new CassandraServiceDataCleaner().prepare(); - cassandra = new EmbeddedCassandraService(); - cassandra.init(); - t = new Thread(cassandra); - t.setDaemon(true); - t.start(); - } -} http://git-wip-us.apache.org/repos/asf/zest-sandbox/blob/d4dd9c17/extensions/entitystore-cassandra/src/test/resources/log4j.properties ---------------------------------------------------------------------- diff --git a/extensions/entitystore-cassandra/src/test/resources/log4j.properties b/extensions/entitystore-cassandra/src/test/resources/log4j.properties deleted file mode 100644 index 3648e32..0000000 --- a/extensions/entitystore-cassandra/src/test/resources/log4j.properties +++ /dev/null @@ -1,7 +0,0 @@ -log4j.rootLogger=INFO,stdout - -# stdout -log4j.appender.stdout=org.apache.log4j.ConsoleAppender -log4j.appender.stdout.layout=org.apache.log4j.SimpleLayout - -log4j.category.org.apache=INFO, stdout \ No newline at end of file http://git-wip-us.apache.org/repos/asf/zest-sandbox/blob/d4dd9c17/extensions/entitystore-cassandra/src/test/resources/storage-conf.xml ---------------------------------------------------------------------- diff --git a/extensions/entitystore-cassandra/src/test/resources/storage-conf.xml b/extensions/entitystore-cassandra/src/test/resources/storage-conf.xml deleted file mode 100644 index 902c7bc..0000000 --- a/extensions/entitystore-cassandra/src/test/resources/storage-conf.xml +++ /dev/null @@ -1,347 +0,0 @@ -<Storage> - <!--======================================================================--> - <!-- Basic Configuration --> - <!--======================================================================--> - - <!-- - ~ The name of this cluster. This is mainly used to prevent machines in - ~ one logical cluster from joining another. - --> - <ClusterName>Qi4j</ClusterName> - - <!-- - ~ Turn on to make new [non-seed] nodes automatically migrate the right data - ~ to themselves. (If no InitialToken is specified, they will pick one - ~ such that they will get half the range of the most-loaded node.) - ~ If a node starts up without bootstrapping, it will mark itself bootstrapped - ~ so that you can't subsequently accidently bootstrap a node with - ~ data on it. (You can reset this by wiping your data and commitlog - ~ directories.) - ~ - ~ Off by default so that new clusters and upgraders from 0.4 don't - ~ bootstrap immediately. You should turn this on when you start adding - ~ new nodes to a cluster that already has data on it. (If you are upgrading - ~ from 0.4, start your cluster with it off once before changing it to true. - ~ Otherwise, no data will be lost but you will incur a lot of unnecessary - ~ I/O before your cluster starts up.) - --> - <AutoBootstrap>false</AutoBootstrap> - - <!-- - ~ Keyspaces and ColumnFamilies: - ~ A ColumnFamily is the Cassandra concept closest to a relational - ~ table. Keyspaces are separate groups of ColumnFamilies. Except in - ~ very unusual circumstances you will have one Keyspace per application. - - ~ There is an implicit keyspace named 'system' for Cassandra internals. - --> - <Keyspaces> - <Keyspace Name="Qi4j"> - <!-- - ~ ColumnFamily definitions have one required attribute (Name) - ~ and several optional ones. - ~ - ~ The CompareWith attribute tells Cassandra how to sort the columns - ~ for slicing operations. The default is BytesType, which is a - ~ straightforward lexical comparison of the bytes in each column. - ~ Other options are AsciiType, UTF8Type, LexicalUUIDType, TimeUUIDType, - ~ and LongType. You can also specify the fully-qualified class - ~ name to a class of your choice extending - ~ org.apache.cassandra.db.marshal.AbstractType. - ~ - ~ SuperColumns have a similar CompareSubcolumnsWith attribute. - ~ - ~ BytesType: Simple sort by byte value. No validation is performed. - ~ AsciiType: Like BytesType, but validates that the input can be - ~ parsed as US-ASCII. - ~ UTF8Type: A string encoded as UTF8 - ~ LongType: A 64bit long - ~ LexicalUUIDType: A 128bit UUID, compared lexically (by byte value) - ~ TimeUUIDType: a 128bit version 1 UUID, compared by timestamp - ~ - ~ (To get the closest approximation to 0.3-style supercolumns, you - ~ would use CompareWith=UTF8Type CompareSubcolumnsWith=LongType.) - ~ - ~ An optional `Comment` attribute may be used to attach additional - ~ human-readable information about the column family to its definition. - ~ - ~ The optional KeysCached attribute specifies - ~ the number of keys per sstable whose locations we keep in - ~ memory in "mostly LRU" order. (JUST the key locations, NOT any - ~ column values.) Specify a fraction (value less than 1), a percentage - ~ (ending in a % sign) or an absolute number of keys to cache. - ~ - ~ The optional RowsCached attribute specifies the number of rows - ~ whose entire contents we cache in memory. Do not use this on - ~ ColumnFamilies with large rows, or ColumnFamilies with high write:read - ~ ratios. Specify a fraction (value less than 1), a percentage (ending in - ~ a % sign) or an absolute number of rows to cache. - --> - - <ColumnFamily CompareWith="BytesType" Name="Qi4jEntries" KeysCached="10%"/> - - - <!-- - ~ Strategy: Setting this to the class that implements - ~ IReplicaPlacementStrategy will change the way the node picker works. - ~ Out of the box, Cassandra provides - ~ org.apache.cassandra.locator.RackUnawareStrategy and - ~ org.apache.cassandra.locator.RackAwareStrategy (place one replica in - ~ a different datacenter, and the others on different racks in the same - ~ one.) - --> - <ReplicaPlacementStrategy>org.apache.cassandra.locator.RackUnawareStrategy</ReplicaPlacementStrategy> - - <!-- Number of replicas of the data --> - <ReplicationFactor>1</ReplicationFactor> - - <!-- - ~ EndPointSnitch: Setting this to the class that implements - ~ AbstractEndpointSnitch, which lets Cassandra know enough - ~ about your network topology to route requests efficiently. - ~ Out of the box, Cassandra provides org.apache.cassandra.locator.EndPointSnitch, - ~ and PropertyFileEndPointSnitch is available in contrib/. - --> - <EndPointSnitch>org.apache.cassandra.locator.EndPointSnitch</EndPointSnitch> - - </Keyspace> - </Keyspaces> - - <!-- - ~ Authenticator: any IAuthenticator may be used, including your own as long - ~ as it is on the classpath. Out of the box, Cassandra provides - ~ org.apache.cassandra.auth.AllowAllAuthenticator and, - ~ org.apache.cassandra.auth.SimpleAuthenticator - ~ (SimpleAuthenticator uses access.properties and passwd.properties by - ~ default). - ~ - ~ If you don't specify an authenticator, AllowAllAuthenticator is used. - --> - <Authenticator>org.apache.cassandra.auth.AllowAllAuthenticator</Authenticator> - - <!-- - ~ Partitioner: any IPartitioner may be used, including your own as long - ~ as it is on the classpath. Out of the box, Cassandra provides - ~ org.apache.cassandra.dht.RandomPartitioner, - ~ org.apache.cassandra.dht.OrderPreservingPartitioner, and - ~ org.apache.cassandra.dht.CollatingOrderPreservingPartitioner. - ~ (CollatingOPP colates according to EN,US rules, not naive byte - ~ ordering. Use this as an example if you need locale-aware collation.) - ~ Range queries require using an order-preserving partitioner. - ~ - ~ Achtung! Changing this parameter requires wiping your data - ~ directories, since the partitioner can modify the sstable on-disk - ~ format. - --> - <Partitioner>org.apache.cassandra.dht.OrderPreservingPartitioner</Partitioner> - - <!-- - ~ If you are using an order-preserving partitioner and you know your key - ~ distribution, you can specify the token for this node to use. (Keys - ~ are sent to the node with the "closest" token, so distributing your - ~ tokens equally along the key distribution space will spread keys - ~ evenly across your cluster.) This setting is only checked the first - ~ time a node is started. - - ~ This can also be useful with RandomPartitioner to force equal spacing - ~ of tokens around the hash space, especially for clusters with a small - ~ number of nodes. - --> - <InitialToken></InitialToken> - - <!-- - ~ Directories: Specify where Cassandra should store different data on - ~ disk. Keep the data disks and the CommitLog disks separate for best - ~ performance - --> - <CommitLogDirectory>./tmp/cassandra-cachestore/commitlog</CommitLogDirectory> - <DataFileDirectories> - <DataFileDirectory>./tmp/cassandra-cachestore/data</DataFileDirectory> - </DataFileDirectories> - <CalloutLocation>./tmp/cassandra-cachestore/callouts</CalloutLocation> - <SavedCachesDirectory>./tmp/saved_caches</SavedCachesDirectory> - - - <!-- - ~ Addresses of hosts that are deemed contact points. Cassandra nodes - ~ use this list of hosts to find each other and learn the topology of - ~ the ring. You must change this if you are running multiple nodes! - --> - <Seeds> - <Seed>127.0.0.1</Seed> - </Seeds> - - - <!-- Miscellaneous --> - - <!-- Time to wait for a reply from other nodes before failing the command --> - <RpcTimeoutInMillis>10000</RpcTimeoutInMillis> - <!-- Size to allow commitlog to grow to before creating a new segment --> - <CommitLogRotationThresholdInMB>128</CommitLogRotationThresholdInMB> - - - <!-- Local hosts and ports --> - - <!-- - ~ Address to bind to and tell other nodes to connect to. You _must_ - ~ change this if you want multiple nodes to be able to communicate! - ~ - ~ Leaving it blank leaves it up to InetAddress.getLocalHost(). This - ~ will always do the Right Thing *if* the node is properly configured - ~ (hostname, name resolution, etc), and the Right Thing is to use the - ~ address associated with the hostname (it might not be). - --> - <ListenAddress></ListenAddress> - <!-- internal communications port --> - <StoragePort>7000</StoragePort> - - <!-- - ~ The address to bind the Thrift RPC service to. Unlike ListenAddress - ~ above, you *can* specify 0.0.0.0 here if you want Thrift to listen on - ~ all interfaces. - ~ - ~ Leaving this blank has the same effect it does for ListenAddress, - ~ (i.e. it will be based on the configured hostname of the node). - --> - <ThriftAddress>localhost</ThriftAddress> - <!-- Thrift RPC port (the port clients connect to). --> - <ThriftPort>9160</ThriftPort> - <!-- - ~ Whether or not to use a framed transport for Thrift. If this option - ~ is set to true then you must also use a framed transport on the - ~ client-side, (framed and non-framed transports are not compatible). - --> - <ThriftFramedTransport>false</ThriftFramedTransport> - - - <!--======================================================================--> - <!-- Memory, Disk, and Performance --> - <!--======================================================================--> - - <!-- - ~ Access mode. mmapped i/o is substantially faster, but only practical on - ~ a 64bit machine (which notably does not include EC2 "small" instances) - ~ or relatively small datasets. "auto", the safe choice, will enable - ~ mmapping on a 64bit JVM. Other values are "mmap", "mmap_index_only" - ~ (which may allow you to get part of the benefits of mmap on a 32bit - ~ machine by mmapping only index files) and "standard". - ~ (The buffer size settings that follow only apply to standard, - ~ non-mmapped i/o.) - --> - <DiskAccessMode>auto</DiskAccessMode> - - <!-- - ~ Size of compacted row above which to log a warning. (If compacted - ~ rows do not fit in memory, Cassandra will crash. This is explained - ~ in http://wiki.apache.org/cassandra/CassandraLimitations and is - ~ scheduled to be fixed in 0.7.) - --> - <RowWarningThresholdInMB>512</RowWarningThresholdInMB> - - <!-- - ~ Buffer size to use when performing contiguous column slices. Increase - ~ this to the size of the column slices you typically perform. - ~ (Name-based queries are performed with a buffer size of - ~ ColumnIndexSizeInKB.) - --> - <SlicedBufferSizeInKB>64</SlicedBufferSizeInKB> - - <!-- -~ Buffer size to use when flushing memtables to disk. (Only one -~ memtable is ever flushed at a time.) Increase (decrease) the index -~ buffer size relative to the data buffer if you have few (many) -~ columns per key. Bigger is only better _if_ your memtables get large -~ enough to use the space. (Check in your data directory after your -~ app has been running long enough.) --> - <FlushDataBufferSizeInMB>32</FlushDataBufferSizeInMB> - <FlushIndexBufferSizeInMB>8</FlushIndexBufferSizeInMB> - - <!-- - ~ Add column indexes to a row after its contents reach this size. - ~ Increase if your column values are large, or if you have a very large - ~ number of columns. The competing causes are, Cassandra has to - ~ deserialize this much of the row to read a single column, so you want - ~ it to be small - at least if you do many partial-row reads - but all - ~ the index data is read for each access, so you don't want to generate - ~ that wastefully either. - --> - <ColumnIndexSizeInKB>64</ColumnIndexSizeInKB> - - <!-- - ~ Flush memtable after this much data has been inserted, including - ~ overwritten data. There is one memtable per column family, and - ~ this threshold is based solely on the amount of data stored, not - ~ actual heap memory usage (there is some overhead in indexing the - ~ columns). - --> - <MemtableThroughputInMB>64</MemtableThroughputInMB> - <!-- - ~ Throughput setting for Binary Memtables. Typically these are - ~ used for bulk load so you want them to be larger. - --> - <BinaryMemtableThroughputInMB>256</BinaryMemtableThroughputInMB> - <!-- - ~ The maximum number of columns in millions to store in memory per - ~ ColumnFamily before flushing to disk. This is also a per-memtable - ~ setting. Use with MemtableThroughputInMB to tune memory usage. - --> - <MemtableOperationsInMillions>0.3</MemtableOperationsInMillions> - <!-- - ~ The maximum time to leave a dirty memtable unflushed. - ~ (While any affected columnfamilies have unflushed data from a - ~ commit log segment, that segment cannot be deleted.) - ~ This needs to be large enough that it won't cause a flush storm - ~ of all your memtables flushing at once because none has hit - ~ the size or count thresholds yet. For production, a larger - ~ value such as 1440 is recommended. - --> - <MemtableFlushAfterMinutes>60</MemtableFlushAfterMinutes> - - <!-- - ~ Unlike most systems, in Cassandra writes are faster than reads, so - ~ you can afford more of those in parallel. A good rule of thumb is 2 - ~ concurrent reads per processor core. Increase ConcurrentWrites to - ~ the number of clients writing at once if you enable CommitLogSync + - ~ CommitLogSyncDelay. --> - <ConcurrentReads>8</ConcurrentReads> - <ConcurrentWrites>32</ConcurrentWrites> - - <!-- - ~ CommitLogSync may be either "periodic" or "batch." When in batch - ~ mode, Cassandra won't ack writes until the commit log has been - ~ fsynced to disk. It will wait up to CommitLogSyncBatchWindowInMS - ~ milliseconds for other writes, before performing the sync. - - ~ This is less necessary in Cassandra than in traditional databases - ~ since replication reduces the odds of losing data from a failure - ~ after writing the log entry but before it actually reaches the disk. - ~ So the other option is "timed," where writes may be acked immediately - ~ and the CommitLog is simply synced every CommitLogSyncPeriodInMS - ~ milliseconds. - --> - <CommitLogSync>periodic</CommitLogSync> - <!-- - ~ Interval at which to perform syncs of the CommitLog in periodic mode. - ~ Usually the default of 10000ms is fine; increase it if your i/o - ~ load is such that syncs are taking excessively long times. - --> - <CommitLogSyncPeriodInMS>10000</CommitLogSyncPeriodInMS> - <!-- - ~ Delay (in milliseconds) during which additional commit log entries - ~ may be written before fsync in batch mode. This will increase - ~ latency slightly, but can vastly improve throughput where there are - ~ many writers. Set to zero to disable (each entry will be synced - ~ individually). Reasonable values range from a minimal 0.1 to 10 or - ~ even more if throughput matters more than latency. - --> - <!-- <CommitLogSyncBatchWindowInMS>1</CommitLogSyncBatchWindowInMS> --> - - <!-- - ~ Time to wait before garbage-collection deletion markers. Set this to - ~ a large enough value that you are confident that the deletion marker - ~ will be propagated to all replicas by the time this many seconds has - ~ elapsed, even in the face of hardware failures. The default value is - ~ ten days. - --> - <GCGraceSeconds>864000</GCGraceSeconds> -</Storage> http://git-wip-us.apache.org/repos/asf/zest-sandbox/blob/d4dd9c17/extensions/entitystore-coherence/.gitignore ---------------------------------------------------------------------- diff --git a/extensions/entitystore-coherence/.gitignore b/extensions/entitystore-coherence/.gitignore deleted file mode 100644 index 2f7896d..0000000 --- a/extensions/entitystore-coherence/.gitignore +++ /dev/null @@ -1 +0,0 @@ -target/
