You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by ch...@apache.org on 2011/02/16 15:09:23 UTC
svn commit: r1071259 [4/12] - in /activemq/trunk:
activemq-camel/src/main/java/org/apache/activemq/camel/
activemq-camel/src/main/java/org/apache/activemq/camel/component/
activemq-camel/src/test/java/org/apache/activemq/camel/
activemq-camel/src/test/...
Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/filter/BooleanExpression.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/filter/BooleanExpression.java?rev=1071259&r1=1071258&r2=1071259&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/filter/BooleanExpression.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/filter/BooleanExpression.java Wed Feb 16 14:08:48 2011
@@ -23,7 +23,7 @@ import javax.jms.JMSException;
* A BooleanExpression is an expression that always
* produces a Boolean result.
*
- * @version $Revision: 1.2 $
+ *
*/
public interface BooleanExpression extends Expression {
Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/filter/ComparisonExpression.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/filter/ComparisonExpression.java?rev=1071259&r1=1071258&r2=1071259&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/filter/ComparisonExpression.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/filter/ComparisonExpression.java Wed Feb 16 14:08:48 2011
@@ -26,7 +26,7 @@ import javax.jms.JMSException;
/**
* A filter performing a comparison of two objects
*
- * @version $Revision: 1.2 $
+ *
*/
public abstract class ComparisonExpression extends BinaryExpression implements BooleanExpression {
Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/filter/CompositeDestinationFilter.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/filter/CompositeDestinationFilter.java?rev=1071259&r1=1071258&r2=1071259&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/filter/CompositeDestinationFilter.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/filter/CompositeDestinationFilter.java Wed Feb 16 14:08:48 2011
@@ -21,7 +21,7 @@ import org.apache.activemq.command.Activ
/**
* A {@link DestinationFilter} used for composite destinations
*
- * @version $Revision: 1.3 $
+ *
*/
public class CompositeDestinationFilter extends DestinationFilter {
Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/filter/ConstantExpression.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/filter/ConstantExpression.java?rev=1071259&r1=1071258&r2=1071259&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/filter/ConstantExpression.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/filter/ConstantExpression.java Wed Feb 16 14:08:48 2011
@@ -23,7 +23,7 @@ import javax.jms.JMSException;
/**
* Represents a constant expression
*
- * @version $Revision: 1.2 $
+ *
*/
public class ConstantExpression implements Expression {
Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/filter/DestinationFilter.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/filter/DestinationFilter.java?rev=1071259&r1=1071258&r2=1071259&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/filter/DestinationFilter.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/filter/DestinationFilter.java Wed Feb 16 14:08:48 2011
@@ -27,7 +27,7 @@ import org.apache.activemq.util.JMSExcep
/**
* Represents a filter which only operates on Destinations
*
- * @version $Revision: 1.3 $
+ *
*/
public abstract class DestinationFilter implements BooleanExpression {
Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/filter/DestinationMap.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/filter/DestinationMap.java?rev=1071259&r1=1071258&r2=1071259&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/filter/DestinationMap.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/filter/DestinationMap.java Wed Feb 16 14:08:48 2011
@@ -36,7 +36,7 @@ import org.apache.activemq.command.Activ
* Looking up of a value could return a single value or a List of matching
* values if a wildcard or composite destination is used.
*
- * @version $Revision: 1.3 $
+ *
*/
public class DestinationMap {
protected static final String ANY_DESCENDENT = DestinationFilter.ANY_DESCENDENT;
Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/filter/DestinationMapEntry.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/filter/DestinationMapEntry.java?rev=1071259&r1=1071258&r2=1071259&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/filter/DestinationMapEntry.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/filter/DestinationMapEntry.java Wed Feb 16 14:08:48 2011
@@ -24,7 +24,7 @@ import org.apache.activemq.command.*;
* A base class for entry objects used to construct a destination based policy
* map.
*
- * @version $Revision: 1.1 $
+ *
* @org.apache.xbean.XBean
*/
public abstract class DestinationMapEntry implements Comparable {
Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/filter/DestinationMapNode.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/filter/DestinationMapNode.java?rev=1071259&r1=1071258&r2=1071259&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/filter/DestinationMapNode.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/filter/DestinationMapNode.java Wed Feb 16 14:08:48 2011
@@ -28,7 +28,7 @@ import java.util.Set;
/**
* An implementation class used to implement {@link DestinationMap}
*
- * @version $Revision: 1.2 $
+ *
*/
public class DestinationMapNode implements DestinationNode {
protected static final String ANY_CHILD = DestinationMap.ANY_CHILD;
Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/filter/DestinationPath.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/filter/DestinationPath.java?rev=1071259&r1=1071258&r2=1071259&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/filter/DestinationPath.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/filter/DestinationPath.java Wed Feb 16 14:08:48 2011
@@ -28,7 +28,7 @@ import org.apache.activemq.command.Messa
/**
* Helper class for decomposing a Destination into a number of paths
*
- * @version $Revision: 1.3 $
+ *
*/
public final class DestinationPath {
protected static final char SEPARATOR = '.';
Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/filter/Expression.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/filter/Expression.java?rev=1071259&r1=1071258&r2=1071259&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/filter/Expression.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/filter/Expression.java Wed Feb 16 14:08:48 2011
@@ -23,7 +23,7 @@ import javax.jms.JMSException;
/**
* Represents an expression
*
- * @version $Revision: 1.2 $
+ *
*/
public interface Expression {
Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/filter/LogicExpression.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/filter/LogicExpression.java?rev=1071259&r1=1071258&r2=1071259&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/filter/LogicExpression.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/filter/LogicExpression.java Wed Feb 16 14:08:48 2011
@@ -21,7 +21,7 @@ import javax.jms.JMSException;
/**
* A filter performing a comparison of two objects
*
- * @version $Revision: 1.2 $
+ *
*/
public abstract class LogicExpression extends BinaryExpression implements BooleanExpression {
Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/filter/MessageEvaluationContext.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/filter/MessageEvaluationContext.java?rev=1071259&r1=1071258&r2=1071259&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/filter/MessageEvaluationContext.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/filter/MessageEvaluationContext.java Wed Feb 16 14:08:48 2011
@@ -29,7 +29,7 @@ import org.apache.activemq.command.Messa
* evaluation results associated with the message in the
* MessageEvaluationContext.
*
- * @version $Revision: 1.4 $
+ *
*/
public class MessageEvaluationContext {
Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/filter/MultiExpressionEvaluator.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/filter/MultiExpressionEvaluator.java?rev=1071259&r1=1071258&r2=1071259&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/filter/MultiExpressionEvaluator.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/filter/MultiExpressionEvaluator.java Wed Feb 16 14:08:48 2011
@@ -64,7 +64,7 @@ import javax.jms.JMSException;
* counter. When a CacheExpressionnotices it's last cached value was generated
* in an old 'view', it invalidates its cached value.
*
- * @version $Revision: 1.2 $ $Date: 2005/08/27 03:52:36 $
+ * $Date: 2005/08/27 03:52:36 $
*/
public class MultiExpressionEvaluator {
Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/filter/NonCachedMessageEvaluationContext.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/filter/NonCachedMessageEvaluationContext.java?rev=1071259&r1=1071258&r2=1071259&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/filter/NonCachedMessageEvaluationContext.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/filter/NonCachedMessageEvaluationContext.java Wed Feb 16 14:08:48 2011
@@ -23,7 +23,7 @@ import org.apache.activemq.command.Messa
/**
* NonCached version of the MessageEvaluationContext
*
- * @version $Revision: 1.4 $
+ *
*/
public class NonCachedMessageEvaluationContext extends MessageEvaluationContext {
Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/filter/PrefixDestinationFilter.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/filter/PrefixDestinationFilter.java?rev=1071259&r1=1071258&r2=1071259&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/filter/PrefixDestinationFilter.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/filter/PrefixDestinationFilter.java Wed Feb 16 14:08:48 2011
@@ -23,7 +23,7 @@ import org.apache.activemq.command.Activ
/**
* Matches messages which match a prefix like "A.B.>"
*
- * @version $Revision: 1.2 $
+ *
*/
public class PrefixDestinationFilter extends DestinationFilter {
Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/filter/PropertyExpression.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/filter/PropertyExpression.java?rev=1071259&r1=1071258&r2=1071259&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/filter/PropertyExpression.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/filter/PropertyExpression.java Wed Feb 16 14:08:48 2011
@@ -32,7 +32,7 @@ import org.apache.activemq.util.JMSExcep
/**
* Represents a property expression
*
- * @version $Revision: 1.5 $
+ *
*/
public class PropertyExpression implements Expression {
Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/filter/SimpleDestinationFilter.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/filter/SimpleDestinationFilter.java?rev=1071259&r1=1071258&r2=1071259&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/filter/SimpleDestinationFilter.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/filter/SimpleDestinationFilter.java Wed Feb 16 14:08:48 2011
@@ -23,7 +23,7 @@ import org.apache.activemq.command.Activ
/**
* Matches messages sent to an exact destination
*
- * @version $Revision: 1.3 $
+ *
*/
public class SimpleDestinationFilter extends DestinationFilter {
Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/filter/UnaryExpression.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/filter/UnaryExpression.java?rev=1071259&r1=1071258&r2=1071259&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/filter/UnaryExpression.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/filter/UnaryExpression.java Wed Feb 16 14:08:48 2011
@@ -27,7 +27,7 @@ import javax.jms.JMSException;
/**
* An expression which performs an operation on two expression values
*
- * @version $Revision: 1.3 $
+ *
*/
public abstract class UnaryExpression implements Expression {
Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/filter/WildcardDestinationFilter.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/filter/WildcardDestinationFilter.java?rev=1071259&r1=1071258&r2=1071259&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/filter/WildcardDestinationFilter.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/filter/WildcardDestinationFilter.java Wed Feb 16 14:08:48 2011
@@ -23,7 +23,7 @@ import org.apache.activemq.command.Activ
/**
* Matches messages which contain wildcards like "A.B.*.*"
*
- * @version $Revision: 1.2 $
+ *
*/
public class WildcardDestinationFilter extends DestinationFilter {
Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/jndi/ActiveMQInitialContextFactory.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/jndi/ActiveMQInitialContextFactory.java?rev=1071259&r1=1071258&r2=1071259&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/jndi/ActiveMQInitialContextFactory.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/jndi/ActiveMQInitialContextFactory.java Wed Feb 16 14:08:48 2011
@@ -44,7 +44,7 @@ import org.apache.activemq.command.Activ
* child context depending on the QoS such as transient or durable and queue or
* topic.
*
- * @version $Revision: 1.2 $
+ *
*/
public class ActiveMQInitialContextFactory implements InitialContextFactory {
Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/jndi/LazyCreateContext.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/jndi/LazyCreateContext.java?rev=1071259&r1=1071258&r2=1071259&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/jndi/LazyCreateContext.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/jndi/LazyCreateContext.java Wed Feb 16 14:08:48 2011
@@ -22,7 +22,7 @@ import javax.naming.NamingException;
/**
* Allows users to dynamically create items
*
- * @version $Revision: 1.2 $
+ *
*/
public abstract class LazyCreateContext extends ReadOnlyContext {
public Object lookup(String name) throws NamingException {
Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/jndi/NameParserImpl.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/jndi/NameParserImpl.java?rev=1071259&r1=1071258&r2=1071259&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/jndi/NameParserImpl.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/jndi/NameParserImpl.java Wed Feb 16 14:08:48 2011
@@ -25,7 +25,7 @@ import javax.naming.NamingException;
/**
* A default implementation of {@link NameParser}
*
- * @version $Revision: 1.2 $
+ *
*/
public class NameParserImpl implements NameParser {
public Name parse(String name) throws NamingException {
Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/jndi/ReadOnlyContext.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/jndi/ReadOnlyContext.java?rev=1071259&r1=1071258&r2=1071259&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/jndi/ReadOnlyContext.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/jndi/ReadOnlyContext.java Wed Feb 16 14:08:48 2011
@@ -58,7 +58,7 @@ import org.slf4j.LoggerFactory;
* String envEntry2 = (String) componentContext.lookup("env/myEntry2");
* </code>
*
- * @version $Revision: 1.2 $ $Date: 2005/08/27 03:52:39 $
+ * $Date: 2005/08/27 03:52:39 $
*/
@SuppressWarnings("unchecked")
public class ReadOnlyContext implements Context, Serializable {
Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/BytesMarshaller.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/BytesMarshaller.java?rev=1071259&r1=1071258&r2=1071259&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/BytesMarshaller.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/BytesMarshaller.java Wed Feb 16 14:08:48 2011
@@ -23,7 +23,7 @@ import java.io.IOException;
/**
* Implementation of a Marshaller for byte arrays
*
- * @version $Revision: 1.2 $
+ *
*/
public class BytesMarshaller implements Marshaller {
/**
Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/CommandMarshaller.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/CommandMarshaller.java?rev=1071259&r1=1071258&r2=1071259&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/CommandMarshaller.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/CommandMarshaller.java Wed Feb 16 14:08:48 2011
@@ -27,7 +27,7 @@ import org.apache.activemq.wireformat.Wi
/**
* Marshall a Message or a MessageReference
*
- * @version $Revision: 1.10 $
+ *
*/
public class CommandMarshaller implements Marshaller<Object> {
Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/ContainerId.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/ContainerId.java?rev=1071259&r1=1071258&r2=1071259&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/ContainerId.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/ContainerId.java Wed Feb 16 14:08:48 2011
@@ -26,7 +26,7 @@ import org.apache.activemq.util.IOHelper
/**
* Used by RootContainers
*
- * @version $Revision: 1.1.1.1 $
+ *
*/
public class ContainerId implements Externalizable {
private static final long serialVersionUID = -8883779541021821943L;
Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/ListContainer.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/ListContainer.java?rev=1071259&r1=1071258&r2=1071259&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/ListContainer.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/ListContainer.java Wed Feb 16 14:08:48 2011
@@ -23,7 +23,7 @@ import java.util.NoSuchElementException;
* Represents a container of persistent objects in the store Acts as a map, but
* values can be retrieved in insertion order
*
- * @version $Revision: 1.2 $
+ *
*/
public interface ListContainer<V> extends List<V> {
Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/MapContainer.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/MapContainer.java?rev=1071259&r1=1071258&r2=1071259&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/MapContainer.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/MapContainer.java Wed Feb 16 14:08:48 2011
@@ -24,7 +24,7 @@ import java.util.Set;
* Represents a container of persistent objects in the store Acts as a map, but
* values can be retrieved in insertion order
*
- * @version $Revision: 1.2 $
+ *
*/
public interface MapContainer<K, V> extends Map<K, V> {
Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/Marshaller.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/Marshaller.java?rev=1071259&r1=1071258&r2=1071259&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/Marshaller.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/Marshaller.java Wed Feb 16 14:08:48 2011
@@ -23,7 +23,7 @@ import java.io.IOException;
/**
*Marshaller for marshalling in/out objects to a RawContainer
*
- * @version $Revision: 1.2 $
+ *
*/
public interface Marshaller<T> {
Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/MessageIdMarshaller.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/MessageIdMarshaller.java?rev=1071259&r1=1071258&r2=1071259&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/MessageIdMarshaller.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/MessageIdMarshaller.java Wed Feb 16 14:08:48 2011
@@ -24,7 +24,7 @@ import org.apache.activemq.command.Messa
/**
* Implementation of a Marshaller for MessageIds
*
- * @version $Revision: 1.2 $
+ *
*/
public class MessageIdMarshaller implements Marshaller<MessageId> {
/**
Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/MessageMarshaller.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/MessageMarshaller.java?rev=1071259&r1=1071258&r2=1071259&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/MessageMarshaller.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/MessageMarshaller.java Wed Feb 16 14:08:48 2011
@@ -26,7 +26,7 @@ import org.apache.activemq.wireformat.Wi
/**
* Implementation of a Marshaller for MessageIds
*
- * @version $Revision: 1.2 $
+ *
*/
public class MessageMarshaller implements Marshaller<Message> {
Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/ObjectMarshaller.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/ObjectMarshaller.java?rev=1071259&r1=1071258&r2=1071259&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/ObjectMarshaller.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/ObjectMarshaller.java Wed Feb 16 14:08:48 2011
@@ -27,7 +27,7 @@ import java.io.ObjectOutputStream;
/**
* Implementation of a Marshaller for Objects
*
- * @version $Revision: 1.2 $
+ *
*/
public class ObjectMarshaller implements Marshaller {
Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/RuntimeStoreException.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/RuntimeStoreException.java?rev=1071259&r1=1071258&r2=1071259&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/RuntimeStoreException.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/RuntimeStoreException.java Wed Feb 16 14:08:48 2011
@@ -19,7 +19,7 @@ package org.apache.activemq.kaha;
/**
* Runtime exception for the Store
*
- * @version $Revision: 1.2 $
+ *
*/
public class RuntimeStoreException extends RuntimeException {
Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/Store.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/Store.java?rev=1071259&r1=1071258&r2=1071259&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/Store.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/Store.java Wed Feb 16 14:08:48 2011
@@ -22,7 +22,7 @@ import java.util.Set;
/**
* A Store is holds persistent containers
*
- * @version $Revision: 1.2 $
+ *
*/
public interface Store {
/**
Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/StoreEntry.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/StoreEntry.java?rev=1071259&r1=1071258&r2=1071259&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/StoreEntry.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/StoreEntry.java Wed Feb 16 14:08:48 2011
@@ -19,7 +19,7 @@ package org.apache.activemq.kaha;
/**
* Entry for Store data
*
- * @version $Revision: 1.2 $
+ *
*/
public interface StoreEntry {
Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/StoreFactory.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/StoreFactory.java?rev=1071259&r1=1071258&r2=1071259&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/StoreFactory.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/StoreFactory.java Wed Feb 16 14:08:48 2011
@@ -25,7 +25,7 @@ import org.apache.activemq.kaha.impl.Kah
/**
* Factory for creating stores
*
- * @version $Revision: 1.2 $
+ *
*/
public final class StoreFactory {
Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/StoreLocation.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/StoreLocation.java?rev=1071259&r1=1071258&r2=1071259&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/StoreLocation.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/StoreLocation.java Wed Feb 16 14:08:48 2011
@@ -19,7 +19,7 @@ package org.apache.activemq.kaha;
/**
* Location of a data in the Store
*
- * @version $Revision: 1.2 $
+ *
*/
public interface StoreLocation {
Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/StringMarshaller.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/StringMarshaller.java?rev=1071259&r1=1071258&r2=1071259&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/StringMarshaller.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/StringMarshaller.java Wed Feb 16 14:08:48 2011
@@ -23,7 +23,7 @@ import java.io.IOException;
/**
* Implementation of a Marshaller for Strings
*
- * @version $Revision: 1.2 $
+ *
*/
public class StringMarshaller implements Marshaller<String> {
/**
Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/IndexRootContainer.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/IndexRootContainer.java?rev=1071259&r1=1071258&r2=1071259&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/IndexRootContainer.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/IndexRootContainer.java Wed Feb 16 14:08:48 2011
@@ -36,7 +36,7 @@ import org.slf4j.LoggerFactory;
/**
* A container of roots for other Containers
*
- * @version $Revision: 1.2 $
+ *
*/
class IndexRootContainer {
Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/KahaStore.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/KahaStore.java?rev=1071259&r1=1071258&r2=1071259&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/KahaStore.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/KahaStore.java Wed Feb 16 14:08:48 2011
@@ -50,7 +50,7 @@ import org.slf4j.LoggerFactory;
/**
* Store Implementation
*
- * @version $Revision: 1.1.1.1 $
+ *
*/
public class KahaStore implements Store {
Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/StoreLockedExcpetion.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/StoreLockedExcpetion.java?rev=1071259&r1=1071258&r2=1071259&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/StoreLockedExcpetion.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/StoreLockedExcpetion.java Wed Feb 16 14:08:48 2011
@@ -21,7 +21,7 @@ import java.io.IOException;
/**
* Exception thrown if the store is in use by another application
*
- * @version $Revision: 1.1.1.1 $
+ *
*/
public class StoreLockedExcpetion extends IOException {
Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/async/AsyncDataManager.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/async/AsyncDataManager.java?rev=1071259&r1=1071258&r2=1071259&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/async/AsyncDataManager.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/async/AsyncDataManager.java Wed Feb 16 14:08:48 2011
@@ -48,7 +48,7 @@ import org.slf4j.LoggerFactory;
/**
* Manages DataFiles
*
- * @version $Revision: 1.1.1.1 $
+ *
*/
public class AsyncDataManager {
Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/async/ControlFile.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/async/ControlFile.java?rev=1071259&r1=1071258&r2=1071259&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/async/ControlFile.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/async/ControlFile.java Wed Feb 16 14:08:48 2011
@@ -31,7 +31,7 @@ import org.apache.activemq.util.IOExcept
* middle of the write of the first or second record do not not result in an
* unknown state.
*
- * @version $Revision: 1.1 $
+ *
*/
public final class ControlFile {
Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/async/DataFile.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/async/DataFile.java?rev=1071259&r1=1071258&r2=1071259&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/async/DataFile.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/async/DataFile.java Wed Feb 16 14:08:48 2011
@@ -26,7 +26,7 @@ import org.apache.activemq.util.LinkedNo
/**
* DataFile
*
- * @version $Revision: 1.1.1.1 $
+ *
*/
public class DataFile extends LinkedNode implements Comparable<DataFile> {
Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/async/DataFileAccessor.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/async/DataFileAccessor.java?rev=1071259&r1=1071258&r2=1071259&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/async/DataFileAccessor.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/async/DataFileAccessor.java Wed Feb 16 14:08:48 2011
@@ -28,7 +28,7 @@ import org.apache.activemq.util.ByteSequ
* Optimized Store reader and updater. Single threaded and synchronous. Use in
* conjunction with the DataFileAccessorPool of concurrent use.
*
- * @version $Revision: 1.1.1.1 $
+ *
*/
final class DataFileAccessor {
Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/async/DataFileAppender.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/async/DataFileAppender.java?rev=1071259&r1=1071258&r2=1071259&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/async/DataFileAppender.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/async/DataFileAppender.java Wed Feb 16 14:08:48 2011
@@ -32,7 +32,7 @@ import org.apache.activemq.util.LinkedNo
* safe and gains throughput as you increase the number of concurrent writes it
* does.
*
- * @version $Revision: 1.1.1.1 $
+ *
*/
class DataFileAppender {
Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/async/DataManagerFacade.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/async/DataManagerFacade.java?rev=1071259&r1=1071258&r2=1071259&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/async/DataManagerFacade.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/async/DataManagerFacade.java Wed Feb 16 14:08:48 2011
@@ -28,7 +28,7 @@ import org.apache.activemq.util.DataByte
/**
* Provides a Kaha DataManager Facade to the DataManager.
*
- * @version $Revision: 1.1.1.1 $
+ *
*/
public final class DataManagerFacade implements org.apache.activemq.kaha.impl.DataManager {
Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/async/JournalFacade.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/async/JournalFacade.java?rev=1071259&r1=1071258&r2=1071259&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/async/JournalFacade.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/async/JournalFacade.java Wed Feb 16 14:08:48 2011
@@ -29,7 +29,7 @@ import org.apache.activemq.util.ByteSequ
/**
* Provides a Journal Facade to the DataManager.
*
- * @version $Revision: 1.1.1.1 $
+ *
*/
public final class JournalFacade implements Journal {
Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/async/Location.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/async/Location.java?rev=1071259&r1=1071258&r2=1071259&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/async/Location.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/async/Location.java Wed Feb 16 14:08:48 2011
@@ -24,7 +24,7 @@ import java.util.concurrent.CountDownLat
/**
* Used as a location in the data store.
*
- * @version $Revision: 1.2 $
+ *
*/
public final class Location implements Comparable<Location> {
Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/async/NIODataFileAppender.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/async/NIODataFileAppender.java?rev=1071259&r1=1071258&r2=1071259&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/async/NIODataFileAppender.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/async/NIODataFileAppender.java Wed Feb 16 14:08:48 2011
@@ -25,7 +25,7 @@ import java.nio.channels.FileChannel;
* An AsyncDataFileAppender that uses NIO ByteBuffers and File chanels to more
* efficently copy data to files.
*
- * @version $Revision: 1.1.1.1 $
+ *
*/
class NIODataFileAppender extends DataFileAppender {
Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/container/BaseContainerImpl.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/container/BaseContainerImpl.java?rev=1071259&r1=1071258&r2=1071259&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/container/BaseContainerImpl.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/container/BaseContainerImpl.java Wed Feb 16 14:08:48 2011
@@ -36,7 +36,7 @@ import org.slf4j.LoggerFactory;
/**
* Implementation of a ListContainer
*
- * @version $Revision: 1.2 $
+ *
*/
public abstract class BaseContainerImpl {
Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/container/ContainerCollectionSupport.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/container/ContainerCollectionSupport.java?rev=1071259&r1=1071258&r2=1071259&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/container/ContainerCollectionSupport.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/container/ContainerCollectionSupport.java Wed Feb 16 14:08:48 2011
@@ -19,7 +19,7 @@ package org.apache.activemq.kaha.impl.co
/**
* Base class for container collections
*
- * @version $Revision: 1.2 $
+ *
*/
class ContainerCollectionSupport {
Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/container/ContainerEntrySet.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/container/ContainerEntrySet.java?rev=1071259&r1=1071258&r2=1071259&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/container/ContainerEntrySet.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/container/ContainerEntrySet.java Wed Feb 16 14:08:48 2011
@@ -26,7 +26,7 @@ import java.util.Set;
/**
* Set of Map.Entry objects for a container
*
- * @version $Revision: 1.2 $
+ *
*/
public class ContainerEntrySet extends ContainerCollectionSupport implements Set {
ContainerEntrySet(MapContainerImpl container) {
Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/container/ContainerEntrySetIterator.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/container/ContainerEntrySetIterator.java?rev=1071259&r1=1071258&r2=1071259&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/container/ContainerEntrySetIterator.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/container/ContainerEntrySetIterator.java Wed Feb 16 14:08:48 2011
@@ -21,7 +21,7 @@ import java.util.Iterator;
/**
* An Iterator for a container entry Set
*
- * @version $Revision: 1.2 $
+ *
*/
public class ContainerEntrySetIterator implements Iterator {
private MapContainerImpl container;
Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/container/ContainerKeySet.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/container/ContainerKeySet.java?rev=1071259&r1=1071258&r2=1071259&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/container/ContainerKeySet.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/container/ContainerKeySet.java Wed Feb 16 14:08:48 2011
@@ -27,7 +27,7 @@ import org.apache.activemq.kaha.impl.ind
/**
* A Set of keys for the container
*
- * @version $Revision: 1.2 $
+ *
*/
public class ContainerKeySet extends ContainerCollectionSupport implements Set {
Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/container/ContainerKeySetIterator.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/container/ContainerKeySetIterator.java?rev=1071259&r1=1071258&r2=1071259&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/container/ContainerKeySetIterator.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/container/ContainerKeySetIterator.java Wed Feb 16 14:08:48 2011
@@ -23,7 +23,7 @@ import org.apache.activemq.kaha.impl.ind
/**
* Iterator for the set of keys for a container
*
- * @version $Revision: 1.2 $
+ *
*/
public class ContainerKeySetIterator implements Iterator {
Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/container/ContainerListIterator.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/container/ContainerListIterator.java?rev=1071259&r1=1071258&r2=1071259&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/container/ContainerListIterator.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/container/ContainerListIterator.java Wed Feb 16 14:08:48 2011
@@ -22,7 +22,7 @@ import org.apache.activemq.kaha.impl.ind
import org.apache.activemq.kaha.impl.index.IndexLinkedList;
/**
- * @version $Revision: 1.2 $
+ *
*/
public class ContainerListIterator extends ContainerValueCollectionIterator implements ListIterator {
Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/container/ContainerMapEntry.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/container/ContainerMapEntry.java?rev=1071259&r1=1071258&r2=1071259&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/container/ContainerMapEntry.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/container/ContainerMapEntry.java Wed Feb 16 14:08:48 2011
@@ -22,7 +22,7 @@ import org.apache.activemq.kaha.MapConta
/**
* Map.Entry implementation for a container
*
- * @version $Revision: 1.2 $
+ *
*/
class ContainerMapEntry implements Map.Entry {
Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/container/ContainerValueCollection.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/container/ContainerValueCollection.java?rev=1071259&r1=1071258&r2=1071259&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/container/ContainerValueCollection.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/container/ContainerValueCollection.java Wed Feb 16 14:08:48 2011
@@ -27,7 +27,7 @@ import org.apache.activemq.kaha.impl.ind
/**
* Values collection for the MapContainer
*
- * @version $Revision: 1.2 $
+ *
*/
class ContainerValueCollection extends ContainerCollectionSupport implements Collection {
Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/container/ContainerValueCollectionIterator.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/container/ContainerValueCollectionIterator.java?rev=1071259&r1=1071258&r2=1071259&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/container/ContainerValueCollectionIterator.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/container/ContainerValueCollectionIterator.java Wed Feb 16 14:08:48 2011
@@ -23,7 +23,7 @@ import org.apache.activemq.kaha.impl.ind
/**
* Values collection iterator for the MapContainer
*
- * @version $Revision: 1.2 $
+ *
*/
public class ContainerValueCollectionIterator implements Iterator {
Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/container/ListContainerImpl.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/container/ListContainerImpl.java?rev=1071259&r1=1071258&r2=1071259&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/container/ListContainerImpl.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/container/ListContainerImpl.java Wed Feb 16 14:08:48 2011
@@ -40,7 +40,7 @@ import org.slf4j.LoggerFactory;
/**
* Implementation of a ListContainer
*
- * @version $Revision: 1.2 $
+ *
*/
public class ListContainerImpl extends BaseContainerImpl implements ListContainer {
Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/container/MapContainerImpl.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/container/MapContainerImpl.java?rev=1071259&r1=1071258&r2=1071259&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/container/MapContainerImpl.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/container/MapContainerImpl.java Wed Feb 16 14:08:48 2011
@@ -46,7 +46,7 @@ import org.slf4j.LoggerFactory;
/**
* Implementation of a MapContainer
*
- * @version $Revision: 1.2 $
+ *
*/
public final class MapContainerImpl extends BaseContainerImpl implements MapContainer {
Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/data/DataFile.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/data/DataFile.java?rev=1071259&r1=1071258&r2=1071259&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/data/DataFile.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/data/DataFile.java Wed Feb 16 14:08:48 2011
@@ -24,7 +24,7 @@ import java.io.RandomAccessFile;
/**
* DataFile
*
- * @version $Revision: 1.1.1.1 $
+ *
*/
class DataFile {
Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/data/DataItem.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/data/DataItem.java?rev=1071259&r1=1071258&r2=1071259&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/data/DataItem.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/data/DataItem.java Wed Feb 16 14:08:48 2011
@@ -21,7 +21,7 @@ import org.apache.activemq.kaha.StoreLoc
/**
* A a wrapper for a data in the store
*
- * @version $Revision: 1.2 $
+ *
*/
public final class DataItem implements Item, StoreLocation {
Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/data/DataManagerImpl.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/data/DataManagerImpl.java?rev=1071259&r1=1071258&r2=1071259&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/data/DataManagerImpl.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/data/DataManagerImpl.java Wed Feb 16 14:08:48 2011
@@ -38,7 +38,7 @@ import org.slf4j.LoggerFactory;
/**
* Manages DataFiles
*
- * @version $Revision: 1.1.1.1 $
+ *
*/
public final class DataManagerImpl implements DataManager {
Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/data/Item.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/data/Item.java?rev=1071259&r1=1071258&r2=1071259&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/data/Item.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/data/Item.java Wed Feb 16 14:08:48 2011
@@ -19,7 +19,7 @@ package org.apache.activemq.kaha.impl.da
/**
* A a wrapper for a data in the store
*
- * @version $Revision: 1.2 $
+ *
*/
public interface Item {
long POSITION_NOT_SET = -1;
Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/data/SyncDataFileReader.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/data/SyncDataFileReader.java?rev=1071259&r1=1071258&r2=1071259&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/data/SyncDataFileReader.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/data/SyncDataFileReader.java Wed Feb 16 14:08:48 2011
@@ -25,7 +25,7 @@ import org.apache.activemq.util.DataByte
/**
* Optimized Store reader
*
- * @version $Revision: 1.1.1.1 $
+ *
*/
public final class SyncDataFileReader {
Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/data/SyncDataFileWriter.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/data/SyncDataFileWriter.java?rev=1071259&r1=1071258&r2=1071259&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/data/SyncDataFileWriter.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/data/SyncDataFileWriter.java Wed Feb 16 14:08:48 2011
@@ -26,7 +26,7 @@ import org.apache.activemq.util.DataByte
* Optimized Store writer. Synchronously marshalls and writes to the data file.
* Simple but may introduce a bit of contention when put under load.
*
- * @version $Revision: 1.1.1.1 $
+ *
*/
public final class SyncDataFileWriter {
Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/index/BadMagicException.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/index/BadMagicException.java?rev=1071259&r1=1071258&r2=1071259&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/index/BadMagicException.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/index/BadMagicException.java Wed Feb 16 14:08:48 2011
@@ -21,7 +21,7 @@ import java.io.IOException;
/**
* Occurs when bad magic occurs in reading a file
*
- * @version $Revision: 1.2 $
+ *
*/
public class BadMagicException extends IOException {
/**
Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/index/Index.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/index/Index.java?rev=1071259&r1=1071258&r2=1071259&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/index/Index.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/index/Index.java Wed Feb 16 14:08:48 2011
@@ -23,7 +23,7 @@ import org.apache.activemq.kaha.StoreEnt
/**
* Simplier than a Map
*
- * @version $Revision: 1.2 $
+ *
*/
public interface Index {
Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/index/IndexItem.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/index/IndexItem.java?rev=1071259&r1=1071258&r2=1071259&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/index/IndexItem.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/index/IndexItem.java Wed Feb 16 14:08:48 2011
@@ -28,7 +28,7 @@ import org.apache.activemq.kaha.impl.dat
/**
* A an Item with a relative position and location to other Items in the Store
*
- * @version $Revision: 1.2 $
+ *
*/
public class IndexItem implements Item, StoreEntry {
Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/index/IndexManager.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/index/IndexManager.java?rev=1071259&r1=1071258&r2=1071259&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/index/IndexManager.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/index/IndexManager.java Wed Feb 16 14:08:48 2011
@@ -30,7 +30,7 @@ import org.slf4j.LoggerFactory;
/**
* Optimized Store reader
*
- * @version $Revision: 1.1.1.1 $
+ *
*/
public final class IndexManager {
Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/index/StoreIndexReader.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/index/StoreIndexReader.java?rev=1071259&r1=1071258&r2=1071259&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/index/StoreIndexReader.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/index/StoreIndexReader.java Wed Feb 16 14:08:48 2011
@@ -24,7 +24,7 @@ import org.apache.activemq.util.DataByte
/**
* Optimized Store reader
*
- * @version $Revision: 1.1.1.1 $
+ *
*/
class StoreIndexReader {
protected RandomAccessFile file;
Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/index/StoreIndexWriter.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/index/StoreIndexWriter.java?rev=1071259&r1=1071258&r2=1071259&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/index/StoreIndexWriter.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/index/StoreIndexWriter.java Wed Feb 16 14:08:48 2011
@@ -25,7 +25,7 @@ import org.apache.activemq.util.DataByte
/**
* Optimized Store writer
*
- * @version $Revision: 1.1.1.1 $
+ *
*/
class StoreIndexWriter {
Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/index/VMIndex.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/index/VMIndex.java?rev=1071259&r1=1071258&r2=1071259&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/index/VMIndex.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/index/VMIndex.java Wed Feb 16 14:08:48 2011
@@ -29,7 +29,7 @@ import org.slf4j.LoggerFactory;
/**
* Index implementation using a HashMap
*
- * @version $Revision: 1.2 $
+ *
*/
public class VMIndex implements Index, IndexMBean {
private static final Logger LOG = LoggerFactory.getLogger(VMIndex.class);
Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/index/VMIndexLinkedList.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/index/VMIndexLinkedList.java?rev=1071259&r1=1071258&r2=1071259&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/index/VMIndexLinkedList.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/index/VMIndexLinkedList.java Wed Feb 16 14:08:48 2011
@@ -21,7 +21,7 @@ import org.apache.activemq.kaha.StoreEnt
/**
* A linked list used by IndexItems
*
- * @version $Revision: 1.2 $
+ *
*/
public final class VMIndexLinkedList implements Cloneable, IndexLinkedList {
private transient IndexItem root;
Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/index/hash/HashBin.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/index/hash/HashBin.java?rev=1071259&r1=1071258&r2=1071259&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/index/hash/HashBin.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/index/hash/HashBin.java Wed Feb 16 14:08:48 2011
@@ -21,7 +21,7 @@ import java.io.IOException;
/**
* Bin in a HashIndex
*
- * @version $Revision: 1.1.1.1 $
+ *
*/
class HashBin {
private HashIndex hashIndex;
Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/index/hash/HashEntry.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/index/hash/HashEntry.java?rev=1071259&r1=1071258&r2=1071259&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/index/hash/HashEntry.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/index/hash/HashEntry.java Wed Feb 16 14:08:48 2011
@@ -24,7 +24,7 @@ import org.apache.activemq.kaha.Marshall
/**
* Key and index for DiskBased Hash Index
*
- * @version $Revision: 1.1.1.1 $
+ *
*/
class HashEntry implements Comparable {
Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/index/hash/HashIndex.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/index/hash/HashIndex.java?rev=1071259&r1=1071258&r2=1071259&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/index/hash/HashIndex.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/index/hash/HashIndex.java Wed Feb 16 14:08:48 2011
@@ -36,7 +36,7 @@ import org.slf4j.LoggerFactory;
/**
* BTree implementation
*
- * @version $Revision: 1.1.1.1 $
+ *
*/
public class HashIndex implements Index, HashIndexMBean {
public static final int DEFAULT_PAGE_SIZE;
Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/index/hash/HashPage.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/index/hash/HashPage.java?rev=1071259&r1=1071258&r2=1071259&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/index/hash/HashPage.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/index/hash/HashPage.java Wed Feb 16 14:08:48 2011
@@ -29,7 +29,7 @@ import org.slf4j.LoggerFactory;
/**
* A Page within a HashPage
*
- * @version $Revision: 1.1.1.1 $
+ *
*/
class HashPage {
static final int PAGE_HEADER_SIZE = 17;
Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/index/hash/HashPageInfo.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/index/hash/HashPageInfo.java?rev=1071259&r1=1071258&r2=1071259&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/index/hash/HashPageInfo.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/index/hash/HashPageInfo.java Wed Feb 16 14:08:48 2011
@@ -22,7 +22,7 @@ import org.apache.activemq.util.LinkedNo
/**
* A Page within a HashPageInfo
*
- * @version $Revision: 1.1.1.1 $
+ *
*/
class HashPageInfo extends LinkedNode{
Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/index/tree/TreeEntry.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/index/tree/TreeEntry.java?rev=1071259&r1=1071258&r2=1071259&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/index/tree/TreeEntry.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/index/tree/TreeEntry.java Wed Feb 16 14:08:48 2011
@@ -24,7 +24,7 @@ import org.apache.activemq.kaha.Marshall
/**
* Key and index for a BTree
*
- * @version $Revision: 1.1.1.1 $
+ *
*/
class TreeEntry implements Comparable {
Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/index/tree/TreeIndex.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/index/tree/TreeIndex.java?rev=1071259&r1=1071258&r2=1071259&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/index/tree/TreeIndex.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/index/tree/TreeIndex.java Wed Feb 16 14:08:48 2011
@@ -34,7 +34,7 @@ import org.slf4j.LoggerFactory;
/**
* BTree implementation
*
- * @version $Revision: 1.1.1.1 $
+ *
*/
public class TreeIndex implements Index {
Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/index/tree/TreePage.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/index/tree/TreePage.java?rev=1071259&r1=1071258&r2=1071259&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/index/tree/TreePage.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/index/tree/TreePage.java Wed Feb 16 14:08:48 2011
@@ -31,7 +31,7 @@ import org.slf4j.LoggerFactory;
/**
* Page in a BTree
*
- * @version $Revision: 1.1.1.1 $
+ *
*/
class TreePage {
Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/index/tree/TreePageEntry.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/index/tree/TreePageEntry.java?rev=1071259&r1=1071258&r2=1071259&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/index/tree/TreePageEntry.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/index/tree/TreePageEntry.java Wed Feb 16 14:08:48 2011
@@ -19,7 +19,7 @@ package org.apache.activemq.kaha.impl.in
/**
* A conglomarate used for return results from a tree lookup
*
- * @version $Revision: 1.1.1.1 $
+ *
*/
class TreePageEntry {
Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/management/BoundaryStatisticImpl.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/management/BoundaryStatisticImpl.java?rev=1071259&r1=1071258&r2=1071259&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/management/BoundaryStatisticImpl.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/management/BoundaryStatisticImpl.java Wed Feb 16 14:08:48 2011
@@ -20,7 +20,7 @@ package org.apache.activemq.management;
/**
* A boundary statistic implementation
*
- * @version $Revision: 1.2 $
+ *
*/
public class BoundaryStatisticImpl extends StatisticImpl {
private long lowerBound;
Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/management/BoundedRangeStatisticImpl.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/management/BoundedRangeStatisticImpl.java?rev=1071259&r1=1071258&r2=1071259&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/management/BoundedRangeStatisticImpl.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/management/BoundedRangeStatisticImpl.java Wed Feb 16 14:08:48 2011
@@ -20,7 +20,7 @@ package org.apache.activemq.management;
/**
* A bounded range statistic implementation
*
- * @version $Revision: 1.2 $
+ *
*/
public class BoundedRangeStatisticImpl extends RangeStatisticImpl {
private long lowerBound;
Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/management/CountStatisticImpl.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/management/CountStatisticImpl.java?rev=1071259&r1=1071258&r2=1071259&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/management/CountStatisticImpl.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/management/CountStatisticImpl.java Wed Feb 16 14:08:48 2011
@@ -23,7 +23,7 @@ import javax.management.j2ee.statistics.
/**
* A count statistic implementation
*
- * @version $Revision: 1.3 $
+ *
*/
public class CountStatisticImpl extends StatisticImpl implements CountStatistic {
Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/management/JCAConnectionPoolStatsImpl.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/management/JCAConnectionPoolStatsImpl.java?rev=1071259&r1=1071258&r2=1071259&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/management/JCAConnectionPoolStatsImpl.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/management/JCAConnectionPoolStatsImpl.java Wed Feb 16 14:08:48 2011
@@ -19,7 +19,7 @@ package org.apache.activemq.management;
/**
* Statistics for a JCA connection pool
*
- * @version $Revision: 1.2 $
+ *
*/
public class JCAConnectionPoolStatsImpl extends JCAConnectionStatsImpl {
private CountStatisticImpl closeCount;
Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/management/JCAConnectionStatsImpl.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/management/JCAConnectionStatsImpl.java?rev=1071259&r1=1071258&r2=1071259&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/management/JCAConnectionStatsImpl.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/management/JCAConnectionStatsImpl.java Wed Feb 16 14:08:48 2011
@@ -20,7 +20,7 @@ package org.apache.activemq.management;
/**
* Statistics for a JCA connection
*
- * @version $Revision: 1.2 $
+ *
*/
public class JCAConnectionStatsImpl extends StatsImpl {
private String connectionFactory;
Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/management/JCAStatsImpl.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/management/JCAStatsImpl.java?rev=1071259&r1=1071258&r2=1071259&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/management/JCAStatsImpl.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/management/JCAStatsImpl.java Wed Feb 16 14:08:48 2011
@@ -20,7 +20,7 @@ package org.apache.activemq.management;
/**
* Statistics for a number of JCA connections and connection pools
*
- * @version $Revision: 1.2 $
+ *
*/
public class JCAStatsImpl extends StatsImpl {
private JCAConnectionStatsImpl[] connectionStats;
Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/management/JMSConnectionStatsImpl.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/management/JMSConnectionStatsImpl.java?rev=1071259&r1=1071258&r2=1071259&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/management/JMSConnectionStatsImpl.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/management/JMSConnectionStatsImpl.java Wed Feb 16 14:08:48 2011
@@ -24,7 +24,7 @@ import org.apache.activemq.util.IndentPr
/**
* Statistics for a JMS connection
*
- * @version $Revision: 1.2 $
+ *
*/
public class JMSConnectionStatsImpl extends StatsImpl {
private List sessions;
Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/management/JMSConsumerStatsImpl.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/management/JMSConsumerStatsImpl.java?rev=1071259&r1=1071258&r2=1071259&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/management/JMSConsumerStatsImpl.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/management/JMSConsumerStatsImpl.java Wed Feb 16 14:08:48 2011
@@ -23,7 +23,7 @@ import org.apache.activemq.util.IndentPr
/**
* Statistics for a JMS consumer
*
- * @version $Revision: 1.2 $
+ *
*/
public class JMSConsumerStatsImpl extends JMSEndpointStatsImpl {
private String origin;
Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/management/JMSEndpointStatsImpl.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/management/JMSEndpointStatsImpl.java?rev=1071259&r1=1071258&r2=1071259&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/management/JMSEndpointStatsImpl.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/management/JMSEndpointStatsImpl.java Wed Feb 16 14:08:48 2011
@@ -30,7 +30,7 @@ import org.slf4j.LoggerFactory;
* but this class can also be used to represent statistics on a
* {@link Destination} as well.
*
- * @version $Revision: 1.3 $
+ *
*/
public class JMSEndpointStatsImpl extends StatsImpl {
private static final Logger LOG = LoggerFactory.getLogger(JMSEndpointStatsImpl.class);
Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/management/JMSProducerStatsImpl.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/management/JMSProducerStatsImpl.java?rev=1071259&r1=1071258&r2=1071259&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/management/JMSProducerStatsImpl.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/management/JMSProducerStatsImpl.java Wed Feb 16 14:08:48 2011
@@ -23,7 +23,7 @@ import org.apache.activemq.util.IndentPr
/**
* Statistics for a JMS producer
*
- * @version $Revision: 1.2 $
+ *
*/
public class JMSProducerStatsImpl extends JMSEndpointStatsImpl {
private String destination;
Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/management/JMSSessionStatsImpl.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/management/JMSSessionStatsImpl.java?rev=1071259&r1=1071258&r2=1071259&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/management/JMSSessionStatsImpl.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/management/JMSSessionStatsImpl.java Wed Feb 16 14:08:48 2011
@@ -25,7 +25,7 @@ import org.apache.activemq.util.IndentPr
/**
* Statistics for a JMS session
*
- * @version $Revision: 1.2 $
+ *
*/
public class JMSSessionStatsImpl extends StatsImpl {
private List producers;
Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/management/JMSStatsImpl.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/management/JMSStatsImpl.java?rev=1071259&r1=1071258&r2=1071259&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/management/JMSStatsImpl.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/management/JMSStatsImpl.java Wed Feb 16 14:08:48 2011
@@ -25,7 +25,7 @@ import org.apache.activemq.util.IndentPr
/**
* Statistics for a number of JMS connections
*
- * @version $Revision: 1.2 $
+ *
*/
public class JMSStatsImpl extends StatsImpl {
private List<ActiveMQConnection> connections = new CopyOnWriteArrayList<ActiveMQConnection>();
Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/management/PollCountStatisticImpl.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/management/PollCountStatisticImpl.java?rev=1071259&r1=1071258&r2=1071259&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/management/PollCountStatisticImpl.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/management/PollCountStatisticImpl.java Wed Feb 16 14:08:48 2011
@@ -25,7 +25,7 @@ import javax.management.j2ee.statistics.
/**
* A count statistic implementation
*
- * @version $Revision$
+ *
*/
public class PollCountStatisticImpl extends StatisticImpl implements CountStatistic {
Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/management/RangeStatisticImpl.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/management/RangeStatisticImpl.java?rev=1071259&r1=1071258&r2=1071259&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/management/RangeStatisticImpl.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/management/RangeStatisticImpl.java Wed Feb 16 14:08:48 2011
@@ -20,7 +20,7 @@ package org.apache.activemq.management;
/**
* A range statistic implementation
*
- * @version $Revision: 1.2 $
+ *
*/
public class RangeStatisticImpl extends StatisticImpl {
private long highWaterMark;
Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/management/Resettable.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/management/Resettable.java?rev=1071259&r1=1071258&r2=1071259&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/management/Resettable.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/management/Resettable.java Wed Feb 16 14:08:48 2011
@@ -19,7 +19,7 @@ package org.apache.activemq.management;
/**
* Represents some statistic that is capable of being reset
*
- * @version $Revision: 1.2 $
+ *
*/
public interface Resettable {
Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/management/StatisticImpl.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/management/StatisticImpl.java?rev=1071259&r1=1071258&r2=1071259&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/management/StatisticImpl.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/management/StatisticImpl.java Wed Feb 16 14:08:48 2011
@@ -21,7 +21,7 @@ import javax.management.j2ee.statistics.
/**
* Base class for a Statistic implementation
*
- * @version $Revision: 1.2 $
+ *
*/
public class StatisticImpl implements Statistic, Resettable {
Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/management/StatsCapable.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/management/StatsCapable.java?rev=1071259&r1=1071258&r2=1071259&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/management/StatsCapable.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/management/StatsCapable.java Wed Feb 16 14:08:48 2011
@@ -20,7 +20,7 @@ package org.apache.activemq.management;
/**
* Represents an object which is capable of providing some stats
*
- * @version $Revision: 1.2 $
+ *
*/
public interface StatsCapable {
Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/management/StatsImpl.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/management/StatsImpl.java?rev=1071259&r1=1071258&r2=1071259&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/management/StatsImpl.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/management/StatsImpl.java Wed Feb 16 14:08:48 2011
@@ -25,7 +25,7 @@ import javax.management.j2ee.statistics.
/**
* Base class for a Stats implementation
*
- * @version $Revision: 1.2 $
+ *
*/
public class StatsImpl extends StatisticImpl implements Stats, Resettable {
//use a Set instead of a Map - to conserve Space
Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/management/TimeStatisticImpl.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/management/TimeStatisticImpl.java?rev=1071259&r1=1071258&r2=1071259&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/management/TimeStatisticImpl.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/management/TimeStatisticImpl.java Wed Feb 16 14:08:48 2011
@@ -20,7 +20,7 @@ package org.apache.activemq.management;
/**
* A time statistic implementation
*
- * @version $Revision: 1.2 $
+ *
*/
public class TimeStatisticImpl extends StatisticImpl {
private long count;
Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/memory/Cache.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/memory/Cache.java?rev=1071259&r1=1071258&r2=1071259&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/memory/Cache.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/memory/Cache.java Wed Feb 16 14:08:48 2011
@@ -19,7 +19,7 @@ package org.apache.activemq.memory;
/**
* Defines the interface used to cache messages.
*
- * @version $Revision$
+ *
*/
public interface Cache {
Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/memory/CacheEntryList.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/memory/CacheEntryList.java?rev=1071259&r1=1071258&r2=1071259&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/memory/CacheEntryList.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/memory/CacheEntryList.java Wed Feb 16 14:08:48 2011
@@ -19,7 +19,7 @@ package org.apache.activemq.memory;
/**
* Maintains a simple linked list of CacheEntry objects. It is thread safe.
*
- * @version $Revision$
+ *
*/
public class CacheEntryList {
Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/memory/CacheFilter.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/memory/CacheFilter.java?rev=1071259&r1=1071258&r2=1071259&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/memory/CacheFilter.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/memory/CacheFilter.java Wed Feb 16 14:08:48 2011
@@ -20,7 +20,7 @@ package org.apache.activemq.memory;
/**
* Filters another Cache implementation.
*
- * @version $Revision$
+ *
*/
public class CacheFilter implements Cache {
Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/memory/LRUMap.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/memory/LRUMap.java?rev=1071259&r1=1071258&r2=1071259&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/memory/LRUMap.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/memory/LRUMap.java Wed Feb 16 14:08:48 2011
@@ -22,7 +22,7 @@ import java.util.Map;
/**
* A simple least-recently-used cache of a fixed size.
*
- * @version $Revision:$
+ *
*/
public class LRUMap<K,V> extends LinkedHashMap<K,V>{