activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From chir...@apache.org
Subject svn commit: r1071259 [3/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/...
Date Wed, 16 Feb 2011 14:09:23 GMT
Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/PrefetchSubscription.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/PrefetchSubscription.java?rev=1071259&r1=1071258&r2=1071259&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/PrefetchSubscription.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/PrefetchSubscription.java Wed Feb 16 14:08:48 2011
@@ -47,7 +47,7 @@ import org.slf4j.LoggerFactory;
 /**
  * A subscription that honors the pre-fetch option of the ConsumerInfo.
  * 
- * @version $Revision: 1.15 $
+ * 
  */
 public abstract class PrefetchSubscription extends AbstractSubscription {
 

Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/Queue.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/Queue.java?rev=1071259&r1=1071258&r2=1071259&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/Queue.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/Queue.java Wed Feb 16 14:08:48 2011
@@ -78,7 +78,7 @@ import org.slf4j.LoggerFactory;
  * The Queue is a List of MessageEntry objects that are dispatched to matching
  * subscriptions.
  * 
- * @version $Revision: 1.28 $
+ * 
  */
 public class Queue extends BaseDestination implements Task, UsageListener {
     protected static final Logger LOG = LoggerFactory.getLogger(Queue.class);

Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/QueueDispatchSelector.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/QueueDispatchSelector.java?rev=1071259&r1=1071258&r2=1071259&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/QueueDispatchSelector.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/QueueDispatchSelector.java Wed Feb 16 14:08:48 2011
@@ -34,7 +34,7 @@ import org.slf4j.LoggerFactory;
  * Queue dispatch policy that determines if a message can be sent to a subscription
  * 
  * @org.apache.xbean.XBean
- * @version $Revision$
+ * 
  */
 public class QueueDispatchSelector extends SimpleDispatchSelector {
     private static final Logger LOG = LoggerFactory.getLogger(QueueDispatchSelector.class);

Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/QueueRegion.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/QueueRegion.java?rev=1071259&r1=1071258&r2=1071259&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/QueueRegion.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/QueueRegion.java Wed Feb 16 14:08:48 2011
@@ -31,7 +31,7 @@ import org.apache.activemq.usage.SystemU
 
 /**
  * 
- * @version $Revision: 1.9 $
+ * 
  */
 public class QueueRegion extends AbstractRegion {
 

Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/Region.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/Region.java?rev=1071259&r1=1071258&r2=1071259&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/Region.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/Region.java Wed Feb 16 14:08:48 2011
@@ -38,7 +38,7 @@ import org.apache.activemq.command.Respo
  * a broker.  A Broker is composed of multiple message processing Regions that
  * provide different QOS options.
  * 
- * @version $Revision$
+ * 
  */
 public interface Region extends Service {
 

Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/RegionBroker.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/RegionBroker.java?rev=1071259&r1=1071258&r2=1071259&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/RegionBroker.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/RegionBroker.java Wed Feb 16 14:08:48 2011
@@ -73,7 +73,7 @@ import org.slf4j.LoggerFactory;
 /**
  * Routes Broker operations to the correct messaging regions for processing.
  * 
- * @version $Revision$
+ * 
  */
 public class RegionBroker extends EmptyBroker {
     public static final String ORIGINAL_EXPIRATION = "originalExpiration";

Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/Subscription.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/Subscription.java?rev=1071259&r1=1071258&r2=1071259&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/Subscription.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/Subscription.java Wed Feb 16 14:08:48 2011
@@ -32,7 +32,7 @@ import org.apache.activemq.command.Respo
 import org.apache.activemq.filter.MessageEvaluationContext;
 
 /**
- * @version $Revision: 1.5 $
+ * 
  */
 public interface Subscription extends SubscriptionRecovery {
 

Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/SubscriptionRecovery.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/SubscriptionRecovery.java?rev=1071259&r1=1071258&r2=1071259&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/SubscriptionRecovery.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/SubscriptionRecovery.java Wed Feb 16 14:08:48 2011
@@ -23,7 +23,7 @@ import org.apache.activemq.command.Activ
  * An interface for recoverying transient messages held by the broker for
  * retractive recovery for subscribers
  * 
- * @version $Revision$
+ * 
  */
 public interface SubscriptionRecovery {
 

Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/TempQueue.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/TempQueue.java?rev=1071259&r1=1071258&r2=1071259&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/TempQueue.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/TempQueue.java Wed Feb 16 14:08:48 2011
@@ -31,7 +31,7 @@ import org.slf4j.LoggerFactory;
  * The Queue is a List of MessageEntry objects that are dispatched to matching
  * subscriptions.
  * 
- * @version $Revision: 1.28 $
+ * 
  */
 public class TempQueue extends Queue{
     private static final Logger LOG = LoggerFactory.getLogger(TempQueue.class);

Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/TempQueueRegion.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/TempQueueRegion.java?rev=1071259&r1=1071258&r2=1071259&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/TempQueueRegion.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/TempQueueRegion.java Wed Feb 16 14:08:48 2011
@@ -30,7 +30,7 @@ import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
 /**
- * @version $Revision: 1.7 $
+ * 
  */
 public class TempQueueRegion extends AbstractTempRegion {
     private static final Logger LOG = LoggerFactory.getLogger(TempQueueRegion.class);

Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/TempTopic.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/TempTopic.java?rev=1071259&r1=1071258&r2=1071259&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/TempTopic.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/TempTopic.java Wed Feb 16 14:08:48 2011
@@ -28,7 +28,7 @@ import org.apache.activemq.thread.TaskRu
  * The Topic is a destination that sends a copy of a message to every active
  * Subscription registered.
  * 
- * @version $Revision: 1.21 $
+ * 
  */
 public class TempTopic  extends Topic  implements Task{
     private final ActiveMQTempDestination tempDest;

Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/TempTopicRegion.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/TempTopicRegion.java?rev=1071259&r1=1071258&r2=1071259&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/TempTopicRegion.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/TempTopicRegion.java Wed Feb 16 14:08:48 2011
@@ -28,7 +28,7 @@ import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
 /**
- * @version $Revision: 1.7 $
+ * 
  */
 public class TempTopicRegion extends AbstractTempRegion {
 

Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/Topic.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/Topic.java?rev=1071259&r1=1071258&r2=1071259&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/Topic.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/Topic.java Wed Feb 16 14:08:48 2011
@@ -59,7 +59,7 @@ import org.slf4j.LoggerFactory;
  * The Topic is a destination that sends a copy of a message to every active
  * Subscription registered.
  * 
- * @version $Revision: 1.21 $
+ * 
  */
 public class Topic extends BaseDestination implements Task {
     protected static final Logger LOG = LoggerFactory.getLogger(Topic.class);

Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/TopicRegion.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/TopicRegion.java?rev=1071259&r1=1071258&r2=1071259&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/TopicRegion.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/TopicRegion.java Wed Feb 16 14:08:48 2011
@@ -42,7 +42,7 @@ import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
 /**
- * @version $Revision: 1.12 $
+ * 
  */
 public class TopicRegion extends AbstractRegion {
     private static final Logger LOG = LoggerFactory.getLogger(TopicRegion.class);

Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/DispatchPolicy.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/DispatchPolicy.java?rev=1071259&r1=1071258&r2=1071259&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/DispatchPolicy.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/DispatchPolicy.java Wed Feb 16 14:08:48 2011
@@ -27,7 +27,7 @@ import org.apache.activemq.filter.Messag
  * into the region implementations.  This is used by a queue to deliver
  * messages to the matching subscriptions.
  * 
- * @version $Revision$
+ * 
  */
 public interface DispatchPolicy {
     

Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/FilePendingDurableSubscriberMessageStoragePolicy.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/FilePendingDurableSubscriberMessageStoragePolicy.java?rev=1071259&r1=1071258&r2=1071259&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/FilePendingDurableSubscriberMessageStoragePolicy.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/FilePendingDurableSubscriberMessageStoragePolicy.java Wed Feb 16 14:08:48 2011
@@ -28,7 +28,7 @@ import org.apache.activemq.broker.region
  * @org.apache.xbean.XBean element="fileDurableSubscriberCursor"
  *                         description="Pending messages for durable subscribers
  *                         held in temporary files"
- * @version $Revision$
+ * 
  */
 public class FilePendingDurableSubscriberMessageStoragePolicy implements PendingDurableSubscriberMessageStoragePolicy {
 

Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/FilePendingQueueMessageStoragePolicy.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/FilePendingQueueMessageStoragePolicy.java?rev=1071259&r1=1071258&r2=1071259&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/FilePendingQueueMessageStoragePolicy.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/FilePendingQueueMessageStoragePolicy.java Wed Feb 16 14:08:48 2011
@@ -27,7 +27,7 @@ import org.apache.activemq.broker.region
  * @org.apache.xbean.XBean element="fileQueueCursor" description="Pending
  *                         messages paged in from file"
  * 
- * @version $Revision$
+ * 
  */
 public class FilePendingQueueMessageStoragePolicy implements PendingQueueMessageStoragePolicy {
 

Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/FilePendingSubscriberMessageStoragePolicy.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/FilePendingSubscriberMessageStoragePolicy.java?rev=1071259&r1=1071258&r2=1071259&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/FilePendingSubscriberMessageStoragePolicy.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/FilePendingSubscriberMessageStoragePolicy.java Wed Feb 16 14:08:48 2011
@@ -28,7 +28,7 @@ import org.apache.activemq.broker.region
  * @org.apache.xbean.XBean element="fileCursor" description="Pending messages
  *                         for durable subscribers held in temporary files"
  * 
- * @version $Revision$
+ * 
  */
 public class FilePendingSubscriberMessageStoragePolicy implements PendingSubscriberMessageStoragePolicy {
 

Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/FixedCountSubscriptionRecoveryPolicy.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/FixedCountSubscriptionRecoveryPolicy.java?rev=1071259&r1=1071258&r2=1071259&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/FixedCountSubscriptionRecoveryPolicy.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/FixedCountSubscriptionRecoveryPolicy.java Wed Feb 16 14:08:48 2011
@@ -32,7 +32,7 @@ import org.apache.activemq.filter.Destin
  * count of last messages.
  * 
  * @org.apache.xbean.XBean
- * @version $Revision$
+ * 
  */
 public class FixedCountSubscriptionRecoveryPolicy implements SubscriptionRecoveryPolicy {
     private volatile MessageReference messages[];

Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/FixedSizedSubscriptionRecoveryPolicy.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/FixedSizedSubscriptionRecoveryPolicy.java?rev=1071259&r1=1071258&r2=1071259&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/FixedSizedSubscriptionRecoveryPolicy.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/FixedSizedSubscriptionRecoveryPolicy.java Wed Feb 16 14:08:48 2011
@@ -35,7 +35,7 @@ import org.apache.activemq.memory.list.S
  * time order.
  * 
  * @org.apache.xbean.XBean
- * @version $Revision$
+ * 
  */
 public class FixedSizedSubscriptionRecoveryPolicy implements SubscriptionRecoveryPolicy {
 

Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/LastImageSubscriptionRecoveryPolicy.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/LastImageSubscriptionRecoveryPolicy.java?rev=1071259&r1=1071258&r2=1071259&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/LastImageSubscriptionRecoveryPolicy.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/LastImageSubscriptionRecoveryPolicy.java Wed Feb 16 14:08:48 2011
@@ -32,7 +32,7 @@ import org.apache.activemq.filter.Destin
  * last message.
  * 
  * @org.apache.xbean.XBean
- * @version $Revision$
+ * 
  */
 public class LastImageSubscriptionRecoveryPolicy implements SubscriptionRecoveryPolicy {
 

Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/NoSubscriptionRecoveryPolicy.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/NoSubscriptionRecoveryPolicy.java?rev=1071259&r1=1071258&r2=1071259&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/NoSubscriptionRecoveryPolicy.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/NoSubscriptionRecoveryPolicy.java Wed Feb 16 14:08:48 2011
@@ -28,7 +28,7 @@ import org.apache.activemq.command.Messa
  * This SubscriptionRecoveryPolicy disable recovery of messages.
  * 
  * @org.apache.xbean.XBean
- * @version $Revision$
+ * 
  */
 public class NoSubscriptionRecoveryPolicy implements SubscriptionRecoveryPolicy {
 

Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/PendingDurableSubscriberMessageStoragePolicy.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/PendingDurableSubscriberMessageStoragePolicy.java?rev=1071259&r1=1071258&r2=1071259&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/PendingDurableSubscriberMessageStoragePolicy.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/PendingDurableSubscriberMessageStoragePolicy.java Wed Feb 16 14:08:48 2011
@@ -24,7 +24,7 @@ import org.apache.activemq.broker.region
  * Abstraction to allow different policies for holding messages awaiting
  * dispatch to active clients
  * 
- * @version $Revision$
+ * 
  */
 public interface PendingDurableSubscriberMessageStoragePolicy {
 

Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/PendingQueueMessageStoragePolicy.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/PendingQueueMessageStoragePolicy.java?rev=1071259&r1=1071258&r2=1071259&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/PendingQueueMessageStoragePolicy.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/PendingQueueMessageStoragePolicy.java Wed Feb 16 14:08:48 2011
@@ -24,7 +24,7 @@ import org.apache.activemq.broker.region
  * Abstraction to allow different policies for holding messages awaiting
  * dispatch on a Queue
  * 
- * @version $Revision$
+ * 
  */
 public interface PendingQueueMessageStoragePolicy {
 

Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/PendingSubscriberMessageStoragePolicy.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/PendingSubscriberMessageStoragePolicy.java?rev=1071259&r1=1071258&r2=1071259&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/PendingSubscriberMessageStoragePolicy.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/PendingSubscriberMessageStoragePolicy.java Wed Feb 16 14:08:48 2011
@@ -24,7 +24,7 @@ import org.apache.activemq.broker.region
  * Abstraction to allow different policies for holding messages awaiting
  * dispatch to active clients
  * 
- * @version $Revision$
+ * 
  */
 public interface PendingSubscriberMessageStoragePolicy {
 

Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/PolicyEntry.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/PolicyEntry.java?rev=1071259&r1=1071258&r2=1071259&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/PolicyEntry.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/PolicyEntry.java Wed Feb 16 14:08:48 2011
@@ -39,7 +39,7 @@ import org.slf4j.LoggerFactory;
  * specific destination or a hierarchical wildcard area of destinations.
  * 
  * @org.apache.xbean.XBean
- * @version $Revision: 1.1 $
+ * 
  */
 public class PolicyEntry extends DestinationMapEntry {
 

Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/PolicyMap.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/PolicyMap.java?rev=1071259&r1=1071258&r2=1071259&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/PolicyMap.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/PolicyMap.java Wed Feb 16 14:08:48 2011
@@ -28,7 +28,7 @@ import org.apache.activemq.filter.Destin
  * 
  * @org.apache.xbean.XBean
  * 
- * @version $Revision: 1.1 $
+ * 
  */
 public class PolicyMap extends DestinationMap {
 

Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/RoundRobinDispatchPolicy.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/RoundRobinDispatchPolicy.java?rev=1071259&r1=1071258&r2=1071259&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/RoundRobinDispatchPolicy.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/RoundRobinDispatchPolicy.java Wed Feb 16 14:08:48 2011
@@ -29,7 +29,7 @@ import org.slf4j.LoggerFactory;
  * matches the message.
  * 
  * @org.apache.xbean.XBean
- * @version $Revision$
+ * 
  */
 public class RoundRobinDispatchPolicy implements DispatchPolicy {
     static final Logger LOG = LoggerFactory.getLogger(RoundRobinDispatchPolicy.class);

Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/SimpleDispatchPolicy.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/SimpleDispatchPolicy.java?rev=1071259&r1=1071258&r2=1071259&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/SimpleDispatchPolicy.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/SimpleDispatchPolicy.java Wed Feb 16 14:08:48 2011
@@ -26,7 +26,7 @@ import org.apache.activemq.filter.Messag
  * matches the message.
  * 
  * @org.apache.xbean.XBean
- * @version $Revision$
+ * 
  */
 public class SimpleDispatchPolicy implements DispatchPolicy {
 

Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/SimpleDispatchSelector.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/SimpleDispatchSelector.java?rev=1071259&r1=1071258&r2=1071259&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/SimpleDispatchSelector.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/SimpleDispatchSelector.java Wed Feb 16 14:08:48 2011
@@ -26,7 +26,7 @@ import org.apache.activemq.filter.NonCac
  * Simple dispatch policy that determines if a message can be sent to a subscription
  *
  * @org.apache.xbean.XBean
- * @version $Revision$
+ * 
  */
 public class SimpleDispatchSelector implements DispatchSelector {
 

Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/StorePendingDurableSubscriberMessageStoragePolicy.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/StorePendingDurableSubscriberMessageStoragePolicy.java?rev=1071259&r1=1071258&r2=1071259&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/StorePendingDurableSubscriberMessageStoragePolicy.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/StorePendingDurableSubscriberMessageStoragePolicy.java Wed Feb 16 14:08:48 2011
@@ -29,7 +29,7 @@ import org.apache.activemq.kaha.Store;
  * @org.apache.xbean.XBean element="storeDurableSubscriberCursor"
  *                         description="Pending messages for a durable
  *                         subscriber are referenced from the Store"
- * @version $Revision$
+ * 
  */
 public class StorePendingDurableSubscriberMessageStoragePolicy implements PendingDurableSubscriberMessageStoragePolicy {
     boolean immediatePriorityDispatch = true;

Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/StorePendingQueueMessageStoragePolicy.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/StorePendingQueueMessageStoragePolicy.java?rev=1071259&r1=1071258&r2=1071259&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/StorePendingQueueMessageStoragePolicy.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/StorePendingQueueMessageStoragePolicy.java Wed Feb 16 14:08:48 2011
@@ -27,7 +27,7 @@ import org.apache.activemq.broker.region
  * @org.apache.xbean.XBean element="storeCursor" description="Pending messages
  *                         paged in from the Store"
  * 
- * @version $Revision$
+ * 
  */
 public class StorePendingQueueMessageStoragePolicy implements PendingQueueMessageStoragePolicy {
 

Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/StrictOrderDispatchPolicy.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/StrictOrderDispatchPolicy.java?rev=1071259&r1=1071258&r2=1071259&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/StrictOrderDispatchPolicy.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/StrictOrderDispatchPolicy.java Wed Feb 16 14:08:48 2011
@@ -27,7 +27,7 @@ import org.apache.activemq.filter.Messag
  * order.
  * 
  * @org.apache.xbean.XBean
- * @version $Revision$
+ * 
  */
 public class StrictOrderDispatchPolicy implements DispatchPolicy {
 

Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/SubscriptionRecoveryPolicy.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/SubscriptionRecoveryPolicy.java?rev=1071259&r1=1071258&r2=1071259&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/SubscriptionRecoveryPolicy.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/SubscriptionRecoveryPolicy.java Wed Feb 16 14:08:48 2011
@@ -31,7 +31,7 @@ import org.apache.activemq.command.Messa
  * into the region implementations.  This is used by a topic to retroactively recover
  * messages that the subscription missed.
  * 
- * @version $Revision$
+ * 
  */
 public interface SubscriptionRecoveryPolicy extends Service {
     

Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/TimedSubscriptionRecoveryPolicy.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/TimedSubscriptionRecoveryPolicy.java?rev=1071259&r1=1071258&r2=1071259&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/TimedSubscriptionRecoveryPolicy.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/TimedSubscriptionRecoveryPolicy.java Wed Feb 16 14:08:48 2011
@@ -37,7 +37,7 @@ import org.apache.activemq.thread.Schedu
  * subscriptions.
  * 
  * @org.apache.xbean.XBean
- * @version $Revision$
+ * 
  */
 public class TimedSubscriptionRecoveryPolicy implements SubscriptionRecoveryPolicy {
 

Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/VMPendingDurableSubscriberMessageStoragePolicy.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/VMPendingDurableSubscriberMessageStoragePolicy.java?rev=1071259&r1=1071258&r2=1071259&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/VMPendingDurableSubscriberMessageStoragePolicy.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/VMPendingDurableSubscriberMessageStoragePolicy.java Wed Feb 16 14:08:48 2011
@@ -27,7 +27,7 @@ import org.apache.activemq.broker.region
  * 
  * @org.apache.xbean.XBean element="vmDurableCursor" description="Pending
  *                         messages held in the JVM"
- * @version $Revision$
+ * 
  */
 public class VMPendingDurableSubscriberMessageStoragePolicy implements PendingDurableSubscriberMessageStoragePolicy {
 

Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/VMPendingQueueMessageStoragePolicy.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/VMPendingQueueMessageStoragePolicy.java?rev=1071259&r1=1071258&r2=1071259&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/VMPendingQueueMessageStoragePolicy.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/VMPendingQueueMessageStoragePolicy.java Wed Feb 16 14:08:48 2011
@@ -27,7 +27,7 @@ import org.apache.activemq.broker.region
  * @org.apache.xbean.XBean element="vmQueueCursor" description="Pending messages
  *                         held in the JVM"
  * 
- * @version $Revision$
+ * 
  */
 public class VMPendingQueueMessageStoragePolicy implements PendingQueueMessageStoragePolicy {
 

Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/VMPendingSubscriberMessageStoragePolicy.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/VMPendingSubscriberMessageStoragePolicy.java?rev=1071259&r1=1071258&r2=1071259&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/VMPendingSubscriberMessageStoragePolicy.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/VMPendingSubscriberMessageStoragePolicy.java Wed Feb 16 14:08:48 2011
@@ -28,7 +28,7 @@ import org.apache.activemq.broker.region
  * @org.apache.xbean.XBean element="vmCursor" description="Pending messages held
  *                         in the JVM"
  * 
- * @version $Revision$
+ * 
  */
 public class VMPendingSubscriberMessageStoragePolicy implements PendingSubscriberMessageStoragePolicy {
 

Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/util/CommandHandler.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/util/CommandHandler.java?rev=1071259&r1=1071258&r2=1071259&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/util/CommandHandler.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/util/CommandHandler.java Wed Feb 16 14:08:48 2011
@@ -21,7 +21,7 @@ import javax.jms.TextMessage;
 /**
  * Represents a processor of text based commands
  *
- * @version $Revision: $
+ * 
  */
 public interface CommandHandler {
     void processCommand(TextMessage request, TextMessage response) throws Exception;

Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/util/CommandMessageListener.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/util/CommandMessageListener.java?rev=1071259&r1=1071258&r2=1071259&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/util/CommandMessageListener.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/util/CommandMessageListener.java Wed Feb 16 14:08:48 2011
@@ -32,7 +32,7 @@ import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
 /**
- * @version $Revision: $
+ * 
  */
 public class CommandMessageListener implements MessageListener {
     private static final Logger LOG = LoggerFactory.getLogger(CommandMessageListener.class);

Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/util/TimeStampingBrokerPlugin.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/util/TimeStampingBrokerPlugin.java?rev=1071259&r1=1071258&r2=1071259&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/util/TimeStampingBrokerPlugin.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/util/TimeStampingBrokerPlugin.java Wed Feb 16 14:08:48 2011
@@ -42,7 +42,7 @@ import org.slf4j.LoggerFactory;
  *
  * @org.apache.xbean.XBean element="timeStampingBrokerPlugin"
  * 
- * @version $Revision$
+ * 
  */
 public class TimeStampingBrokerPlugin extends BrokerPluginSupport {
     private static final Logger LOG = LoggerFactory.getLogger(TimeStampingBrokerPlugin.class);

Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/util/TraceBrokerPathPlugin.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/util/TraceBrokerPathPlugin.java?rev=1071259&r1=1071258&r2=1071259&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/util/TraceBrokerPathPlugin.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/util/TraceBrokerPathPlugin.java Wed Feb 16 14:08:48 2011
@@ -32,7 +32,7 @@ import org.slf4j.LoggerFactory;
  * 
  * @org.apache.xbean.XBean element="traceBrokerPathPlugin"
  * 
- * @version $Revision$
+ * 
  */
 
 public class TraceBrokerPathPlugin extends BrokerPluginSupport {

Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/view/ConnectionDotFileInterceptor.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/view/ConnectionDotFileInterceptor.java?rev=1071259&r1=1071258&r2=1071259&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/view/ConnectionDotFileInterceptor.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/view/ConnectionDotFileInterceptor.java Wed Feb 16 14:08:48 2011
@@ -39,7 +39,7 @@ import java.util.Set;
 import javax.management.ObjectName;
 
 /**
- * @version $Revision: $
+ * 
  */
 public class ConnectionDotFileInterceptor extends DotFileInterceptorSupport {
 

Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/view/ConnectionDotFilePlugin.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/view/ConnectionDotFilePlugin.java?rev=1071259&r1=1071258&r2=1071259&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/view/ConnectionDotFilePlugin.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/view/ConnectionDotFilePlugin.java Wed Feb 16 14:08:48 2011
@@ -25,7 +25,7 @@ import org.apache.activemq.broker.Broker
  * 
  * @org.apache.xbean.XBean
  * 
- * @version $Revision: $
+ * 
  */
 public class ConnectionDotFilePlugin implements BrokerPlugin {
     private String file = "ActiveMQConnections.dot";

Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/view/DestinationDotFileInterceptor.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/view/DestinationDotFileInterceptor.java?rev=1071259&r1=1071258&r2=1071259&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/view/DestinationDotFileInterceptor.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/view/DestinationDotFileInterceptor.java Wed Feb 16 14:08:48 2011
@@ -27,7 +27,7 @@ import org.apache.activemq.filter.Destin
 import org.apache.activemq.filter.DestinationMapNode;
 
 /**
- * @version $Revision: $
+ * 
  */
 public class DestinationDotFileInterceptor extends DotFileInterceptorSupport {
 

Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/view/DestinationDotFilePlugin.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/view/DestinationDotFilePlugin.java?rev=1071259&r1=1071258&r2=1071259&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/view/DestinationDotFilePlugin.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/view/DestinationDotFilePlugin.java Wed Feb 16 14:08:48 2011
@@ -25,7 +25,7 @@ import org.apache.activemq.broker.Broker
  * 
  * @org.apache.xbean.XBean
  * 
- * @version $Revision: $
+ * 
  */
 public class DestinationDotFilePlugin implements BrokerPlugin {
     private String file = "ActiveMQDestinations.dot";

Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/view/DotFileInterceptorSupport.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/view/DotFileInterceptorSupport.java?rev=1071259&r1=1071258&r2=1071259&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/view/DotFileInterceptorSupport.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/view/DotFileInterceptorSupport.java Wed Feb 16 14:08:48 2011
@@ -27,7 +27,7 @@ import org.slf4j.LoggerFactory;
 /**
  * Useful base class
  * 
- * @version $Revision: $
+ * 
  */
 public abstract class DotFileInterceptorSupport extends BrokerFilter {
     private final Logger log = LoggerFactory.getLogger(DotFileInterceptorSupport.class);

Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ActiveMQBlobMessage.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ActiveMQBlobMessage.java?rev=1071259&r1=1071258&r2=1071259&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ActiveMQBlobMessage.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ActiveMQBlobMessage.java Wed Feb 16 14:08:48 2011
@@ -31,7 +31,7 @@ import org.apache.activemq.util.JMSExcep
 /**
  * An implementation of {@link BlobMessage} for out of band BLOB transfer
  * 
- * @version $Revision: $
+ * 
  * @openwire:marshaller code="29"
  */
 public class ActiveMQBlobMessage extends ActiveMQMessage implements BlobMessage {

Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ActiveMQDestination.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ActiveMQDestination.java?rev=1071259&r1=1071258&r2=1071259&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ActiveMQDestination.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ActiveMQDestination.java Wed Feb 16 14:08:48 2011
@@ -42,7 +42,7 @@ import org.apache.activemq.util.URISuppo
 
 /**
  * @openwire:marshaller
- * @version $Revision: 1.10 $
+ * 
  */
 public abstract class ActiveMQDestination extends JNDIBaseStorable implements DataStructure, Destination, Externalizable, Comparable {
 

Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ActiveMQMessage.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ActiveMQMessage.java?rev=1071259&r1=1071258&r2=1071259&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ActiveMQMessage.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ActiveMQMessage.java Wed Feb 16 14:08:48 2011
@@ -39,7 +39,7 @@ import org.apache.activemq.util.JMSExcep
 import org.apache.activemq.util.TypeConversionSupport;
 
 /**
- * @version $Revision:$
+ * 
  * @openwire:marshaller code="23"
  */
 public class ActiveMQMessage extends Message implements org.apache.activemq.Message, ScheduledMessage {

Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ActiveMQQueue.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ActiveMQQueue.java?rev=1071259&r1=1071258&r2=1071259&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ActiveMQQueue.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ActiveMQQueue.java Wed Feb 16 14:08:48 2011
@@ -25,7 +25,7 @@ import javax.jms.Queue;
  *                         Destination"
  * 
  * @openwire:marshaller code="100"
- * @version $Revision: 1.5 $
+ * 
  */
 public class ActiveMQQueue extends ActiveMQDestination implements Queue {
 

Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ActiveMQTempDestination.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ActiveMQTempDestination.java?rev=1071259&r1=1071258&r2=1071259&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ActiveMQTempDestination.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ActiveMQTempDestination.java Wed Feb 16 14:08:48 2011
@@ -23,7 +23,7 @@ import org.slf4j.LoggerFactory;
 
 /**
  * @openwire:marshaller
- * @version $Revision: 1.5 $
+ * 
  */
 public abstract class ActiveMQTempDestination extends ActiveMQDestination {
 

Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ActiveMQTempQueue.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ActiveMQTempQueue.java?rev=1071259&r1=1071258&r2=1071259&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ActiveMQTempQueue.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ActiveMQTempQueue.java Wed Feb 16 14:08:48 2011
@@ -21,7 +21,7 @@ import javax.jms.TemporaryQueue;
 
 /**
  * @openwire:marshaller code="102"
- * @version $Revision: 1.6 $
+ * 
  */
 public class ActiveMQTempQueue extends ActiveMQTempDestination implements TemporaryQueue {
 

Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ActiveMQTempTopic.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ActiveMQTempTopic.java?rev=1071259&r1=1071258&r2=1071259&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ActiveMQTempTopic.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ActiveMQTempTopic.java Wed Feb 16 14:08:48 2011
@@ -21,7 +21,7 @@ import javax.jms.TemporaryTopic;
 
 /**
  * @openwire:marshaller code="103"
- * @version $Revision: 1.6 $
+ * 
  */
 public class ActiveMQTempTopic extends ActiveMQTempDestination implements TemporaryTopic {
 

Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ActiveMQTextMessage.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ActiveMQTextMessage.java?rev=1071259&r1=1071258&r2=1071259&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ActiveMQTextMessage.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ActiveMQTextMessage.java Wed Feb 16 14:08:48 2011
@@ -39,7 +39,7 @@ import org.apache.activemq.wireformat.Wi
 
 /**
  * @openwire:marshaller code="28"
- * @version $Revision$
+ * 
  */
 public class ActiveMQTextMessage extends ActiveMQMessage implements TextMessage {
 

Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ActiveMQTopic.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ActiveMQTopic.java?rev=1071259&r1=1071258&r2=1071259&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ActiveMQTopic.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ActiveMQTopic.java Wed Feb 16 14:08:48 2011
@@ -23,7 +23,7 @@ import javax.jms.Topic;
  * @org.apache.xbean.XBean element="topic" description="An ActiveMQ Topic
  *                         Destination"
  * @openwire:marshaller code="101"
- * @version $Revision: 1.5 $
+ * 
  */
 public class ActiveMQTopic extends ActiveMQDestination implements Topic {
 

Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/BaseCommand.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/BaseCommand.java?rev=1071259&r1=1071258&r2=1071259&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/BaseCommand.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/BaseCommand.java Wed Feb 16 14:08:48 2011
@@ -23,7 +23,7 @@ import org.apache.activemq.util.Introspe
 /**
  * 
  * @openwire:marshaller
- * @version $Revision: 1.11 $
+ * 
  */
 public abstract class BaseCommand implements Command {
 

Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/BrokerId.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/BrokerId.java?rev=1071259&r1=1071258&r2=1071259&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/BrokerId.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/BrokerId.java Wed Feb 16 14:08:48 2011
@@ -18,7 +18,7 @@ package org.apache.activemq.command;
 
 /**
  * @openwire:marshaller code="124"
- * @version $Revision$
+ * 
  */
 public class BrokerId implements DataStructure {
 

Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/BrokerInfo.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/BrokerInfo.java?rev=1071259&r1=1071258&r2=1071259&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/BrokerInfo.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/BrokerInfo.java Wed Feb 16 14:08:48 2011
@@ -28,7 +28,7 @@ import org.apache.activemq.util.Marshall
  * in discovering other nodes in the cluster.
  * 
  * @openwire:marshaller code="2"
- * @version $Revision: 1.7 $
+ * 
  */
 public class BrokerInfo extends BaseCommand {
     private static final String PASSIVE_SLAVE_KEY = "passiveSlave";

Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/Command.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/Command.java?rev=1071259&r1=1071258&r2=1071259&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/Command.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/Command.java Wed Feb 16 14:08:48 2011
@@ -22,7 +22,7 @@ import org.apache.activemq.state.Command
  * The Command Pattern so that we can send and receive commands on the different
  * transports
  * 
- * @version $Revision: 1.7 $
+ * 
  */
 public interface Command extends DataStructure {
 

Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/CommandTypes.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/CommandTypes.java?rev=1071259&r1=1071258&r2=1071259&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/CommandTypes.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/CommandTypes.java Wed Feb 16 14:08:48 2011
@@ -19,7 +19,7 @@ package org.apache.activemq.command;
 /**
  * Holds the command id constants used by the command objects.
  * 
- * @version $Revision: 1.21 $
+ * 
  */
 public interface CommandTypes {
 

Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ConnectionControl.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ConnectionControl.java?rev=1071259&r1=1071258&r2=1071259&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ConnectionControl.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ConnectionControl.java Wed Feb 16 14:08:48 2011
@@ -22,7 +22,7 @@ import org.apache.activemq.state.Command
  * Used to start and stop transports as well as terminating clients.
  * 
  * @openwire:marshaller code="18"
- * @version $Revision: 1.1 $
+ * 
  */
 public class ConnectionControl extends BaseCommand {
     public static final byte DATA_STRUCTURE_TYPE = CommandTypes.CONNECTION_CONTROL;

Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ConnectionError.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ConnectionError.java?rev=1071259&r1=1071258&r2=1071259&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ConnectionError.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ConnectionError.java Wed Feb 16 14:08:48 2011
@@ -21,7 +21,7 @@ import org.apache.activemq.state.Command
 /**
  * 
  * @openwire:marshaller code="16"
- * @version $Revision$
+ * 
  */
 public class ConnectionError extends BaseCommand {
 

Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ConnectionId.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ConnectionId.java?rev=1071259&r1=1071258&r2=1071259&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ConnectionId.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ConnectionId.java Wed Feb 16 14:08:48 2011
@@ -18,7 +18,7 @@ package org.apache.activemq.command;
 
 /**
  * @openwire:marshaller code="120"
- * @version $Revision$
+ * 
  */
 public class ConnectionId implements DataStructure, Comparable<ConnectionId> {
 

Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ConnectionInfo.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ConnectionInfo.java?rev=1071259&r1=1071258&r2=1071259&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ConnectionInfo.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ConnectionInfo.java Wed Feb 16 14:08:48 2011
@@ -21,7 +21,7 @@ import org.apache.activemq.state.Command
 /**
  * 
  * @openwire:marshaller code="3"
- * @version $Revision: 1.11 $
+ * 
  */
 public class ConnectionInfo extends BaseCommand {
 

Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ConsumerControl.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ConsumerControl.java?rev=1071259&r1=1071258&r2=1071259&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ConsumerControl.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ConsumerControl.java Wed Feb 16 14:08:48 2011
@@ -22,7 +22,7 @@ import org.apache.activemq.state.Command
  * Used to start and stop transports as well as terminating clients.
  * 
  * @openwire:marshaller code="17"
- * @version $Revision: 1.1 $
+ * 
  */
 public class ConsumerControl extends BaseCommand {
 

Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ConsumerId.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ConsumerId.java?rev=1071259&r1=1071258&r2=1071259&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ConsumerId.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ConsumerId.java Wed Feb 16 14:08:48 2011
@@ -18,7 +18,7 @@ package org.apache.activemq.command;
 
 /**
  * @openwire:marshaller code="122"
- * @version $Revision$
+ * 
  */
 public class ConsumerId implements DataStructure {
 

Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ConsumerInfo.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ConsumerInfo.java?rev=1071259&r1=1071258&r2=1071259&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ConsumerInfo.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ConsumerInfo.java Wed Feb 16 14:08:48 2011
@@ -24,7 +24,7 @@ import org.apache.activemq.state.Command
 
 /**
  * @openwire:marshaller code="5"
- * @version $Revision: 1.20 $
+ * 
  */
 public class ConsumerInfo extends BaseCommand {
 

Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ControlCommand.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ControlCommand.java?rev=1071259&r1=1071258&r2=1071259&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ControlCommand.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ControlCommand.java Wed Feb 16 14:08:48 2011
@@ -23,7 +23,7 @@ import org.apache.activemq.state.Command
  * 
  * @openwire:marshaller code="14"
  * 
- * @version $Revision: 1.1 $
+ * 
  */
 public class ControlCommand extends BaseCommand {
 

Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/DataArrayResponse.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/DataArrayResponse.java?rev=1071259&r1=1071258&r2=1071259&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/DataArrayResponse.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/DataArrayResponse.java Wed Feb 16 14:08:48 2011
@@ -18,7 +18,7 @@ package org.apache.activemq.command;
 
 /**
  * @openwire:marshaller code="33"
- * @version $Revision$
+ * 
  */
 public class DataArrayResponse extends Response {
 

Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/DataResponse.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/DataResponse.java?rev=1071259&r1=1071258&r2=1071259&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/DataResponse.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/DataResponse.java Wed Feb 16 14:08:48 2011
@@ -19,7 +19,7 @@ package org.apache.activemq.command;
 /**
  * 
  * @openwire:marshaller code="32"
- * @version $Revision$
+ * 
  */
 public class DataResponse extends Response {
 

Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/DataStructure.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/DataStructure.java?rev=1071259&r1=1071258&r2=1071259&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/DataStructure.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/DataStructure.java Wed Feb 16 14:08:48 2011
@@ -17,7 +17,7 @@
 package org.apache.activemq.command;
 
 /**
- * @version $Revision$
+ * 
  */
 public interface DataStructure {
     

Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/DestinationInfo.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/DestinationInfo.java?rev=1071259&r1=1071258&r2=1071259&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/DestinationInfo.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/DestinationInfo.java Wed Feb 16 14:08:48 2011
@@ -24,7 +24,7 @@ import org.apache.activemq.state.Command
  * Used to create and destroy destinations on the broker.
  * 
  * @openwire:marshaller code="8"
- * @version $Revision: 1.9 $
+ * 
  */
 public class DestinationInfo extends BaseCommand {
 

Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/DiscoveryEvent.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/DiscoveryEvent.java?rev=1071259&r1=1071258&r2=1071259&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/DiscoveryEvent.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/DiscoveryEvent.java Wed Feb 16 14:08:48 2011
@@ -20,7 +20,7 @@ package org.apache.activemq.command;
  * Represents a discovery event containing the details of the service
  * 
  * @openwire:marshaller code="40"
- * @version $Revision:$
+ * 
  */
 public class DiscoveryEvent implements DataStructure {
 

Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ExceptionResponse.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ExceptionResponse.java?rev=1071259&r1=1071258&r2=1071259&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ExceptionResponse.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ExceptionResponse.java Wed Feb 16 14:08:48 2011
@@ -18,7 +18,7 @@ package org.apache.activemq.command;
 
 /**
  * @openwire:marshaller code="31"
- * @version $Revision: 1.4 $
+ * 
  */
 public class ExceptionResponse extends Response {
 

Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/FlushCommand.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/FlushCommand.java?rev=1071259&r1=1071258&r2=1071259&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/FlushCommand.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/FlushCommand.java Wed Feb 16 14:08:48 2011
@@ -22,7 +22,7 @@ import org.apache.activemq.state.Command
  * An indication to the transport layer that a flush is required.
  * 
  * @openwire:marshaller code="15"
- * @version $Revision$
+ * 
  */
 public class FlushCommand extends BaseCommand {
 

Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/IntegerResponse.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/IntegerResponse.java?rev=1071259&r1=1071258&r2=1071259&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/IntegerResponse.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/IntegerResponse.java Wed Feb 16 14:08:48 2011
@@ -18,7 +18,7 @@ package org.apache.activemq.command;
 
 /**
  * @openwire:marshaller code="34"
- * @version $Revision$
+ * 
  */
 public class IntegerResponse extends Response {
 

Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/JournalQueueAck.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/JournalQueueAck.java?rev=1071259&r1=1071258&r2=1071259&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/JournalQueueAck.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/JournalQueueAck.java Wed Feb 16 14:08:48 2011
@@ -20,7 +20,7 @@ import org.apache.activemq.util.Introspe
 
 /**
  * @openwire:marshaller code="52"
- * @version $Revision$
+ * 
  */
 public class JournalQueueAck implements DataStructure {
 

Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/JournalTopicAck.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/JournalTopicAck.java?rev=1071259&r1=1071258&r2=1071259&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/JournalTopicAck.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/JournalTopicAck.java Wed Feb 16 14:08:48 2011
@@ -20,7 +20,7 @@ import org.apache.activemq.util.Introspe
 
 /**
  * @openwire:marshaller code="50"
- * @version $Revision$
+ * 
  */
 public class JournalTopicAck implements DataStructure {
 

Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/JournalTrace.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/JournalTrace.java?rev=1071259&r1=1071258&r2=1071259&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/JournalTrace.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/JournalTrace.java Wed Feb 16 14:08:48 2011
@@ -20,7 +20,7 @@ import org.apache.activemq.util.Introspe
 
 /**
  * @openwire:marshaller code="53"
- * @version $Revision: 1.6 $
+ * 
  */
 public class JournalTrace implements DataStructure {
 

Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/KeepAliveInfo.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/KeepAliveInfo.java?rev=1071259&r1=1071258&r2=1071259&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/KeepAliveInfo.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/KeepAliveInfo.java Wed Feb 16 14:08:48 2011
@@ -21,7 +21,7 @@ import org.apache.activemq.util.Introspe
 
 /**
  * @openwire:marshaller code="10"
- * @version $Revision$
+ * 
  */
 public class KeepAliveInfo extends BaseCommand {
 

Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/LocalTransactionId.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/LocalTransactionId.java?rev=1071259&r1=1071258&r2=1071259&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/LocalTransactionId.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/LocalTransactionId.java Wed Feb 16 14:08:48 2011
@@ -18,7 +18,7 @@ package org.apache.activemq.command;
 
 /**
  * @openwire:marshaller code="111"
- * @version $Revision: 1.11 $
+ * 
  */
 public class LocalTransactionId extends TransactionId implements Comparable<LocalTransactionId> {
 

Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/Message.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/Message.java?rev=1071259&r1=1071258&r2=1071259&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/Message.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/Message.java Wed Feb 16 14:08:48 2011
@@ -38,7 +38,7 @@ import org.apache.activemq.wireformat.Wi
  * Represents an ActiveMQ message
  * 
  * @openwire:marshaller
- * @version $Revision$
+ * 
  */
 public abstract class Message extends BaseCommand implements MarshallAware, MessageReference {
 

Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/MessageAck.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/MessageAck.java?rev=1071259&r1=1071258&r2=1071259&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/MessageAck.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/MessageAck.java Wed Feb 16 14:08:48 2011
@@ -20,7 +20,7 @@ import org.apache.activemq.state.Command
 
 /**
  * @openwire:marshaller code="22"
- * @version $Revision: 1.11 $
+ * 
  */
 public class MessageAck extends BaseCommand {
 

Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/MessageDispatch.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/MessageDispatch.java?rev=1071259&r1=1071258&r2=1071259&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/MessageDispatch.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/MessageDispatch.java Wed Feb 16 14:08:48 2011
@@ -21,7 +21,7 @@ import org.apache.activemq.state.Command
 /**
  * 
  * @openwire:marshaller code="21"
- * @version $Revision$
+ * 
  */
 public class MessageDispatch extends BaseCommand {
 

Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/MessageDispatchNotification.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/MessageDispatchNotification.java?rev=1071259&r1=1071258&r2=1071259&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/MessageDispatchNotification.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/MessageDispatchNotification.java Wed Feb 16 14:08:48 2011
@@ -20,7 +20,7 @@ import org.apache.activemq.state.Command
 
 /**
  * @openwire:marshaller code="90"
- * @version $Revision$
+ * 
  */
 public class MessageDispatchNotification extends BaseCommand {
 

Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/MessageId.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/MessageId.java?rev=1071259&r1=1071258&r2=1071259&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/MessageId.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/MessageId.java Wed Feb 16 14:08:48 2011
@@ -18,7 +18,7 @@ package org.apache.activemq.command;
 
 /**
  * @openwire:marshaller code="110"
- * @version $Revision: 1.12 $
+ * 
  */
 public class MessageId implements DataStructure, Comparable<MessageId> {
 

Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/NetworkBridgeFilter.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/NetworkBridgeFilter.java?rev=1071259&r1=1071258&r2=1071259&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/NetworkBridgeFilter.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/NetworkBridgeFilter.java Wed Feb 16 14:08:48 2011
@@ -29,7 +29,7 @@ import org.slf4j.LoggerFactory;
 
 /**
  * @openwire:marshaller code="91"
- * @version $Revision: 1.12 $
+ * 
  */
 public class NetworkBridgeFilter implements DataStructure, BooleanExpression {
 

Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ProducerAck.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ProducerAck.java?rev=1071259&r1=1071258&r2=1071259&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ProducerAck.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ProducerAck.java Wed Feb 16 14:08:48 2011
@@ -25,7 +25,7 @@ import org.apache.activemq.state.Command
  * broker.
  * 
  * @openwire:marshaller code="19" version="3"
- * @version $Revision: 1.11 $
+ * 
  */
 public class ProducerAck extends BaseCommand {
 

Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ProducerId.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ProducerId.java?rev=1071259&r1=1071258&r2=1071259&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ProducerId.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ProducerId.java Wed Feb 16 14:08:48 2011
@@ -18,7 +18,7 @@ package org.apache.activemq.command;
 
 /**
  * @openwire:marshaller code="123"
- * @version $Revision$
+ * 
  */
 public class ProducerId implements DataStructure {
 

Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ProducerInfo.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ProducerInfo.java?rev=1071259&r1=1071258&r2=1071259&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ProducerInfo.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ProducerInfo.java Wed Feb 16 14:08:48 2011
@@ -21,7 +21,7 @@ import org.apache.activemq.state.Command
 /**
  * 
  * @openwire:marshaller code="6"
- * @version $Revision: 1.13 $
+ * 
  */
 public class ProducerInfo extends BaseCommand {
 

Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/RemoveInfo.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/RemoveInfo.java?rev=1071259&r1=1071258&r2=1071259&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/RemoveInfo.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/RemoveInfo.java Wed Feb 16 14:08:48 2011
@@ -24,7 +24,7 @@ import org.apache.activemq.state.Command
  * Removes a consumer, producer, session or connection.
  * 
  * @openwire:marshaller code="12"
- * @version $Revision$
+ * 
  */
 public class RemoveInfo extends BaseCommand {
 

Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/RemoveSubscriptionInfo.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/RemoveSubscriptionInfo.java?rev=1071259&r1=1071258&r2=1071259&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/RemoveSubscriptionInfo.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/RemoveSubscriptionInfo.java Wed Feb 16 14:08:48 2011
@@ -20,7 +20,7 @@ import org.apache.activemq.state.Command
 
 /**
  * @openwire:marshaller code="9"
- * @version $Revision: 1.7 $
+ * 
  */
 public class RemoveSubscriptionInfo extends BaseCommand {
 

Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/Response.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/Response.java?rev=1071259&r1=1071258&r2=1071259&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/Response.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/Response.java Wed Feb 16 14:08:48 2011
@@ -20,7 +20,7 @@ import org.apache.activemq.state.Command
 
 /**
  * @openwire:marshaller code="30"
- * @version $Revision: 1.6 $
+ * 
  */
 public class Response extends BaseCommand {
 

Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/SessionId.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/SessionId.java?rev=1071259&r1=1071258&r2=1071259&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/SessionId.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/SessionId.java Wed Feb 16 14:08:48 2011
@@ -19,7 +19,7 @@ package org.apache.activemq.command;
 /**
  * 
  * @openwire:marshaller code="121"
- * @version $Revision$
+ * 
  */
 public class SessionId implements DataStructure {
 

Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/SessionInfo.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/SessionInfo.java?rev=1071259&r1=1071258&r2=1071259&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/SessionInfo.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/SessionInfo.java Wed Feb 16 14:08:48 2011
@@ -21,7 +21,7 @@ import org.apache.activemq.state.Command
 /**
  * 
  * @openwire:marshaller code="4"
- * @version $Revision: 1.13 $
+ * 
  */
 public class SessionInfo extends BaseCommand {
 

Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ShutdownInfo.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ShutdownInfo.java?rev=1071259&r1=1071258&r2=1071259&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ShutdownInfo.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ShutdownInfo.java Wed Feb 16 14:08:48 2011
@@ -21,7 +21,7 @@ import org.apache.activemq.state.Command
 /**
  * 
  * @openwire:marshaller code="11"
- * @version $Revision$
+ * 
  */
 public class ShutdownInfo extends BaseCommand {
 

Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/SubscriptionInfo.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/SubscriptionInfo.java?rev=1071259&r1=1071258&r2=1071259&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/SubscriptionInfo.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/SubscriptionInfo.java Wed Feb 16 14:08:48 2011
@@ -22,7 +22,7 @@ import org.apache.activemq.util.Introspe
  * Used to represent a durable subscription.
  * 
  * @openwire:marshaller code="55"
- * @version $Revision: 1.6 $
+ * 
  */
 public class SubscriptionInfo implements DataStructure {
 

Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/TransactionId.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/TransactionId.java?rev=1071259&r1=1071258&r2=1071259&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/TransactionId.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/TransactionId.java Wed Feb 16 14:08:48 2011
@@ -18,7 +18,7 @@ package org.apache.activemq.command;
 
 /**
  * @openwire:marshaller
- * @version $Revision: 1.6 $
+ * 
  */
 public abstract class TransactionId implements DataStructure {
 

Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/TransactionInfo.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/TransactionInfo.java?rev=1071259&r1=1071258&r2=1071259&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/TransactionInfo.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/TransactionInfo.java Wed Feb 16 14:08:48 2011
@@ -23,7 +23,7 @@ import org.apache.activemq.state.Command
 /**
  * 
  * @openwire:marshaller code="7"
- * @version $Revision: 1.10 $
+ * 
  */
 public class TransactionInfo extends BaseCommand {
 

Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/WireFormatInfo.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/WireFormatInfo.java?rev=1071259&r1=1071258&r2=1071259&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/WireFormatInfo.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/WireFormatInfo.java Wed Feb 16 14:08:48 2011
@@ -32,7 +32,7 @@ import org.apache.activemq.wireformat.Wi
 
 /**
  * @openwire:marshaller code="1"
- * @version $Revision$
+ * 
  */
 public class WireFormatInfo implements Command, MarshallAware {
 

Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/XATransactionId.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/XATransactionId.java?rev=1071259&r1=1071258&r2=1071259&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/XATransactionId.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/XATransactionId.java Wed Feb 16 14:08:48 2011
@@ -22,7 +22,7 @@ import org.apache.activemq.util.HexSuppo
 
 /**
  * @openwire:marshaller code="112"
- * @version $Revision: 1.6 $
+ * 
  */
 public class XATransactionId extends TransactionId implements Xid, Comparable {
 

Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/filter/ArithmeticExpression.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/filter/ArithmeticExpression.java?rev=1071259&r1=1071258&r2=1071259&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/filter/ArithmeticExpression.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/filter/ArithmeticExpression.java Wed Feb 16 14:08:48 2011
@@ -21,7 +21,7 @@ import javax.jms.JMSException;
 /**
  * An expression which performs an operation on two expression values
  * 
- * @version $Revision: 1.2 $
+ * 
  */
 public abstract class ArithmeticExpression extends BinaryExpression {
 

Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/filter/BinaryExpression.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/filter/BinaryExpression.java?rev=1071259&r1=1071258&r2=1071259&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/filter/BinaryExpression.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/filter/BinaryExpression.java Wed Feb 16 14:08:48 2011
@@ -21,7 +21,7 @@ package org.apache.activemq.filter;
 /**
  * An expression which performs an operation on two expression values.
  * 
- * @version $Revision: 1.2 $
+ * 
  */
 public abstract class BinaryExpression implements Expression {
     protected Expression left;



Mime
View raw message