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 [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/...
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;