activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From chir...@apache.org
Subject svn commit: r474986 [1/6] - in /incubator/activemq/branches/activemq-4.1: ./ activemq-console/src/main/java/org/apache/activemq/console/ activemq-console/src/main/resources/META-INF/ activemq-console/src/test/resources/ activemq-core/src/main/java/org/...
Date Tue, 14 Nov 2006 21:17:39 GMT
Author: chirino
Date: Tue Nov 14 13:17:31 2006
New Revision: 474986

URL: http://svn.apache.org/viewvc?view=rev&rev=474986
Log:
setting svn:eol-style

Modified:
    incubator/activemq/branches/activemq-4.1/DISCLAIMER.txt   (props changed)
    incubator/activemq/branches/activemq-4.1/NOTICE.txt   (contents, props changed)
    incubator/activemq/branches/activemq-4.1/activemq-console/src/main/java/org/apache/activemq/console/ConsoleCommandHandler.java   (props changed)
    incubator/activemq/branches/activemq-4.1/activemq-console/src/main/resources/META-INF/NOTICE.txt   (contents, props changed)
    incubator/activemq/branches/activemq-4.1/activemq-console/src/test/resources/log4j.properties   (contents, props changed)
    incubator/activemq/branches/activemq-4.1/activemq-core/src/main/java/org/apache/activemq/ActiveMQSslConnectionFactory.java   (props changed)
    incubator/activemq/branches/activemq-4.1/activemq-core/src/main/java/org/apache/activemq/Disposable.java   (props changed)
    incubator/activemq/branches/activemq-4.1/activemq-core/src/main/java/org/apache/activemq/broker/SslBrokerService.java   (props changed)
    incubator/activemq/branches/activemq-4.1/activemq-core/src/main/java/org/apache/activemq/broker/region/DestinationFactory.java   (props changed)
    incubator/activemq/branches/activemq-4.1/activemq-core/src/main/java/org/apache/activemq/broker/region/DestinationFactoryImpl.java   (props changed)
    incubator/activemq/branches/activemq-4.1/activemq-core/src/main/java/org/apache/activemq/broker/region/NullMessageReference.java   (props changed)
    incubator/activemq/branches/activemq-4.1/activemq-core/src/main/java/org/apache/activemq/broker/region/QueueMessageReference.java   (props changed)
    incubator/activemq/branches/activemq-4.1/activemq-core/src/main/java/org/apache/activemq/broker/region/cursors/AbstractPendingMessageCursor.java   (props changed)
    incubator/activemq/branches/activemq-4.1/activemq-core/src/main/java/org/apache/activemq/broker/region/cursors/FilePendingMessageCursor.java   (props changed)
    incubator/activemq/branches/activemq-4.1/activemq-core/src/main/java/org/apache/activemq/broker/region/cursors/PendingMessageCursor.java   (props changed)
    incubator/activemq/branches/activemq-4.1/activemq-core/src/main/java/org/apache/activemq/broker/region/cursors/StoreDurableSubscriberCursor.java   (props changed)
    incubator/activemq/branches/activemq-4.1/activemq-core/src/main/java/org/apache/activemq/broker/region/cursors/TopicStorePrefetch.java   (props changed)
    incubator/activemq/branches/activemq-4.1/activemq-core/src/main/java/org/apache/activemq/broker/region/cursors/VMPendingMessageCursor.java   (props changed)
    incubator/activemq/branches/activemq-4.1/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/FilePendingDurableSubscriberMessageStoragePolicy.java   (props changed)
    incubator/activemq/branches/activemq-4.1/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/PendingDurableSubscriberMessageStoragePolicy.java   (props changed)
    incubator/activemq/branches/activemq-4.1/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/PendingQueueMessageStoragePolicy.java   (props changed)
    incubator/activemq/branches/activemq-4.1/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/StorePendingDurableSubscriberMessageStoragePolicy.java   (props changed)
    incubator/activemq/branches/activemq-4.1/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/VMPendingDurableSubscriberMessageStoragePolicy.java   (props changed)
    incubator/activemq/branches/activemq-4.1/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/VMPendingQueueMessageStoragePolicy.java   (props changed)
    incubator/activemq/branches/activemq-4.1/activemq-core/src/main/java/org/apache/activemq/broker/util/CommandAgent.java   (props changed)
    incubator/activemq/branches/activemq-4.1/activemq-core/src/main/java/org/apache/activemq/broker/util/CommandHandler.java   (props changed)
    incubator/activemq/branches/activemq-4.1/activemq-core/src/main/java/org/apache/activemq/broker/util/CommandMessageListener.java   (props changed)
    incubator/activemq/branches/activemq-4.1/activemq-core/src/main/java/org/apache/activemq/broker/util/MulticastTraceBrokerPlugin.java   (props changed)
    incubator/activemq/branches/activemq-4.1/activemq-core/src/main/java/org/apache/activemq/broker/util/UDPTraceBrokerPlugin.java   (props changed)
    incubator/activemq/branches/activemq-4.1/activemq-core/src/main/java/org/apache/activemq/command/JournalTrace.java   (props changed)
    incubator/activemq/branches/activemq-4.1/activemq-core/src/main/java/org/apache/activemq/kaha/IndexTypes.java   (props changed)
    incubator/activemq/branches/activemq-4.1/activemq-core/src/main/java/org/apache/activemq/kaha/StoreEntry.java   (props changed)
    incubator/activemq/branches/activemq-4.1/activemq-core/src/main/java/org/apache/activemq/kaha/StoreLocation.java   (props changed)
    incubator/activemq/branches/activemq-4.1/activemq-core/src/main/java/org/apache/activemq/kaha/impl/IndexRootContainer.java   (props changed)
    incubator/activemq/branches/activemq-4.1/activemq-core/src/main/java/org/apache/activemq/kaha/impl/StoreLockedExcpetion.java   (props changed)
    incubator/activemq/branches/activemq-4.1/activemq-core/src/main/java/org/apache/activemq/kaha/impl/container/CachedContainerListIterator.java   (props changed)
    incubator/activemq/branches/activemq-4.1/activemq-core/src/main/java/org/apache/activemq/kaha/impl/index/DiskIndexLinkedList.java   (contents, props changed)
    incubator/activemq/branches/activemq-4.1/activemq-core/src/main/java/org/apache/activemq/kaha/impl/index/IndexLinkedList.java   (props changed)
    incubator/activemq/branches/activemq-4.1/activemq-core/src/main/java/org/apache/activemq/kaha/impl/index/RangeLimitedMap.java   (props changed)
    incubator/activemq/branches/activemq-4.1/activemq-core/src/main/java/org/apache/activemq/kaha/impl/index/RangeLimitedMapKeySet.java   (props changed)
    incubator/activemq/branches/activemq-4.1/activemq-core/src/main/java/org/apache/activemq/kaha/impl/index/RangeLimitedMapKeySetIterator.java   (props changed)
    incubator/activemq/branches/activemq-4.1/activemq-core/src/main/java/org/apache/activemq/kaha/package.html   (props changed)
    incubator/activemq/branches/activemq-4.1/activemq-core/src/main/java/org/apache/activemq/security/JaasCertificateAuthenticationBroker.java   (props changed)
    incubator/activemq/branches/activemq-4.1/activemq-core/src/main/java/org/apache/activemq/security/JaasCertificateAuthenticationPlugin.java   (props changed)
    incubator/activemq/branches/activemq-4.1/activemq-core/src/main/java/org/apache/activemq/security/JaasCertificateSecurityContext.java   (props changed)
    incubator/activemq/branches/activemq-4.1/activemq-core/src/main/java/org/apache/activemq/state/Tracked.java   (props changed)
    incubator/activemq/branches/activemq-4.1/activemq-core/src/main/java/org/apache/activemq/state/TransactionState.java   (props changed)
    incubator/activemq/branches/activemq-4.1/activemq-core/src/main/java/org/apache/activemq/store/kahadaptor/ConsumerMessageRef.java   (props changed)
    incubator/activemq/branches/activemq-4.1/activemq-core/src/main/java/org/apache/activemq/store/kahadaptor/ConsumerMessageRefMarshaller.java   (props changed)
    incubator/activemq/branches/activemq-4.1/activemq-core/src/main/java/org/apache/activemq/store/kahadaptor/KahaPersistenceAdapter.java   (contents, props changed)
    incubator/activemq/branches/activemq-4.1/activemq-core/src/main/java/org/apache/activemq/store/kahadaptor/StoreEntryMarshaller.java   (props changed)
    incubator/activemq/branches/activemq-4.1/activemq-core/src/main/java/org/apache/activemq/store/kahadaptor/TopicSubAck.java   (props changed)
    incubator/activemq/branches/activemq-4.1/activemq-core/src/main/java/org/apache/activemq/store/kahadaptor/TopicSubAckMarshaller.java   (props changed)
    incubator/activemq/branches/activemq-4.1/activemq-core/src/main/java/org/apache/activemq/store/kahadaptor/TopicSubContainer.java   (props changed)
    incubator/activemq/branches/activemq-4.1/activemq-core/src/main/java/org/apache/activemq/transport/TransportDisposedIOException.java   (props changed)
    incubator/activemq/branches/activemq-4.1/activemq-core/src/main/java/org/apache/activemq/transport/stomp/FrameTranslator.java   (props changed)
    incubator/activemq/branches/activemq-4.1/activemq-core/src/main/java/org/apache/activemq/transport/stomp/LegacyFrameTranslator.java   (props changed)
    incubator/activemq/branches/activemq-4.1/activemq-core/src/main/java/org/apache/activemq/transport/tcp/SslTransport.java   (props changed)
    incubator/activemq/branches/activemq-4.1/activemq-core/src/main/java/org/apache/activemq/transport/tcp/SslTransportServer.java   (props changed)
    incubator/activemq/branches/activemq-4.1/activemq-core/src/main/java/org/apache/activemq/util/ByteArrayInputStream.java   (props changed)
    incubator/activemq/branches/activemq-4.1/activemq-core/src/main/java/org/apache/activemq/util/ByteArrayOutputStream.java   (props changed)
    incubator/activemq/branches/activemq-4.1/activemq-core/src/main/java/org/apache/activemq/util/ByteSequence.java   (props changed)
    incubator/activemq/branches/activemq-4.1/activemq-core/src/main/java/org/apache/activemq/util/ByteSequenceData.java   (props changed)
    incubator/activemq/branches/activemq-4.1/activemq-core/src/main/java/org/apache/activemq/util/ClassLoadingAwareObjectInputStream.java   (props changed)
    incubator/activemq/branches/activemq-4.1/activemq-core/src/main/java/org/apache/activemq/util/DataByteArrayInputStream.java   (props changed)
    incubator/activemq/branches/activemq-4.1/activemq-core/src/main/java/org/apache/activemq/util/DataByteArrayOutputStream.java   (props changed)
    incubator/activemq/branches/activemq-4.1/activemq-core/src/main/java/org/apache/activemq/util/FactoryFinder.java   (props changed)
    incubator/activemq/branches/activemq-4.1/activemq-core/src/main/java/org/apache/activemq/util/MemoryIntPropertyEditor.java   (props changed)
    incubator/activemq/branches/activemq-4.1/activemq-core/src/main/java/org/apache/activemq/util/MemoryPropertyEditor.java   (props changed)
    incubator/activemq/branches/activemq-4.1/activemq-core/src/main/java/org/apache/activemq/wireformat/ObjectStreamWireFormat.java   (props changed)
    incubator/activemq/branches/activemq-4.1/activemq-core/src/main/java/org/apache/activemq/wireformat/WireFormat.java   (props changed)
    incubator/activemq/branches/activemq-4.1/activemq-core/src/main/java/org/apache/activemq/wireformat/WireFormatFactory.java   (props changed)
    incubator/activemq/branches/activemq-4.1/activemq-core/src/main/java/org/apache/activemq/wireformat/package.html   (props changed)
    incubator/activemq/branches/activemq-4.1/activemq-core/src/main/resources/META-INF/NOTICE.txt   (contents, props changed)
    incubator/activemq/branches/activemq-4.1/activemq-core/src/test/eclipse-resources/log4j.properties   (props changed)
    incubator/activemq/branches/activemq-4.1/activemq-core/src/test/java/org/apache/activemq/JmsSendReceiveWithMessageExpirationTest.java   (contents, props changed)
    incubator/activemq/branches/activemq-4.1/activemq-core/src/test/java/org/apache/activemq/broker/BrokerServiceTest.java   (props changed)
    incubator/activemq/branches/activemq-4.1/activemq-core/src/test/java/org/apache/activemq/broker/StubBroker.java   (props changed)
    incubator/activemq/branches/activemq-4.1/activemq-core/src/test/java/org/apache/activemq/broker/region/cursors/CursorDurableTest.java   (props changed)
    incubator/activemq/branches/activemq-4.1/activemq-core/src/test/java/org/apache/activemq/broker/region/cursors/KahaCursorDurableTest.java   (props changed)
    incubator/activemq/branches/activemq-4.1/activemq-core/src/test/java/org/apache/activemq/kaha/VolumeTest.java   (props changed)
    incubator/activemq/branches/activemq-4.1/activemq-core/src/test/java/org/apache/activemq/kaha/impl/CachedListContainerImplTest.java   (props changed)
    incubator/activemq/branches/activemq-4.1/activemq-core/src/test/java/org/apache/activemq/kaha/impl/index/RangeLimitedMapTest.java   (props changed)
    incubator/activemq/branches/activemq-4.1/activemq-core/src/test/java/org/apache/activemq/kaha/impl/index/VMIndexLinkedListTest.java   (props changed)
    incubator/activemq/branches/activemq-4.1/activemq-core/src/test/java/org/apache/activemq/network/NetworkReconnectTest.java   (contents, props changed)
    incubator/activemq/branches/activemq-4.1/activemq-core/src/test/java/org/apache/activemq/network/SSHTunnelNetworkReconnectTest.java   (contents, props changed)
    incubator/activemq/branches/activemq-4.1/activemq-core/src/test/java/org/apache/activemq/perf/InactiveDurableTopicTest.java   (props changed)
    incubator/activemq/branches/activemq-4.1/activemq-core/src/test/java/org/apache/activemq/perf/InactiveQueueTest.java   (props changed)
    incubator/activemq/branches/activemq-4.1/activemq-core/src/test/java/org/apache/activemq/pool/ConnectionFailureEvictsFromPool.java   (props changed)
    incubator/activemq/branches/activemq-4.1/activemq-core/src/test/java/org/apache/activemq/security/JaasCertificateAuthenticationBrokerTest.java   (props changed)
    incubator/activemq/branches/activemq-4.1/activemq-core/src/test/java/org/apache/activemq/security/StubDoNothingCallbackHandler.java   (props changed)
    incubator/activemq/branches/activemq-4.1/activemq-core/src/test/java/org/apache/activemq/security/StubJaasConfiguration.java   (props changed)
    incubator/activemq/branches/activemq-4.1/activemq-core/src/test/java/org/apache/activemq/security/StubLoginModule.java   (props changed)
    incubator/activemq/branches/activemq-4.1/activemq-core/src/test/java/org/apache/activemq/security/StubSecurityContext.java   (props changed)
    incubator/activemq/branches/activemq-4.1/activemq-core/src/test/java/org/apache/activemq/transport/failover/ReconnectTest.java   (props changed)
    incubator/activemq/branches/activemq-4.1/activemq-core/src/test/java/org/apache/activemq/transport/tcp/SslTransportFactoryTest.java   (props changed)
    incubator/activemq/branches/activemq-4.1/activemq-core/src/test/java/org/apache/activemq/transport/tcp/SslTransportServerTest.java   (props changed)
    incubator/activemq/branches/activemq-4.1/activemq-core/src/test/java/org/apache/activemq/transport/tcp/SslTransportTest.java   (props changed)
    incubator/activemq/branches/activemq-4.1/activemq-core/src/test/java/org/apache/activemq/transport/tcp/StubSSLServerSocket.java   (props changed)
    incubator/activemq/branches/activemq-4.1/activemq-core/src/test/java/org/apache/activemq/transport/tcp/StubSSLSession.java   (props changed)
    incubator/activemq/branches/activemq-4.1/activemq-core/src/test/java/org/apache/activemq/transport/tcp/StubSSLSocket.java   (props changed)
    incubator/activemq/branches/activemq-4.1/activemq-core/src/test/java/org/apache/activemq/transport/tcp/StubSSLSocketFactory.java   (props changed)
    incubator/activemq/branches/activemq-4.1/activemq-core/src/test/java/org/apache/activemq/transport/tcp/StubSslTransport.java   (props changed)
    incubator/activemq/branches/activemq-4.1/activemq-core/src/test/java/org/apache/activemq/transport/tcp/StubX509Certificate.java   (props changed)
    incubator/activemq/branches/activemq-4.1/activemq-core/src/test/resources/META-INF/NOTICE.txt   (contents, props changed)
    incubator/activemq/branches/activemq-4.1/activemq-jaas/src/main/java/org/apache/activemq/jaas/CertificateCallback.java   (props changed)
    incubator/activemq/branches/activemq-4.1/activemq-jaas/src/main/java/org/apache/activemq/jaas/CertificateLoginModule.java   (props changed)
    incubator/activemq/branches/activemq-4.1/activemq-jaas/src/main/java/org/apache/activemq/jaas/JaasCertificateCallbackHandler.java   (props changed)
    incubator/activemq/branches/activemq-4.1/activemq-jaas/src/main/java/org/apache/activemq/jaas/JassCredentialCallbackHandler.java   (props changed)
    incubator/activemq/branches/activemq-4.1/activemq-jaas/src/main/java/org/apache/activemq/jaas/TextFileCertificateLoginModule.java   (props changed)
    incubator/activemq/branches/activemq-4.1/activemq-jaas/src/main/resources/META-INF/NOTICE.txt   (contents, props changed)
    incubator/activemq/branches/activemq-4.1/activemq-jaas/src/test/java/org/apache/activemq/jaas/CertificateLoginModuleTest.java   (props changed)
    incubator/activemq/branches/activemq-4.1/activemq-jaas/src/test/java/org/apache/activemq/jaas/StubCertificateLoginModule.java   (props changed)
    incubator/activemq/branches/activemq-4.1/activemq-openwire-generator/src/main/java/org/apache/activemq/openwire/tool/CGeneratorTask.java   (props changed)
    incubator/activemq/branches/activemq-4.1/activemq-openwire-generator/src/main/java/org/apache/activemq/openwire/tool/CHeadersGenerator.java   (props changed)
    incubator/activemq/branches/activemq-4.1/activemq-openwire-generator/src/main/java/org/apache/activemq/openwire/tool/CSharpClassesGenerator.java   (props changed)
    incubator/activemq/branches/activemq-4.1/activemq-openwire-generator/src/main/java/org/apache/activemq/openwire/tool/CSharpGeneratorTask.java   (props changed)
    incubator/activemq/branches/activemq-4.1/activemq-openwire-generator/src/main/java/org/apache/activemq/openwire/tool/CSharpMarshallingGenerator.java   (props changed)
    incubator/activemq/branches/activemq-4.1/activemq-openwire-generator/src/main/java/org/apache/activemq/openwire/tool/CSourcesGenerator.java   (props changed)
    incubator/activemq/branches/activemq-4.1/activemq-openwire-generator/src/main/java/org/apache/activemq/openwire/tool/CppGeneratorTask.java   (props changed)
    incubator/activemq/branches/activemq-4.1/activemq-openwire-generator/src/main/java/org/apache/activemq/openwire/tool/JavaGeneratorTask.java   (props changed)
    incubator/activemq/branches/activemq-4.1/activemq-openwire-generator/src/main/java/org/apache/activemq/openwire/tool/JavaMarshallingGenerator.java   (props changed)
    incubator/activemq/branches/activemq-4.1/activemq-openwire-generator/src/main/java/org/apache/activemq/openwire/tool/JavaTestsGenerator.java   (props changed)
    incubator/activemq/branches/activemq-4.1/activemq-openwire-generator/src/main/java/org/apache/activemq/openwire/tool/MultiSourceGenerator.java   (props changed)
    incubator/activemq/branches/activemq-4.1/activemq-openwire-generator/src/main/java/org/apache/activemq/openwire/tool/SingleSourceGenerator.java   (props changed)
    incubator/activemq/branches/activemq-4.1/activemq-optional/src/main/java/org/apache/activemq/filter/JAXPXPathEvaluator.java   (contents, props changed)
    incubator/activemq/branches/activemq-4.1/activemq-optional/src/main/java/org/apache/activemq/filter/XMLBeansXPathEvaluator.java   (contents, props changed)
    incubator/activemq/branches/activemq-4.1/activemq-optional/src/main/resources/META-INF/NOTICE.txt   (contents, props changed)
    incubator/activemq/branches/activemq-4.1/activemq-perftest/readme.html   (contents, props changed)
    incubator/activemq/branches/activemq-4.1/activemq-perftest/src/main/resources/consumer-conf/AMQ-Cons-1-1-queue.properties   (contents, props changed)
    incubator/activemq/branches/activemq-4.1/activemq-perftest/src/main/resources/consumer-conf/AMQ-Cons-1-1-topic-durable.properties   (contents, props changed)
    incubator/activemq/branches/activemq-4.1/activemq-perftest/src/main/resources/consumer-conf/AMQ-Cons-1-1-topic-nondurable.properties   (contents, props changed)
    incubator/activemq/branches/activemq-4.1/activemq-perftest/src/main/resources/consumer-conf/AMQ-Cons-10-1-queue.properties   (contents, props changed)
    incubator/activemq/branches/activemq-4.1/activemq-perftest/src/main/resources/consumer-conf/AMQ-Cons-10-1-topic-durable.properties   (contents, props changed)
    incubator/activemq/branches/activemq-4.1/activemq-perftest/src/main/resources/consumer-conf/AMQ-Cons-10-1-topic-nondurable.properties   (contents, props changed)
    incubator/activemq/branches/activemq-4.1/activemq-perftest/src/main/resources/consumer-conf/AMQ-Cons-10-10-queue.properties   (contents, props changed)
    incubator/activemq/branches/activemq-4.1/activemq-perftest/src/main/resources/consumer-conf/AMQ-Cons-10-10-topic-durable.properties   (contents, props changed)
    incubator/activemq/branches/activemq-4.1/activemq-perftest/src/main/resources/consumer-conf/AMQ-Cons-10-10-topic-nondurable.properties   (contents, props changed)
    incubator/activemq/branches/activemq-4.1/activemq-perftest/src/main/resources/producer-conf/AMQ-Prod-1-1-queue-nonpersistent.properties   (contents, props changed)
    incubator/activemq/branches/activemq-4.1/activemq-perftest/src/main/resources/producer-conf/AMQ-Prod-1-1-queue-persistent.properties   (contents, props changed)
    incubator/activemq/branches/activemq-4.1/activemq-perftest/src/main/resources/producer-conf/AMQ-Prod-1-1-topic-nonpersistent.properties   (contents, props changed)
    incubator/activemq/branches/activemq-4.1/activemq-perftest/src/main/resources/producer-conf/AMQ-Prod-1-1-topic-persistent.properties   (contents, props changed)
    incubator/activemq/branches/activemq-4.1/activemq-perftest/src/main/resources/producer-conf/AMQ-Prod-10-1-queue-nonpersistent.properties   (contents, props changed)
    incubator/activemq/branches/activemq-4.1/activemq-perftest/src/main/resources/producer-conf/AMQ-Prod-10-1-queue-persistent.properties   (contents, props changed)
    incubator/activemq/branches/activemq-4.1/activemq-perftest/src/main/resources/producer-conf/AMQ-Prod-10-1-topic-nonpersistent.properties   (contents, props changed)
    incubator/activemq/branches/activemq-4.1/activemq-perftest/src/main/resources/producer-conf/AMQ-Prod-10-1-topic-persistent.properties   (contents, props changed)
    incubator/activemq/branches/activemq-4.1/activemq-perftest/src/main/resources/producer-conf/AMQ-Prod-10-10-queue-nonpersistent.properties   (contents, props changed)
    incubator/activemq/branches/activemq-4.1/activemq-perftest/src/main/resources/producer-conf/AMQ-Prod-10-10-queue-persistent.properties   (contents, props changed)
    incubator/activemq/branches/activemq-4.1/activemq-perftest/src/main/resources/producer-conf/AMQ-Prod-10-10-topic-nonpersistent.properties   (contents, props changed)
    incubator/activemq/branches/activemq-4.1/activemq-perftest/src/main/resources/producer-conf/AMQ-Prod-10-10-topic-persistent.properties   (contents, props changed)
    incubator/activemq/branches/activemq-4.1/activemq-ra/src/main/resources/META-INF/NOTICE.txt   (contents, props changed)
    incubator/activemq/branches/activemq-4.1/activemq-rar/src/main/rar/META-INF/DISCLAIMER.txt   (contents, props changed)
    incubator/activemq/branches/activemq-4.1/activemq-rar/src/main/rar/META-INF/LICENSE.txt   (contents, props changed)
    incubator/activemq/branches/activemq-4.1/activemq-rar/src/main/rar/META-INF/NOTICE.txt   (contents, props changed)
    incubator/activemq/branches/activemq-4.1/activemq-soaktest/project.properties   (contents, props changed)
    incubator/activemq/branches/activemq-4.1/activemq-tooling/maven-activemq-memtest-plugin/readme.txt   (contents, props changed)
    incubator/activemq/branches/activemq-4.1/activemq-tooling/maven-activemq-memtest-plugin/src/main/resources/META-INF/NOTICE.txt   (contents, props changed)
    incubator/activemq/branches/activemq-4.1/activemq-tooling/maven-activemq-perf-plugin/src/main/resources/META-INF/NOTICE.txt   (contents, props changed)
    incubator/activemq/branches/activemq-4.1/activemq-tooling/maven-activemq-plugin/src/main/resources/META-INF/NOTICE.txt   (contents, props changed)
    incubator/activemq/branches/activemq-4.1/activemq-web-console/LICENSE.txt   (props changed)
    incubator/activemq/branches/activemq-4.1/activemq-web-console/src/main/webapp/META-INF/DISCLAIMER.txt   (props changed)
    incubator/activemq/branches/activemq-4.1/activemq-web-demo/src/main/webapp/META-INF/DISCLAIMER.txt   (props changed)
    incubator/activemq/branches/activemq-4.1/activemq-web/src/main/resources/META-INF/NOTICE.txt   (contents, props changed)
    incubator/activemq/branches/activemq-4.1/activemq-xmpp/src/main/resources/META-INF/NOTICE.txt   (contents, props changed)
    incubator/activemq/branches/activemq-4.1/assembly/src/main/resources/META-INF/NOTICE.txt   (contents, props changed)
    incubator/activemq/branches/activemq-4.1/assembly/src/release/NOTICE.txt   (contents, props changed)
    incubator/activemq/branches/activemq-4.1/assembly/src/release/example/ruby/README.txt   (props changed)
    incubator/activemq/branches/activemq-4.1/assembly/src/release/example/src/CommnadLineSupport.java   (props changed)
    incubator/activemq/branches/activemq-4.1/assembly/src/release/example/src/RequesterTool.java   (props changed)
    incubator/activemq/branches/activemq-4.1/assembly/src/release/example/src/TopicListener.java   (props changed)
    incubator/activemq/branches/activemq-4.1/assembly/src/release/example/src/TopicPublisher.java   (props changed)

Propchange: incubator/activemq/branches/activemq-4.1/DISCLAIMER.txt
------------------------------------------------------------------------------
    svn:eol-style = native

Modified: incubator/activemq/branches/activemq-4.1/NOTICE.txt
URL: http://svn.apache.org/viewvc/incubator/activemq/branches/activemq-4.1/NOTICE.txt?view=diff&rev=474986&r1=474985&r2=474986
==============================================================================
--- incubator/activemq/branches/activemq-4.1/NOTICE.txt (original)
+++ incubator/activemq/branches/activemq-4.1/NOTICE.txt Tue Nov 14 13:17:31 2006
@@ -1,11 +1,11 @@
-   =========================================================================
-   ==  NOTICE file corresponding to the section 4 d of                    ==
-   ==  the Apache License, Version 2.0,                                   ==
-   ==  in this case for the Apache ActiveMQ distribution.                 ==
-   =========================================================================
-
-   This product includes software developed by
-   The Apache Software Foundation (http://www.apache.org/).
-
-   Please read the different LICENSE files present in the licenses directory of
-   this distribution.
+   =========================================================================
+   ==  NOTICE file corresponding to the section 4 d of                    ==
+   ==  the Apache License, Version 2.0,                                   ==
+   ==  in this case for the Apache ActiveMQ distribution.                 ==
+   =========================================================================
+
+   This product includes software developed by
+   The Apache Software Foundation (http://www.apache.org/).
+
+   Please read the different LICENSE files present in the licenses directory of
+   this distribution.

Propchange: incubator/activemq/branches/activemq-4.1/NOTICE.txt
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/branches/activemq-4.1/activemq-console/src/main/java/org/apache/activemq/console/ConsoleCommandHandler.java
------------------------------------------------------------------------------
    svn:eol-style = native

Modified: incubator/activemq/branches/activemq-4.1/activemq-console/src/main/resources/META-INF/NOTICE.txt
URL: http://svn.apache.org/viewvc/incubator/activemq/branches/activemq-4.1/activemq-console/src/main/resources/META-INF/NOTICE.txt?view=diff&rev=474986&r1=474985&r2=474986
==============================================================================
--- incubator/activemq/branches/activemq-4.1/activemq-console/src/main/resources/META-INF/NOTICE.txt (original)
+++ incubator/activemq/branches/activemq-4.1/activemq-console/src/main/resources/META-INF/NOTICE.txt Tue Nov 14 13:17:31 2006
@@ -1,12 +1,12 @@
-=========================================================================
-==  NOTICE file corresponding to the section 4 d of                    ==
-==  the Apache License, Version 2.0,                                   ==
-==  in this case for the Apache ActiveMQ distribution.                 ==
-=========================================================================
-
-Apache ActiveMQ
-Copyright 2005-2006 The Apache Software Foundation
-
-This product includes software developed by
-The Apache Software Foundation (http://www.apache.org/).
-
+=========================================================================
+==  NOTICE file corresponding to the section 4 d of                    ==
+==  the Apache License, Version 2.0,                                   ==
+==  in this case for the Apache ActiveMQ distribution.                 ==
+=========================================================================
+
+Apache ActiveMQ
+Copyright 2005-2006 The Apache Software Foundation
+
+This product includes software developed by
+The Apache Software Foundation (http://www.apache.org/).
+

Propchange: incubator/activemq/branches/activemq-4.1/activemq-console/src/main/resources/META-INF/NOTICE.txt
------------------------------------------------------------------------------
    svn:eol-style = native

Modified: incubator/activemq/branches/activemq-4.1/activemq-console/src/test/resources/log4j.properties
URL: http://svn.apache.org/viewvc/incubator/activemq/branches/activemq-4.1/activemq-console/src/test/resources/log4j.properties?view=diff&rev=474986&r1=474985&r2=474986
==============================================================================
--- incubator/activemq/branches/activemq-4.1/activemq-console/src/test/resources/log4j.properties (original)
+++ incubator/activemq/branches/activemq-4.1/activemq-console/src/test/resources/log4j.properties Tue Nov 14 13:17:31 2006
@@ -1,28 +1,28 @@
-## ---------------------------------------------------------------------------
-## Licensed to the Apache Software Foundation (ASF) under one or more
-## contributor license agreements.  See the NOTICE file distributed with
-## this work for additional information regarding copyright ownership.
-## The ASF licenses this file to You under the Apache License, Version 2.0
-## (the "License"); you may not use this file except in compliance with
-## the License.  You may obtain a copy of the License at
-## 
-## http://www.apache.org/licenses/LICENSE-2.0
-## 
-## Unless required by applicable law or agreed to in writing, software
-## distributed under the License is distributed on an "AS IS" BASIS,
-## WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-## See the License for the specific language governing permissions and
-## limitations under the License.
-## ---------------------------------------------------------------------------
-
-#
-# The logging properties used during tests..
-#
-log4j.rootLogger=DEBUG, stdout
-
-log4j.logger.org.apache.activemq.spring=WARN
-
-# CONSOLE appender not used by default
-log4j.appender.stdout=org.apache.log4j.ConsoleAppender
-log4j.appender.stdout.layout=org.apache.log4j.PatternLayout
+## ---------------------------------------------------------------------------
+## Licensed to the Apache Software Foundation (ASF) under one or more
+## contributor license agreements.  See the NOTICE file distributed with
+## this work for additional information regarding copyright ownership.
+## The ASF licenses this file to You under the Apache License, Version 2.0
+## (the "License"); you may not use this file except in compliance with
+## the License.  You may obtain a copy of the License at
+## 
+## http://www.apache.org/licenses/LICENSE-2.0
+## 
+## Unless required by applicable law or agreed to in writing, software
+## distributed under the License is distributed on an "AS IS" BASIS,
+## WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+## See the License for the specific language governing permissions and
+## limitations under the License.
+## ---------------------------------------------------------------------------
+
+#
+# The logging properties used during tests..
+#
+log4j.rootLogger=DEBUG, stdout
+
+log4j.logger.org.apache.activemq.spring=WARN
+
+# CONSOLE appender not used by default
+log4j.appender.stdout=org.apache.log4j.ConsoleAppender
+log4j.appender.stdout.layout=org.apache.log4j.PatternLayout
 log4j.appender.stdout.layout.ConversionPattern=%d [%-15.15t] %-5p %-30.30c{1} - %m%n

Propchange: incubator/activemq/branches/activemq-4.1/activemq-console/src/test/resources/log4j.properties
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/branches/activemq-4.1/activemq-core/src/main/java/org/apache/activemq/ActiveMQSslConnectionFactory.java
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/branches/activemq-4.1/activemq-core/src/main/java/org/apache/activemq/Disposable.java
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/branches/activemq-4.1/activemq-core/src/main/java/org/apache/activemq/broker/SslBrokerService.java
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/branches/activemq-4.1/activemq-core/src/main/java/org/apache/activemq/broker/region/DestinationFactory.java
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/branches/activemq-4.1/activemq-core/src/main/java/org/apache/activemq/broker/region/DestinationFactoryImpl.java
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/branches/activemq-4.1/activemq-core/src/main/java/org/apache/activemq/broker/region/NullMessageReference.java
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/branches/activemq-4.1/activemq-core/src/main/java/org/apache/activemq/broker/region/QueueMessageReference.java
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/branches/activemq-4.1/activemq-core/src/main/java/org/apache/activemq/broker/region/cursors/AbstractPendingMessageCursor.java
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/branches/activemq-4.1/activemq-core/src/main/java/org/apache/activemq/broker/region/cursors/FilePendingMessageCursor.java
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/branches/activemq-4.1/activemq-core/src/main/java/org/apache/activemq/broker/region/cursors/PendingMessageCursor.java
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/branches/activemq-4.1/activemq-core/src/main/java/org/apache/activemq/broker/region/cursors/StoreDurableSubscriberCursor.java
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/branches/activemq-4.1/activemq-core/src/main/java/org/apache/activemq/broker/region/cursors/TopicStorePrefetch.java
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/branches/activemq-4.1/activemq-core/src/main/java/org/apache/activemq/broker/region/cursors/VMPendingMessageCursor.java
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/branches/activemq-4.1/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/FilePendingDurableSubscriberMessageStoragePolicy.java
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/branches/activemq-4.1/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/PendingDurableSubscriberMessageStoragePolicy.java
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/branches/activemq-4.1/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/PendingQueueMessageStoragePolicy.java
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/branches/activemq-4.1/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/StorePendingDurableSubscriberMessageStoragePolicy.java
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/branches/activemq-4.1/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/VMPendingDurableSubscriberMessageStoragePolicy.java
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/branches/activemq-4.1/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/VMPendingQueueMessageStoragePolicy.java
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/branches/activemq-4.1/activemq-core/src/main/java/org/apache/activemq/broker/util/CommandAgent.java
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/branches/activemq-4.1/activemq-core/src/main/java/org/apache/activemq/broker/util/CommandHandler.java
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/branches/activemq-4.1/activemq-core/src/main/java/org/apache/activemq/broker/util/CommandMessageListener.java
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/branches/activemq-4.1/activemq-core/src/main/java/org/apache/activemq/broker/util/MulticastTraceBrokerPlugin.java
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/branches/activemq-4.1/activemq-core/src/main/java/org/apache/activemq/broker/util/UDPTraceBrokerPlugin.java
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/branches/activemq-4.1/activemq-core/src/main/java/org/apache/activemq/command/JournalTrace.java
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/branches/activemq-4.1/activemq-core/src/main/java/org/apache/activemq/kaha/IndexTypes.java
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/branches/activemq-4.1/activemq-core/src/main/java/org/apache/activemq/kaha/StoreEntry.java
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/branches/activemq-4.1/activemq-core/src/main/java/org/apache/activemq/kaha/StoreLocation.java
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/branches/activemq-4.1/activemq-core/src/main/java/org/apache/activemq/kaha/impl/IndexRootContainer.java
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/branches/activemq-4.1/activemq-core/src/main/java/org/apache/activemq/kaha/impl/StoreLockedExcpetion.java
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/branches/activemq-4.1/activemq-core/src/main/java/org/apache/activemq/kaha/impl/container/CachedContainerListIterator.java
------------------------------------------------------------------------------
    svn:eol-style = native

Modified: incubator/activemq/branches/activemq-4.1/activemq-core/src/main/java/org/apache/activemq/kaha/impl/index/DiskIndexLinkedList.java
URL: http://svn.apache.org/viewvc/incubator/activemq/branches/activemq-4.1/activemq-core/src/main/java/org/apache/activemq/kaha/impl/index/DiskIndexLinkedList.java?view=diff&rev=474986&r1=474985&r2=474986
==============================================================================
--- incubator/activemq/branches/activemq-4.1/activemq-core/src/main/java/org/apache/activemq/kaha/impl/index/DiskIndexLinkedList.java (original)
+++ incubator/activemq/branches/activemq-4.1/activemq-core/src/main/java/org/apache/activemq/kaha/impl/index/DiskIndexLinkedList.java Tue Nov 14 13:17:31 2006
@@ -15,257 +15,257 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package org.apache.activemq.kaha.impl.index;
-
-import java.io.IOException;
+package org.apache.activemq.kaha.impl.index;
+
+import java.io.IOException;
 import org.apache.activemq.kaha.StoreEntry;
-/**
- * A linked list used by IndexItems
- * 
- * @version $Revision$
- */
-public class DiskIndexLinkedList implements IndexLinkedList{
-    protected IndexManager indexManager;
-    protected transient IndexItem root;
-    protected transient IndexItem last;
-    protected transient int size=0;
-
-    /**
-     * Constructs an empty list.
-     */
-    public DiskIndexLinkedList(IndexManager im,IndexItem header){
-        this.indexManager=im;
-        this.root=header;
-    }
-
-    public IndexItem getRoot(){
-        return root;
-    }
-
-    void setRoot(IndexItem e){
-        this.root=e;
-    }
-
-    /**
-     * Returns the first element in this list.
-     * 
-     * @return the first element in this list.
-     */
-    public IndexItem getFirst(){
-        if(size==0)
-            return null;
-        return getNextEntry(root);
-    }
-
-    /**
-     * Returns the last element in this list.
-     * 
-     * @return the last element in this list.
-     */
-    public IndexItem getLast(){
-        if(size==0)
-            return null;
-        return last;
-    }
-
-    /**
-     * Removes and returns the first element from this list.
-     * 
-     * @return the first element from this list.
-     */
-    public StoreEntry removeFirst(){
-        if(size==0){
-            return null;
-        }
-        IndexItem result=getNextEntry(root);
-        remove(result);
-        return result;
-    }
-
-    /**
-     * Removes and returns the last element from this list.
-     * 
-     * @return the last element from this list.
-     */
-    public Object removeLast(){
-        if(size==0)
-            return null;
-        StoreEntry result=last;
-        remove(last);
-        return result;
-    }
-
-    /**
-     * Inserts the given element at the beginning of this list.
-     * 
-     * @param o the element to be inserted at the beginning of this list.
-     */
-    public void addFirst(IndexItem item){
-        if(size==0){
-            last=item;
-        }
-        size++;
-    }
-
-    /**
-     * Appends the given element to the end of this list. (Identical in function to the <tt>add</tt> method; included
-     * only for consistency.)
-     * 
-     * @param o the element to be inserted at the end of this list.
-     */
-    public void addLast(IndexItem item){
-        size++;
-        last=item;
-    }
-
-    /**
-     * Returns the number of elements in this list.
-     * 
-     * @return the number of elements in this list.
-     */
-    public int size(){
-        return size;
-    }
-
-    /**
-     * is the list empty?
-     * 
-     * @return true if there are no elements in the list
-     */
-    public boolean isEmpty(){
-        return size==0;
-    }
-
-    /**
-     * Appends the specified element to the end of this list.
-     * 
-     * @param o element to be appended to this list.
-     * @return <tt>true</tt> (as per the general contract of <tt>Collection.add</tt>).
-     */
+/**
+ * A linked list used by IndexItems
+ * 
+ * @version $Revision$
+ */
+public class DiskIndexLinkedList implements IndexLinkedList{
+    protected IndexManager indexManager;
+    protected transient IndexItem root;
+    protected transient IndexItem last;
+    protected transient int size=0;
+
+    /**
+     * Constructs an empty list.
+     */
+    public DiskIndexLinkedList(IndexManager im,IndexItem header){
+        this.indexManager=im;
+        this.root=header;
+    }
+
+    public IndexItem getRoot(){
+        return root;
+    }
+
+    void setRoot(IndexItem e){
+        this.root=e;
+    }
+
+    /**
+     * Returns the first element in this list.
+     * 
+     * @return the first element in this list.
+     */
+    public IndexItem getFirst(){
+        if(size==0)
+            return null;
+        return getNextEntry(root);
+    }
+
+    /**
+     * Returns the last element in this list.
+     * 
+     * @return the last element in this list.
+     */
+    public IndexItem getLast(){
+        if(size==0)
+            return null;
+        return last;
+    }
+
+    /**
+     * Removes and returns the first element from this list.
+     * 
+     * @return the first element from this list.
+     */
+    public StoreEntry removeFirst(){
+        if(size==0){
+            return null;
+        }
+        IndexItem result=getNextEntry(root);
+        remove(result);
+        return result;
+    }
+
+    /**
+     * Removes and returns the last element from this list.
+     * 
+     * @return the last element from this list.
+     */
+    public Object removeLast(){
+        if(size==0)
+            return null;
+        StoreEntry result=last;
+        remove(last);
+        return result;
+    }
+
+    /**
+     * Inserts the given element at the beginning of this list.
+     * 
+     * @param o the element to be inserted at the beginning of this list.
+     */
+    public void addFirst(IndexItem item){
+        if(size==0){
+            last=item;
+        }
+        size++;
+    }
+
+    /**
+     * Appends the given element to the end of this list. (Identical in function to the <tt>add</tt> method; included
+     * only for consistency.)
+     * 
+     * @param o the element to be inserted at the end of this list.
+     */
+    public void addLast(IndexItem item){
+        size++;
+        last=item;
+    }
+
+    /**
+     * Returns the number of elements in this list.
+     * 
+     * @return the number of elements in this list.
+     */
+    public int size(){
+        return size;
+    }
+
+    /**
+     * is the list empty?
+     * 
+     * @return true if there are no elements in the list
+     */
+    public boolean isEmpty(){
+        return size==0;
+    }
+
+    /**
+     * Appends the specified element to the end of this list.
+     * 
+     * @param o element to be appended to this list.
+     * @return <tt>true</tt> (as per the general contract of <tt>Collection.add</tt>).
+     */
     public boolean add(IndexItem item){
-        addLast(item);
-        return true;
-    }
-
-    /**
-     * Removes all of the elements from this list.
-     */
-    public void clear(){
-        last=null;
-        size=0;
-    }
-
-    // Positional Access Operations
-    /**
-     * Returns the element at the specified position in this list.
-     * 
-     * @param index index of element to return.
-     * @return the element at the specified position in this list.
-     * 
-     * @throws IndexOutOfBoundsException if the specified index is is out of range (<tt>index &lt; 0 || index &gt;= size()</tt>).
-     */
-    public IndexItem get(int index){
-        return entry(index);
-    }
-
-    /**
-     * Inserts the specified element at the specified position in this list. Shifts the element currently at that
-     * position (if any) and any subsequent elements to the right (adds one to their indices).
-     * 
-     * @param index index at which the specified element is to be inserted.
-     * @param element element to be inserted.
-     * 
-     * @throws IndexOutOfBoundsException if the specified index is out of range (<tt>index &lt; 0 || index &gt; size()</tt>).
-     */
-    public void add(int index,IndexItem element){
-        if(index==size-1){
-            last=element;
-        }
-        size++;
-    }
-
-    /**
-     * Removes the element at the specified position in this list. Shifts any subsequent elements to the left (subtracts
-     * one from their indices). Returns the element that was removed from the list.
-     * 
-     * @param index the index of the element to removed.
-     * @return the element previously at the specified position.
-     * 
-     * @throws IndexOutOfBoundsException if the specified index is out of range (<tt>index &lt; 0 || index &gt;= size()</tt>).
-     */
-    public Object remove(int index){
-        IndexItem e=entry(index);
-        remove(e);
-        return e;
-    }
-
-    /**
-     * Return the indexed entry.
-     */
-    private IndexItem entry(int index){
-        if(index<0||index>=size)
-            throw new IndexOutOfBoundsException("Index: "+index+", Size: "+size);
-        IndexItem e=root;
-        
-        for(int i=0;i<=index;i++)
-            e=getNextEntry(e);
-        if(e != null &&last!=null && last.equals(e)){
-            last = e;
-         }
-        return e;
-    }
-
-    // Search Operations
-    /**
-     * Returns the index in this list of the first occurrence of the specified element, or -1 if the List does not
-     * contain this element. More formally, returns the lowest index i such that
-     * <tt>(o==null ? get(i)==null : o.equals(get(i)))</tt>, or -1 if there is no such index.
-     * 
-     * @param o element to search for.
-     * @return the index in this list of the first occurrence of the specified element, or -1 if the list does not
-     *         contain this element.
-     */
-    public int indexOf(StoreEntry o){
-        int index=0;
-        if(size>0){
-            for(IndexItem e=getNextEntry(root);e!=null;e=getNextEntry(e)){
-                if(o.equals(e)){
-                    return index;
-                }
-                index++;
-            }
-        }
-        return -1;
-    }
-
-    /**
-     * Retrieve the next entry after this entry
-     * 
-     * @param entry
-     * @return next entry
-     */
-    public IndexItem getNextEntry(IndexItem current){
-        IndexItem result=null;
-        if(current!=null&&current.getNextItem()>=0){
-            try{
-                result=indexManager.getIndex(current.getNextItem());
-            }catch(IOException e){
-                throw new RuntimeException("Failed to get next index from " + indexManager + " for " + current,e);
-            }
-        }
-        //      essential last get's updated consistently
-        if(result != null &&last!=null && last.equals(result)){
-           result = last;
-        }
-        return result;
-    }
-
-    /**
-     * Retrive the prev entry after this entry
-     * 
-     * @param entry
-     * @return prev entry
-     */
+        addLast(item);
+        return true;
+    }
+
+    /**
+     * Removes all of the elements from this list.
+     */
+    public void clear(){
+        last=null;
+        size=0;
+    }
+
+    // Positional Access Operations
+    /**
+     * Returns the element at the specified position in this list.
+     * 
+     * @param index index of element to return.
+     * @return the element at the specified position in this list.
+     * 
+     * @throws IndexOutOfBoundsException if the specified index is is out of range (<tt>index &lt; 0 || index &gt;= size()</tt>).
+     */
+    public IndexItem get(int index){
+        return entry(index);
+    }
+
+    /**
+     * Inserts the specified element at the specified position in this list. Shifts the element currently at that
+     * position (if any) and any subsequent elements to the right (adds one to their indices).
+     * 
+     * @param index index at which the specified element is to be inserted.
+     * @param element element to be inserted.
+     * 
+     * @throws IndexOutOfBoundsException if the specified index is out of range (<tt>index &lt; 0 || index &gt; size()</tt>).
+     */
+    public void add(int index,IndexItem element){
+        if(index==size-1){
+            last=element;
+        }
+        size++;
+    }
+
+    /**
+     * Removes the element at the specified position in this list. Shifts any subsequent elements to the left (subtracts
+     * one from their indices). Returns the element that was removed from the list.
+     * 
+     * @param index the index of the element to removed.
+     * @return the element previously at the specified position.
+     * 
+     * @throws IndexOutOfBoundsException if the specified index is out of range (<tt>index &lt; 0 || index &gt;= size()</tt>).
+     */
+    public Object remove(int index){
+        IndexItem e=entry(index);
+        remove(e);
+        return e;
+    }
+
+    /**
+     * Return the indexed entry.
+     */
+    private IndexItem entry(int index){
+        if(index<0||index>=size)
+            throw new IndexOutOfBoundsException("Index: "+index+", Size: "+size);
+        IndexItem e=root;
+        
+        for(int i=0;i<=index;i++)
+            e=getNextEntry(e);
+        if(e != null &&last!=null && last.equals(e)){
+            last = e;
+         }
+        return e;
+    }
+
+    // Search Operations
+    /**
+     * Returns the index in this list of the first occurrence of the specified element, or -1 if the List does not
+     * contain this element. More formally, returns the lowest index i such that
+     * <tt>(o==null ? get(i)==null : o.equals(get(i)))</tt>, or -1 if there is no such index.
+     * 
+     * @param o element to search for.
+     * @return the index in this list of the first occurrence of the specified element, or -1 if the list does not
+     *         contain this element.
+     */
+    public int indexOf(StoreEntry o){
+        int index=0;
+        if(size>0){
+            for(IndexItem e=getNextEntry(root);e!=null;e=getNextEntry(e)){
+                if(o.equals(e)){
+                    return index;
+                }
+                index++;
+            }
+        }
+        return -1;
+    }
+
+    /**
+     * Retrieve the next entry after this entry
+     * 
+     * @param entry
+     * @return next entry
+     */
+    public IndexItem getNextEntry(IndexItem current){
+        IndexItem result=null;
+        if(current!=null&&current.getNextItem()>=0){
+            try{
+                result=indexManager.getIndex(current.getNextItem());
+            }catch(IOException e){
+                throw new RuntimeException("Failed to get next index from " + indexManager + " for " + current,e);
+            }
+        }
+        //      essential last get's updated consistently
+        if(result != null &&last!=null && last.equals(result)){
+           result = last;
+        }
+        return result;
+    }
+
+    /**
+     * Retrive the prev entry after this entry
+     * 
+     * @param entry
+     * @return prev entry
+     */
     public IndexItem getPrevEntry(IndexItem current){
         IndexItem result=null;
         if(current!=null&&current.getPreviousItem()>=0){
@@ -280,22 +280,22 @@
             return root;
         }
         return result;
-    }
-    
-   public  StoreEntry getEntry(StoreEntry current){
-        StoreEntry result=null;
-        if(current != null && current.getOffset() >= 0){
-            try{
-                result=indexManager.getIndex(current.getOffset());
-            }catch(IOException e){
-                throw new RuntimeException("Failed to index",e);
-            }
-        }
-        //essential root get's updated consistently
-        if(result != null &&root!=null && root.equals(result)){
-           return root;
-        }
-        return result;
+    }
+    
+   public  StoreEntry getEntry(StoreEntry current){
+        StoreEntry result=null;
+        if(current != null && current.getOffset() >= 0){
+            try{
+                result=indexManager.getIndex(current.getOffset());
+            }catch(IOException e){
+                throw new RuntimeException("Failed to index",e);
+            }
+        }
+        //essential root get's updated consistently
+        if(result != null &&root!=null && root.equals(result)){
+           return root;
+        }
+        return result;
     }
    
    /**
@@ -316,18 +316,18 @@
           return root;
        }
        return result;
-   }
-
-    public void remove(IndexItem e){
-        if(e==root||e.equals(root))
-            return;
-        if(e==last||e.equals(last)){
-            if(size>1){
-                last=getPrevEntry(last);
-            }else{
-                last=null;
-            }
-        }
-        size--;
-    }
-}
+   }
+
+    public void remove(IndexItem e){
+        if(e==root||e.equals(root))
+            return;
+        if(e==last||e.equals(last)){
+            if(size>1){
+                last=getPrevEntry(last);
+            }else{
+                last=null;
+            }
+        }
+        size--;
+    }
+}

Propchange: incubator/activemq/branches/activemq-4.1/activemq-core/src/main/java/org/apache/activemq/kaha/impl/index/DiskIndexLinkedList.java
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/branches/activemq-4.1/activemq-core/src/main/java/org/apache/activemq/kaha/impl/index/IndexLinkedList.java
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/branches/activemq-4.1/activemq-core/src/main/java/org/apache/activemq/kaha/impl/index/RangeLimitedMap.java
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/branches/activemq-4.1/activemq-core/src/main/java/org/apache/activemq/kaha/impl/index/RangeLimitedMapKeySet.java
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/branches/activemq-4.1/activemq-core/src/main/java/org/apache/activemq/kaha/impl/index/RangeLimitedMapKeySetIterator.java
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/branches/activemq-4.1/activemq-core/src/main/java/org/apache/activemq/kaha/package.html
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/branches/activemq-4.1/activemq-core/src/main/java/org/apache/activemq/security/JaasCertificateAuthenticationBroker.java
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/branches/activemq-4.1/activemq-core/src/main/java/org/apache/activemq/security/JaasCertificateAuthenticationPlugin.java
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/branches/activemq-4.1/activemq-core/src/main/java/org/apache/activemq/security/JaasCertificateSecurityContext.java
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/branches/activemq-4.1/activemq-core/src/main/java/org/apache/activemq/state/Tracked.java
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/branches/activemq-4.1/activemq-core/src/main/java/org/apache/activemq/state/TransactionState.java
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/branches/activemq-4.1/activemq-core/src/main/java/org/apache/activemq/store/kahadaptor/ConsumerMessageRef.java
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/branches/activemq-4.1/activemq-core/src/main/java/org/apache/activemq/store/kahadaptor/ConsumerMessageRefMarshaller.java
------------------------------------------------------------------------------
    svn:eol-style = native

Modified: incubator/activemq/branches/activemq-4.1/activemq-core/src/main/java/org/apache/activemq/store/kahadaptor/KahaPersistenceAdapter.java
URL: http://svn.apache.org/viewvc/incubator/activemq/branches/activemq-4.1/activemq-core/src/main/java/org/apache/activemq/store/kahadaptor/KahaPersistenceAdapter.java?view=diff&rev=474986&r1=474985&r2=474986
==============================================================================
--- incubator/activemq/branches/activemq-4.1/activemq-core/src/main/java/org/apache/activemq/store/kahadaptor/KahaPersistenceAdapter.java (original)
+++ incubator/activemq/branches/activemq-4.1/activemq-core/src/main/java/org/apache/activemq/store/kahadaptor/KahaPersistenceAdapter.java Tue Nov 14 13:17:31 2006
@@ -1,249 +1,249 @@
-/**
- * 
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with this
- * work for additional information regarding copyright ownership. The ASF
- * licenses this file to You under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
- * 
- * http://www.apache.org/licenses/LICENSE-2.0
- * 
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
- * WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
- * License for the specific language governing permissions and limitations under
- * the License.
- */
-
-package org.apache.activemq.store.kahadaptor;
-
-import java.io.File;
-import java.io.IOException;
-import java.util.HashSet;
-import java.util.Iterator;
-import java.util.Set;
-import org.apache.activemq.broker.ConnectionContext;
-import org.apache.activemq.command.ActiveMQDestination;
-import org.apache.activemq.command.ActiveMQQueue;
-import org.apache.activemq.command.ActiveMQTopic;
-import org.apache.activemq.kaha.IndexTypes;
-import org.apache.activemq.kaha.ListContainer;
-import org.apache.activemq.kaha.MapContainer;
-import org.apache.activemq.kaha.Store;
-import org.apache.activemq.kaha.StoreFactory;
-import org.apache.activemq.kaha.StringMarshaller;
-import org.apache.activemq.memory.UsageManager;
-import org.apache.activemq.openwire.OpenWireFormat;
-import org.apache.activemq.store.MessageStore;
-import org.apache.activemq.store.PersistenceAdapter;
-import org.apache.activemq.store.TopicMessageStore;
-import org.apache.activemq.store.TransactionStore;
-import org.apache.commons.logging.Log;
-import org.apache.commons.logging.LogFactory;
-import edu.emory.mathcs.backport.java.util.concurrent.ConcurrentHashMap;
-
-/**
- * @org.apache.xbean.XBean
- * 
- * @version $Revision: 1.4 $
- */
-public class KahaPersistenceAdapter implements PersistenceAdapter{
-
-    private static final Log log=LogFactory.getLog(KahaPersistenceAdapter.class);
-    static final String PREPARED_TRANSACTIONS_NAME="PreparedTransactions";
-    KahaTransactionStore transactionStore;
-    ConcurrentHashMap topics=new ConcurrentHashMap();
-    ConcurrentHashMap queues=new ConcurrentHashMap();
-    ConcurrentHashMap messageStores=new ConcurrentHashMap();
-    private boolean useExternalMessageReferences;
-    private OpenWireFormat wireFormat=new OpenWireFormat();
-    private long maxDataFileLength=32*1024*1024;
-    private String indexType=IndexTypes.DISK_INDEX;
-    private File dir;
-    private Store theStore;
-
-    public KahaPersistenceAdapter(File dir) throws IOException{
-        if(!dir.exists()){
-            dir.mkdirs();
-        }
-        this.dir=dir;
-    }
-
-    public Set getDestinations(){
-        Set rc=new HashSet();
-        try{
-            Store store=getStore();
-            for(Iterator i=store.getMapContainerIds().iterator();i.hasNext();){
-                Object obj=i.next();
-                if(obj instanceof ActiveMQDestination){
-                    rc.add(obj);
-                }
-            }
-        }catch(IOException e){
-            log.error("Failed to get destinations ",e);
-        }
-        return rc;
-    }
-
-    public synchronized MessageStore createQueueMessageStore(ActiveMQQueue destination) throws IOException{
-        MessageStore rc=(MessageStore)queues.get(destination);
-        if(rc==null){
-            rc=new KahaMessageStore(getMapContainer(destination,"queue-data"),destination);
-            messageStores.put(destination,rc);
-            if(transactionStore!=null){
-                rc=transactionStore.proxy(rc);
-            }
-            queues.put(destination,rc);
-        }
-        return rc;
-    }
-
-    public synchronized TopicMessageStore createTopicMessageStore(ActiveMQTopic destination) throws IOException{
-        TopicMessageStore rc=(TopicMessageStore)topics.get(destination);
-        if(rc==null){
-            Store store=getStore();
-            ListContainer messageContainer=getListContainer(destination,"topic-data");
-            MapContainer subsContainer=getMapContainer(destination.toString()+"-Subscriptions","topic-subs");
-            ListContainer ackContainer=store.getListContainer(destination.toString(),"topic-acks");
-            ackContainer.setMarshaller(new TopicSubAckMarshaller());
-            rc=new KahaTopicMessageStore(store,messageContainer,ackContainer,subsContainer,destination);
-            messageStores.put(destination,rc);
-            if(transactionStore!=null){
-                rc=transactionStore.proxy(rc);
-            }
-            topics.put(destination,rc);
-        }
-        return rc;
-    }
-
-    protected MessageStore retrieveMessageStore(Object id){
-        MessageStore result=(MessageStore)messageStores.get(id);
-        return result;
-    }
-
-    public TransactionStore createTransactionStore() throws IOException{
-        if(transactionStore==null){
-            Store store=getStore();
-            MapContainer container=store.getMapContainer(PREPARED_TRANSACTIONS_NAME,"transactions");
-            container.setKeyMarshaller(new CommandMarshaller(wireFormat));
-            container.setValueMarshaller(new TransactionMarshaller(wireFormat));
-            container.load();
-            transactionStore=new KahaTransactionStore(this,container);
-        }
-        return transactionStore;
-    }
-
-    public void beginTransaction(ConnectionContext context){
-    }
-
-    public void commitTransaction(ConnectionContext context) throws IOException{
-        if(theStore!=null){
-            theStore.force();
-        }
-    }
-
-    public void rollbackTransaction(ConnectionContext context){
-    }
-
-    public void start() throws Exception{
-    }
-
-    public void stop() throws Exception{
-        if(theStore!=null){
-            theStore.close();
-        }
-    }
-
-    public long getLastMessageBrokerSequenceId() throws IOException{
-        return 0;
-    }
-
-    public void deleteAllMessages() throws IOException{
-        if(theStore!=null){
-            theStore.delete();
-        }
-    }
-
-    public boolean isUseExternalMessageReferences(){
-        return useExternalMessageReferences;
-    }
-
-    public void setUseExternalMessageReferences(boolean useExternalMessageReferences){
-        this.useExternalMessageReferences=useExternalMessageReferences;
-    }
-
-    protected MapContainer getMapContainer(Object id,String containerName) throws IOException{
-        Store store=getStore();
-        MapContainer container=store.getMapContainer(id,containerName);
-        container.setKeyMarshaller(new StringMarshaller());
-        if(useExternalMessageReferences){
-            container.setValueMarshaller(new StringMarshaller());
-        }else{
-            container.setValueMarshaller(new CommandMarshaller(wireFormat));
-        }
-        container.load();
-        return container;
-    }
-    
-    protected ListContainer getListContainer(Object id,String containerName) throws IOException{
-        Store store=getStore();
-        ListContainer container=store.getListContainer(id,containerName);
-        if(useExternalMessageReferences){
-            container.setMarshaller(new StringMarshaller());
-        }else{
-            container.setMarshaller(new CommandMarshaller(wireFormat));
-        }
-        container.load();
-        return container;
-    }
-
-    /**
-     * @param usageManager
-     *            The UsageManager that is controlling the broker's memory
-     *            usage.
-     */
-    public void setUsageManager(UsageManager usageManager){
-    }
-
-    /**
-     * @return the maxDataFileLength
-     */
-    public long getMaxDataFileLength(){
-        return maxDataFileLength;
-    }
-
-    /**
-     * @param maxDataFileLength
-     *            the maxDataFileLength to set
-     * 
-     * @org.apache.xbean.Property propertyEditor="org.apache.activemq.util.MemoryPropertyEditor"
-     */
-    public void setMaxDataFileLength(long maxDataFileLength){
-        this.maxDataFileLength=maxDataFileLength;
-    }
-
-    /**
-     * @return the indexType
-     */
-    public String getIndexType(){
-        return this.indexType;
-    }
-
-    /**
-     * @param indexType the indexTypes to set
-     */
-    public void setIndexType(String indexType){
-        this.indexType=indexType;
-    }
-
-    protected synchronized Store getStore() throws IOException{
-        if(theStore==null){
-            String name=dir.getAbsolutePath()+File.separator+"kaha.db";
-            theStore=StoreFactory.open(name,"rw");
-            theStore.setMaxDataFileLength(maxDataFileLength);
-            theStore.setIndexType(indexType);
-        }
-        return theStore;
-    }
-}
+/**
+ * 
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with this
+ * work for additional information regarding copyright ownership. The ASF
+ * licenses this file to You under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ * 
+ * http://www.apache.org/licenses/LICENSE-2.0
+ * 
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
+ * WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
+ * License for the specific language governing permissions and limitations under
+ * the License.
+ */
+
+package org.apache.activemq.store.kahadaptor;
+
+import java.io.File;
+import java.io.IOException;
+import java.util.HashSet;
+import java.util.Iterator;
+import java.util.Set;
+import org.apache.activemq.broker.ConnectionContext;
+import org.apache.activemq.command.ActiveMQDestination;
+import org.apache.activemq.command.ActiveMQQueue;
+import org.apache.activemq.command.ActiveMQTopic;
+import org.apache.activemq.kaha.IndexTypes;
+import org.apache.activemq.kaha.ListContainer;
+import org.apache.activemq.kaha.MapContainer;
+import org.apache.activemq.kaha.Store;
+import org.apache.activemq.kaha.StoreFactory;
+import org.apache.activemq.kaha.StringMarshaller;
+import org.apache.activemq.memory.UsageManager;
+import org.apache.activemq.openwire.OpenWireFormat;
+import org.apache.activemq.store.MessageStore;
+import org.apache.activemq.store.PersistenceAdapter;
+import org.apache.activemq.store.TopicMessageStore;
+import org.apache.activemq.store.TransactionStore;
+import org.apache.commons.logging.Log;
+import org.apache.commons.logging.LogFactory;
+import edu.emory.mathcs.backport.java.util.concurrent.ConcurrentHashMap;
+
+/**
+ * @org.apache.xbean.XBean
+ * 
+ * @version $Revision: 1.4 $
+ */
+public class KahaPersistenceAdapter implements PersistenceAdapter{
+
+    private static final Log log=LogFactory.getLog(KahaPersistenceAdapter.class);
+    static final String PREPARED_TRANSACTIONS_NAME="PreparedTransactions";
+    KahaTransactionStore transactionStore;
+    ConcurrentHashMap topics=new ConcurrentHashMap();
+    ConcurrentHashMap queues=new ConcurrentHashMap();
+    ConcurrentHashMap messageStores=new ConcurrentHashMap();
+    private boolean useExternalMessageReferences;
+    private OpenWireFormat wireFormat=new OpenWireFormat();
+    private long maxDataFileLength=32*1024*1024;
+    private String indexType=IndexTypes.DISK_INDEX;
+    private File dir;
+    private Store theStore;
+
+    public KahaPersistenceAdapter(File dir) throws IOException{
+        if(!dir.exists()){
+            dir.mkdirs();
+        }
+        this.dir=dir;
+    }
+
+    public Set getDestinations(){
+        Set rc=new HashSet();
+        try{
+            Store store=getStore();
+            for(Iterator i=store.getMapContainerIds().iterator();i.hasNext();){
+                Object obj=i.next();
+                if(obj instanceof ActiveMQDestination){
+                    rc.add(obj);
+                }
+            }
+        }catch(IOException e){
+            log.error("Failed to get destinations ",e);
+        }
+        return rc;
+    }
+
+    public synchronized MessageStore createQueueMessageStore(ActiveMQQueue destination) throws IOException{
+        MessageStore rc=(MessageStore)queues.get(destination);
+        if(rc==null){
+            rc=new KahaMessageStore(getMapContainer(destination,"queue-data"),destination);
+            messageStores.put(destination,rc);
+            if(transactionStore!=null){
+                rc=transactionStore.proxy(rc);
+            }
+            queues.put(destination,rc);
+        }
+        return rc;
+    }
+
+    public synchronized TopicMessageStore createTopicMessageStore(ActiveMQTopic destination) throws IOException{
+        TopicMessageStore rc=(TopicMessageStore)topics.get(destination);
+        if(rc==null){
+            Store store=getStore();
+            ListContainer messageContainer=getListContainer(destination,"topic-data");
+            MapContainer subsContainer=getMapContainer(destination.toString()+"-Subscriptions","topic-subs");
+            ListContainer ackContainer=store.getListContainer(destination.toString(),"topic-acks");
+            ackContainer.setMarshaller(new TopicSubAckMarshaller());
+            rc=new KahaTopicMessageStore(store,messageContainer,ackContainer,subsContainer,destination);
+            messageStores.put(destination,rc);
+            if(transactionStore!=null){
+                rc=transactionStore.proxy(rc);
+            }
+            topics.put(destination,rc);
+        }
+        return rc;
+    }
+
+    protected MessageStore retrieveMessageStore(Object id){
+        MessageStore result=(MessageStore)messageStores.get(id);
+        return result;
+    }
+
+    public TransactionStore createTransactionStore() throws IOException{
+        if(transactionStore==null){
+            Store store=getStore();
+            MapContainer container=store.getMapContainer(PREPARED_TRANSACTIONS_NAME,"transactions");
+            container.setKeyMarshaller(new CommandMarshaller(wireFormat));
+            container.setValueMarshaller(new TransactionMarshaller(wireFormat));
+            container.load();
+            transactionStore=new KahaTransactionStore(this,container);
+        }
+        return transactionStore;
+    }
+
+    public void beginTransaction(ConnectionContext context){
+    }
+
+    public void commitTransaction(ConnectionContext context) throws IOException{
+        if(theStore!=null){
+            theStore.force();
+        }
+    }
+
+    public void rollbackTransaction(ConnectionContext context){
+    }
+
+    public void start() throws Exception{
+    }
+
+    public void stop() throws Exception{
+        if(theStore!=null){
+            theStore.close();
+        }
+    }
+
+    public long getLastMessageBrokerSequenceId() throws IOException{
+        return 0;
+    }
+
+    public void deleteAllMessages() throws IOException{
+        if(theStore!=null){
+            theStore.delete();
+        }
+    }
+
+    public boolean isUseExternalMessageReferences(){
+        return useExternalMessageReferences;
+    }
+
+    public void setUseExternalMessageReferences(boolean useExternalMessageReferences){
+        this.useExternalMessageReferences=useExternalMessageReferences;
+    }
+
+    protected MapContainer getMapContainer(Object id,String containerName) throws IOException{
+        Store store=getStore();
+        MapContainer container=store.getMapContainer(id,containerName);
+        container.setKeyMarshaller(new StringMarshaller());
+        if(useExternalMessageReferences){
+            container.setValueMarshaller(new StringMarshaller());
+        }else{
+            container.setValueMarshaller(new CommandMarshaller(wireFormat));
+        }
+        container.load();
+        return container;
+    }
+    
+    protected ListContainer getListContainer(Object id,String containerName) throws IOException{
+        Store store=getStore();
+        ListContainer container=store.getListContainer(id,containerName);
+        if(useExternalMessageReferences){
+            container.setMarshaller(new StringMarshaller());
+        }else{
+            container.setMarshaller(new CommandMarshaller(wireFormat));
+        }
+        container.load();
+        return container;
+    }
+
+    /**
+     * @param usageManager
+     *            The UsageManager that is controlling the broker's memory
+     *            usage.
+     */
+    public void setUsageManager(UsageManager usageManager){
+    }
+
+    /**
+     * @return the maxDataFileLength
+     */
+    public long getMaxDataFileLength(){
+        return maxDataFileLength;
+    }
+
+    /**
+     * @param maxDataFileLength
+     *            the maxDataFileLength to set
+     * 
+     * @org.apache.xbean.Property propertyEditor="org.apache.activemq.util.MemoryPropertyEditor"
+     */
+    public void setMaxDataFileLength(long maxDataFileLength){
+        this.maxDataFileLength=maxDataFileLength;
+    }
+
+    /**
+     * @return the indexType
+     */
+    public String getIndexType(){
+        return this.indexType;
+    }
+
+    /**
+     * @param indexType the indexTypes to set
+     */
+    public void setIndexType(String indexType){
+        this.indexType=indexType;
+    }
+
+    protected synchronized Store getStore() throws IOException{
+        if(theStore==null){
+            String name=dir.getAbsolutePath()+File.separator+"kaha.db";
+            theStore=StoreFactory.open(name,"rw");
+            theStore.setMaxDataFileLength(maxDataFileLength);
+            theStore.setIndexType(indexType);
+        }
+        return theStore;
+    }
+}

Propchange: incubator/activemq/branches/activemq-4.1/activemq-core/src/main/java/org/apache/activemq/store/kahadaptor/KahaPersistenceAdapter.java
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/branches/activemq-4.1/activemq-core/src/main/java/org/apache/activemq/store/kahadaptor/StoreEntryMarshaller.java
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/branches/activemq-4.1/activemq-core/src/main/java/org/apache/activemq/store/kahadaptor/TopicSubAck.java
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/branches/activemq-4.1/activemq-core/src/main/java/org/apache/activemq/store/kahadaptor/TopicSubAckMarshaller.java
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/branches/activemq-4.1/activemq-core/src/main/java/org/apache/activemq/store/kahadaptor/TopicSubContainer.java
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/branches/activemq-4.1/activemq-core/src/main/java/org/apache/activemq/transport/TransportDisposedIOException.java
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/branches/activemq-4.1/activemq-core/src/main/java/org/apache/activemq/transport/stomp/FrameTranslator.java
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/branches/activemq-4.1/activemq-core/src/main/java/org/apache/activemq/transport/stomp/LegacyFrameTranslator.java
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/branches/activemq-4.1/activemq-core/src/main/java/org/apache/activemq/transport/tcp/SslTransport.java
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/branches/activemq-4.1/activemq-core/src/main/java/org/apache/activemq/transport/tcp/SslTransportServer.java
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/branches/activemq-4.1/activemq-core/src/main/java/org/apache/activemq/util/ByteArrayInputStream.java
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/branches/activemq-4.1/activemq-core/src/main/java/org/apache/activemq/util/ByteArrayOutputStream.java
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/branches/activemq-4.1/activemq-core/src/main/java/org/apache/activemq/util/ByteSequence.java
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/branches/activemq-4.1/activemq-core/src/main/java/org/apache/activemq/util/ByteSequenceData.java
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/branches/activemq-4.1/activemq-core/src/main/java/org/apache/activemq/util/ClassLoadingAwareObjectInputStream.java
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/branches/activemq-4.1/activemq-core/src/main/java/org/apache/activemq/util/DataByteArrayInputStream.java
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/branches/activemq-4.1/activemq-core/src/main/java/org/apache/activemq/util/DataByteArrayOutputStream.java
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/branches/activemq-4.1/activemq-core/src/main/java/org/apache/activemq/util/FactoryFinder.java
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/branches/activemq-4.1/activemq-core/src/main/java/org/apache/activemq/util/MemoryIntPropertyEditor.java
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/branches/activemq-4.1/activemq-core/src/main/java/org/apache/activemq/util/MemoryPropertyEditor.java
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/branches/activemq-4.1/activemq-core/src/main/java/org/apache/activemq/wireformat/ObjectStreamWireFormat.java
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/branches/activemq-4.1/activemq-core/src/main/java/org/apache/activemq/wireformat/WireFormat.java
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/branches/activemq-4.1/activemq-core/src/main/java/org/apache/activemq/wireformat/WireFormatFactory.java
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/branches/activemq-4.1/activemq-core/src/main/java/org/apache/activemq/wireformat/package.html
------------------------------------------------------------------------------
    svn:eol-style = native

Modified: incubator/activemq/branches/activemq-4.1/activemq-core/src/main/resources/META-INF/NOTICE.txt
URL: http://svn.apache.org/viewvc/incubator/activemq/branches/activemq-4.1/activemq-core/src/main/resources/META-INF/NOTICE.txt?view=diff&rev=474986&r1=474985&r2=474986
==============================================================================
--- incubator/activemq/branches/activemq-4.1/activemq-core/src/main/resources/META-INF/NOTICE.txt (original)
+++ incubator/activemq/branches/activemq-4.1/activemq-core/src/main/resources/META-INF/NOTICE.txt Tue Nov 14 13:17:31 2006
@@ -1,12 +1,12 @@
-=========================================================================
-==  NOTICE file corresponding to the section 4 d of                    ==
-==  the Apache License, Version 2.0,                                   ==
-==  in this case for the Apache ActiveMQ distribution.                 ==
-=========================================================================
-
-Apache ActiveMQ
-Copyright 2005-2006 The Apache Software Foundation
-
-This product includes software developed by
-The Apache Software Foundation (http://www.apache.org/).
-
+=========================================================================
+==  NOTICE file corresponding to the section 4 d of                    ==
+==  the Apache License, Version 2.0,                                   ==
+==  in this case for the Apache ActiveMQ distribution.                 ==
+=========================================================================
+
+Apache ActiveMQ
+Copyright 2005-2006 The Apache Software Foundation
+
+This product includes software developed by
+The Apache Software Foundation (http://www.apache.org/).
+

Propchange: incubator/activemq/branches/activemq-4.1/activemq-core/src/main/resources/META-INF/NOTICE.txt
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/branches/activemq-4.1/activemq-core/src/test/eclipse-resources/log4j.properties
------------------------------------------------------------------------------
    svn:eol-style = native



Mime
View raw message