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 14:59:17 UTC
svn commit: r1071256 [2/8] - in /activemq/trunk:
activemq-camel/src/main/java/org/apache/activemq/camel/component/
activemq-camel/src/main/java/org/apache/activemq/camel/converter/
activemq-camel/src/test/java/org/apache/activemq/camel/ activemq-camel/...
Modified: activemq/trunk/activemq-camel/src/test/java/org/apache/activemq/camel/component/JournalRoutePerformance.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-camel/src/test/java/org/apache/activemq/camel/component/JournalRoutePerformance.java?rev=1071256&r1=1071255&r2=1071256&view=diff
==============================================================================
--- activemq/trunk/activemq-camel/src/test/java/org/apache/activemq/camel/component/JournalRoutePerformance.java (original)
+++ activemq/trunk/activemq-camel/src/test/java/org/apache/activemq/camel/component/JournalRoutePerformance.java Wed Feb 16 13:58:54 2011
@@ -28,7 +28,7 @@ import org.apache.camel.builder.RouteBui
* Used to get an idea of what kind of performance can be expected from
* the journal.
*
- * @version $Revision$
+ *
*/
public class JournalRoutePerformance extends ContextTestSupport {
Modified: activemq/trunk/activemq-camel/src/test/java/org/apache/activemq/camel/component/JournalRouteTest.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-camel/src/test/java/org/apache/activemq/camel/component/JournalRouteTest.java?rev=1071256&r1=1071255&r2=1071256&view=diff
==============================================================================
--- activemq/trunk/activemq-camel/src/test/java/org/apache/activemq/camel/component/JournalRouteTest.java (original)
+++ activemq/trunk/activemq-camel/src/test/java/org/apache/activemq/camel/component/JournalRouteTest.java Wed Feb 16 13:58:54 2011
@@ -28,7 +28,7 @@ import org.apache.camel.component.mock.M
import org.apache.camel.impl.DefaultCamelContext;
/**
- * @version $Revision$
+ *
*/
public class JournalRouteTest extends ContextTestSupport {
Modified: activemq/trunk/activemq-camel/src/test/java/org/apache/activemq/camel/converter/InvokeMessageListenerTest.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-camel/src/test/java/org/apache/activemq/camel/converter/InvokeMessageListenerTest.java?rev=1071256&r1=1071255&r2=1071256&view=diff
==============================================================================
--- activemq/trunk/activemq-camel/src/test/java/org/apache/activemq/camel/converter/InvokeMessageListenerTest.java (original)
+++ activemq/trunk/activemq-camel/src/test/java/org/apache/activemq/camel/converter/InvokeMessageListenerTest.java Wed Feb 16 13:58:54 2011
@@ -29,7 +29,7 @@ import org.apache.camel.builder.RouteBui
import org.apache.camel.component.mock.MockEndpoint;
/**
- * @version $Revision$
+ *
*/
public class InvokeMessageListenerTest extends ContextTestSupport { protected MockEndpoint resultEndpoint;
protected String startEndpointUri = "activemq:queue:test.a";
Modified: activemq/trunk/activemq-console/src/main/java/org/apache/activemq/console/util/SimpleConsole.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-console/src/main/java/org/apache/activemq/console/util/SimpleConsole.java?rev=1071256&r1=1071255&r2=1071256&view=diff
==============================================================================
--- activemq/trunk/activemq-console/src/main/java/org/apache/activemq/console/util/SimpleConsole.java (original)
+++ activemq/trunk/activemq-console/src/main/java/org/apache/activemq/console/util/SimpleConsole.java Wed Feb 16 13:58:54 2011
@@ -25,7 +25,7 @@ import org.apache.activemq.broker.util.C
* A simple interactive console which can be used to communicate with a running
* broker assuming that the classpath is fully setup
*
- * @version $Revision$
+ *
*/
public final class SimpleConsole {
Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/ActiveMQMessageAuditNoSync.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/ActiveMQMessageAuditNoSync.java?rev=1071256&r1=1071255&r2=1071256&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/ActiveMQMessageAuditNoSync.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/ActiveMQMessageAuditNoSync.java Wed Feb 16 13:58:54 2011
@@ -31,7 +31,7 @@ import org.apache.activemq.util.LRUCache
/**
* Provides basic audit functions for Messages without sync
*
- * @version $Revision$
+ *
*/
public class ActiveMQMessageAuditNoSync implements Serializable {
Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/ActiveMQXAConnectionFactory.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/ActiveMQXAConnectionFactory.java?rev=1071256&r1=1071255&r2=1071256&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/ActiveMQXAConnectionFactory.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/ActiveMQXAConnectionFactory.java Wed Feb 16 13:58:54 2011
@@ -32,7 +32,7 @@ import org.apache.activemq.transport.Tra
/**
* A factory of {@link XAConnection} instances
*
- * @version $Revision$
+ *
*/
public class ActiveMQXAConnectionFactory extends ActiveMQConnectionFactory implements XAConnectionFactory, XAQueueConnectionFactory, XATopicConnectionFactory {
Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/MessageTransformer.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/MessageTransformer.java?rev=1071256&r1=1071255&r2=1071256&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/MessageTransformer.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/MessageTransformer.java Wed Feb 16 13:58:54 2011
@@ -26,7 +26,7 @@ import javax.jms.Session;
* A plugin strategy for transforming a message before it is sent by the JMS client or before it is
* dispatched to the JMS consumer
*
- * @version $Revision$
+ *
*/
public interface MessageTransformer {
Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/MessageTransformerSupport.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/MessageTransformerSupport.java?rev=1071256&r1=1071255&r2=1071256&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/MessageTransformerSupport.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/MessageTransformerSupport.java Wed Feb 16 13:58:54 2011
@@ -22,7 +22,7 @@ import javax.jms.Message;
/**
* A useful base class for message transformers.
*
- * @version $Revision$
+ *
*/
public abstract class MessageTransformerSupport implements MessageTransformer {
Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/advisory/ConsumerEvent.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/advisory/ConsumerEvent.java?rev=1071256&r1=1071255&r2=1071256&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/advisory/ConsumerEvent.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/advisory/ConsumerEvent.java Wed Feb 16 13:58:54 2011
@@ -25,7 +25,7 @@ import org.apache.activemq.command.Consu
/**
* An event when the number of consumers on a given destination changes.
*
- * @version $Revision$
+ *
*/
public abstract class ConsumerEvent extends EventObject {
private static final long serialVersionUID = 2442156576867593780L;
Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/advisory/ConsumerEventSource.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/advisory/ConsumerEventSource.java?rev=1071256&r1=1071255&r2=1071256&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/advisory/ConsumerEventSource.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/advisory/ConsumerEventSource.java Wed Feb 16 13:58:54 2011
@@ -41,7 +41,7 @@ import org.slf4j.LoggerFactory;
* An object which can be used to listen to the number of active consumers
* available on a given destination.
*
- * @version $Revision$
+ *
*/
public class ConsumerEventSource implements Service, MessageListener {
private static final Logger LOG = LoggerFactory.getLogger(ConsumerEventSource.class);
Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/advisory/ConsumerListener.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/advisory/ConsumerListener.java?rev=1071256&r1=1071255&r2=1071256&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/advisory/ConsumerListener.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/advisory/ConsumerListener.java Wed Feb 16 13:58:54 2011
@@ -19,7 +19,7 @@ package org.apache.activemq.advisory;
/**
* Listen to the changes in the number of active consumers available for a given destination.
*
- * @version $Revision$
+ *
*/
public interface ConsumerListener {
Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/advisory/ConsumerStartedEvent.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/advisory/ConsumerStartedEvent.java?rev=1071256&r1=1071255&r2=1071256&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/advisory/ConsumerStartedEvent.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/advisory/ConsumerStartedEvent.java Wed Feb 16 13:58:54 2011
@@ -22,7 +22,7 @@ import org.apache.activemq.command.Consu
/**
* An event when a new consumer has started.
*
- * @version $Revision$
+ *
*/
public class ConsumerStartedEvent extends ConsumerEvent {
Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/advisory/ConsumerStoppedEvent.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/advisory/ConsumerStoppedEvent.java?rev=1071256&r1=1071255&r2=1071256&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/advisory/ConsumerStoppedEvent.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/advisory/ConsumerStoppedEvent.java Wed Feb 16 13:58:54 2011
@@ -22,7 +22,7 @@ import org.apache.activemq.command.Consu
/**
* An event generated when a consumer stops.
*
- * @version $Revision$
+ *
*/
public class ConsumerStoppedEvent extends ConsumerEvent {
Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/advisory/DestinationEvent.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/advisory/DestinationEvent.java?rev=1071256&r1=1071255&r2=1071256&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/advisory/DestinationEvent.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/advisory/DestinationEvent.java Wed Feb 16 13:58:54 2011
@@ -27,7 +27,7 @@ import org.apache.activemq.command.Activ
/**
* An event caused when a destination is created or deleted
*
- * @version $Revision$
+ *
*/
public class DestinationEvent extends EventObject {
private static final long serialVersionUID = 2442156576867593780L;
Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/advisory/DestinationListener.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/advisory/DestinationListener.java?rev=1071256&r1=1071255&r2=1071256&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/advisory/DestinationListener.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/advisory/DestinationListener.java Wed Feb 16 13:58:54 2011
@@ -19,7 +19,7 @@ package org.apache.activemq.advisory;
/**
* Listen to the changes in destinations being created or destroyed
*
- * @version $Revision$
+ *
*/
public interface DestinationListener {
void onDestinationEvent(DestinationEvent event);
Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/advisory/DestinationSource.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/advisory/DestinationSource.java?rev=1071256&r1=1071255&r2=1071256&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/advisory/DestinationSource.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/advisory/DestinationSource.java Wed Feb 16 13:58:54 2011
@@ -42,7 +42,7 @@ import org.slf4j.LoggerFactory;
* A helper class which keeps track of the Destinations available in a broker and allows you to listen to them
* being created or deleted.
*
- * @version $Revision$
+ *
*/
public class DestinationSource implements MessageListener {
private static final Logger LOG = LoggerFactory.getLogger(ConsumerEventSource.class);
Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/advisory/ProducerEvent.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/advisory/ProducerEvent.java?rev=1071256&r1=1071255&r2=1071256&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/advisory/ProducerEvent.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/advisory/ProducerEvent.java Wed Feb 16 13:58:54 2011
@@ -25,7 +25,7 @@ import org.apache.activemq.command.Produ
/**
* An event when the number of producers on a given destination changes.
*
- * @version $Revision: 359679 $
+ *
*/
public abstract class ProducerEvent extends EventObject {
private static final long serialVersionUID = 2442156576867593780L;
Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/advisory/ProducerEventSource.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/advisory/ProducerEventSource.java?rev=1071256&r1=1071255&r2=1071256&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/advisory/ProducerEventSource.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/advisory/ProducerEventSource.java Wed Feb 16 13:58:54 2011
@@ -41,7 +41,7 @@ import org.slf4j.LoggerFactory;
* An object which can be used to listen to the number of active consumers
* available on a given destination.
*
- * @version $Revision: 359679 $
+ *
*/
public class ProducerEventSource implements Service, MessageListener {
private static final Logger LOG = LoggerFactory.getLogger(ProducerEventSource.class);
Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/advisory/ProducerListener.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/advisory/ProducerListener.java?rev=1071256&r1=1071255&r2=1071256&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/advisory/ProducerListener.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/advisory/ProducerListener.java Wed Feb 16 13:58:54 2011
@@ -19,7 +19,7 @@ package org.apache.activemq.advisory;
/**
* Listen to the changes in the number of active consumers available for a given destination.
*
- * @version $Revision: 359679 $
+ *
*/
public interface ProducerListener {
Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/advisory/ProducerStartedEvent.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/advisory/ProducerStartedEvent.java?rev=1071256&r1=1071255&r2=1071256&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/advisory/ProducerStartedEvent.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/advisory/ProducerStartedEvent.java Wed Feb 16 13:58:54 2011
@@ -22,7 +22,7 @@ import org.apache.activemq.command.Produ
/**
* An event when a new consumer has started.
*
- * @version $Revision: 359679 $
+ *
*/
public class ProducerStartedEvent extends ProducerEvent {
Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/advisory/ProducerStoppedEvent.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/advisory/ProducerStoppedEvent.java?rev=1071256&r1=1071255&r2=1071256&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/advisory/ProducerStoppedEvent.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/advisory/ProducerStoppedEvent.java Wed Feb 16 13:58:54 2011
@@ -22,7 +22,7 @@ import org.apache.activemq.command.Produ
/**
* An event generated when a consumer stops.
*
- * @version $Revision: 359679 $
+ *
*/
public class ProducerStoppedEvent extends ProducerEvent {
Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/BrokerFactoryHandler.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/BrokerFactoryHandler.java?rev=1071256&r1=1071255&r2=1071256&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/BrokerFactoryHandler.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/BrokerFactoryHandler.java Wed Feb 16 13:58:54 2011
@@ -21,7 +21,7 @@ import java.net.URI;
/**
* Represents the interface used to create a broker from a URI scheme.
*
- * @version $Revision$
+ *
*/
public interface BrokerFactoryHandler {
BrokerService createBroker(URI brokerURI) throws Exception;
Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/BrokerPlugin.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/BrokerPlugin.java?rev=1071256&r1=1071255&r2=1071256&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/BrokerPlugin.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/BrokerPlugin.java Wed Feb 16 13:58:54 2011
@@ -19,7 +19,7 @@ package org.apache.activemq.broker;
/**
* Represents a plugin into a Broker
*
- * @version $Revision$
+ *
*/
public interface BrokerPlugin {
Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/BrokerPluginSupport.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/BrokerPluginSupport.java?rev=1071256&r1=1071255&r2=1071256&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/BrokerPluginSupport.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/BrokerPluginSupport.java Wed Feb 16 13:58:54 2011
@@ -22,7 +22,7 @@ import org.slf4j.LoggerFactory;
/**
* A useful base class for implementing broker plugins.
*
- * @version $Revision$
+ *
*/
public abstract class BrokerPluginSupport extends MutableBrokerFilter implements BrokerPlugin {
private static final Logger LOG = LoggerFactory.getLogger(BrokerPluginSupport.class);
Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/DestinationAlreadyExistsException.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/DestinationAlreadyExistsException.java?rev=1071256&r1=1071255&r2=1071256&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/DestinationAlreadyExistsException.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/DestinationAlreadyExistsException.java Wed Feb 16 13:58:54 2011
@@ -23,7 +23,7 @@ import org.apache.activemq.command.Activ
/**
* An exception thrown if a destination is attempted to be created when it already exists.
*
- * @version $Revision$
+ *
*/
public class DestinationAlreadyExistsException extends JMSException {
private final ActiveMQDestination destination;
Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/PropertiesBrokerFactory.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/PropertiesBrokerFactory.java?rev=1071256&r1=1071255&r2=1071256&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/PropertiesBrokerFactory.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/PropertiesBrokerFactory.java Wed Feb 16 13:58:54 2011
@@ -32,7 +32,7 @@ import org.apache.activemq.util.Introspe
* A {@link BrokerFactoryHandler} which uses a properties file to configure the
* broker's various policies.
*
- * @version $Revision$
+ *
*/
public class PropertiesBrokerFactory implements BrokerFactoryHandler {
Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/jmx/TopicSubscriptionView.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/jmx/TopicSubscriptionView.java?rev=1071256&r1=1071255&r2=1071256&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/jmx/TopicSubscriptionView.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/jmx/TopicSubscriptionView.java Wed Feb 16 13:58:54 2011
@@ -21,7 +21,7 @@ import org.apache.activemq.broker.region
/**
*
- * @version $Revision$
+ *
*/
public class TopicSubscriptionView extends SubscriptionView implements TopicSubscriptionViewMBean {
Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/jmx/TopicSubscriptionViewMBean.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/jmx/TopicSubscriptionViewMBean.java?rev=1071256&r1=1071255&r2=1071256&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/jmx/TopicSubscriptionViewMBean.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/jmx/TopicSubscriptionViewMBean.java Wed Feb 16 13:58:54 2011
@@ -18,7 +18,7 @@ package org.apache.activemq.broker.jmx;
/**
*
- * @version $Revision$
+ *
*/
public interface TopicSubscriptionViewMBean extends SubscriptionViewMBean {
Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/CompositeDestinationInterceptor.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/CompositeDestinationInterceptor.java?rev=1071256&r1=1071255&r2=1071256&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/CompositeDestinationInterceptor.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/CompositeDestinationInterceptor.java Wed Feb 16 13:58:54 2011
@@ -19,7 +19,7 @@ package org.apache.activemq.broker.regio
/**
* Represents a Composite Pattern of a {@link DestinationInterceptor}
*
- * @version $Revision$
+ *
*/
public class CompositeDestinationInterceptor implements DestinationInterceptor {
Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/ConnectionStatistics.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/ConnectionStatistics.java?rev=1071256&r1=1071255&r2=1071256&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/ConnectionStatistics.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/ConnectionStatistics.java Wed Feb 16 13:58:54 2011
@@ -23,7 +23,7 @@ import org.apache.activemq.management.St
/**
* The J2EE Statistics for the Connection.
*
- * @version $Revision$
+ *
*/
public class ConnectionStatistics extends StatsImpl {
Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/ConnectorStatistics.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/ConnectorStatistics.java?rev=1071256&r1=1071255&r2=1071256&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/ConnectorStatistics.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/ConnectorStatistics.java Wed Feb 16 13:58:54 2011
@@ -24,7 +24,7 @@ import org.apache.activemq.management.St
/**
* The J2EE Statistics for the a Destination.
*
- * @version $Revision$
+ *
*/
public class ConnectorStatistics extends StatsImpl {
Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/DestinationFactory.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/DestinationFactory.java?rev=1071256&r1=1071255&r2=1071256&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/DestinationFactory.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/DestinationFactory.java Wed Feb 16 13:58:54 2011
@@ -28,7 +28,7 @@ import org.apache.activemq.command.Subsc
* Used to create Destinations. One instance of DestinationFactory is used per BrokerService.
*
* @author fateev@amazon.com
- * @version $Revision$
+ *
*/
public abstract class DestinationFactory {
Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/DestinationFactoryImpl.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/DestinationFactoryImpl.java?rev=1071256&r1=1071255&r2=1071256&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/DestinationFactoryImpl.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/DestinationFactoryImpl.java Wed Feb 16 13:58:54 2011
@@ -37,7 +37,7 @@ import org.apache.activemq.thread.TaskRu
* {@link org.apache.activemq.broker.region.Destination}.
*
* @author fateev@amazon.com
- * @version $Revision$
+ *
*/
public class DestinationFactoryImpl extends DestinationFactory {
Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/DestinationFilter.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/DestinationFilter.java?rev=1071256&r1=1071255&r2=1071256&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/DestinationFilter.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/DestinationFilter.java Wed Feb 16 13:58:54 2011
@@ -35,7 +35,7 @@ import org.apache.activemq.usage.Usage;
/**
*
- * @version $Revision$
+ *
*/
public class DestinationFilter implements Destination {
Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/DestinationInterceptor.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/DestinationInterceptor.java?rev=1071256&r1=1071255&r2=1071256&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/DestinationInterceptor.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/DestinationInterceptor.java Wed Feb 16 13:58:54 2011
@@ -20,7 +20,7 @@ package org.apache.activemq.broker.regio
/**
* Represents an interceptor on destination instances.
*
- * @version $Revision$
+ *
*/
public interface DestinationInterceptor {
Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/MessageReferenceFilter.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/MessageReferenceFilter.java?rev=1071256&r1=1071255&r2=1071256&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/MessageReferenceFilter.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/MessageReferenceFilter.java Wed Feb 16 13:58:54 2011
@@ -23,7 +23,7 @@ import org.apache.activemq.broker.Connec
/**
* Represents a filter on message references
*
- * @version $Revision$
+ *
*/
public interface MessageReferenceFilter {
Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/QueueMessageReference.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/QueueMessageReference.java?rev=1071256&r1=1071255&r2=1071256&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/QueueMessageReference.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/QueueMessageReference.java Wed Feb 16 13:58:54 2011
@@ -20,7 +20,7 @@ package org.apache.activemq.broker.regio
* Queue specific MessageReference.
*
* @author fateev@amazon.com
- * @version $Revision$
+ *
*/
public interface QueueMessageReference extends MessageReference {
Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/cursors/AbstractPendingMessageCursor.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/cursors/AbstractPendingMessageCursor.java?rev=1071256&r1=1071255&r2=1071256&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/cursors/AbstractPendingMessageCursor.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/cursors/AbstractPendingMessageCursor.java Wed Feb 16 13:58:54 2011
@@ -34,7 +34,7 @@ import org.apache.activemq.usage.SystemU
* Abstract method holder for pending message (messages awaiting disptach to a
* consumer) cursor
*
- * @version $Revision$
+ *
*/
public abstract class AbstractPendingMessageCursor implements PendingMessageCursor {
protected int memoryUsageHighWaterMark = 70;
Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/cursors/FilePendingMessageCursor.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/cursors/FilePendingMessageCursor.java?rev=1071256&r1=1071255&r2=1071256&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/cursors/FilePendingMessageCursor.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/cursors/FilePendingMessageCursor.java Wed Feb 16 13:58:54 2011
@@ -44,7 +44,7 @@ import org.apache.kahadb.util.ByteSequen
* persist pending messages pending message (messages awaiting dispatch to a
* consumer) cursor
*
- * @version $Revision$
+ *
*/
public class FilePendingMessageCursor extends AbstractPendingMessageCursor implements UsageListener {
static final Logger LOG = LoggerFactory.getLogger(FilePendingMessageCursor.class);
Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/cursors/PendingMessageCursor.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/cursors/PendingMessageCursor.java?rev=1071256&r1=1071255&r2=1071256&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/cursors/PendingMessageCursor.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/cursors/PendingMessageCursor.java Wed Feb 16 13:58:54 2011
@@ -31,7 +31,7 @@ import org.apache.activemq.usage.SystemU
* Interface to pending message (messages awaiting disptach to a consumer)
* cursor
*
- * @version $Revision$
+ *
*/
public interface PendingMessageCursor extends Service {
Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/cursors/QueueStorePrefetch.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/cursors/QueueStorePrefetch.java?rev=1071256&r1=1071255&r2=1071256&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/cursors/QueueStorePrefetch.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/cursors/QueueStorePrefetch.java Wed Feb 16 13:58:54 2011
@@ -28,7 +28,7 @@ import org.slf4j.LoggerFactory;
* persist pending messages pending message (messages awaiting dispatch to a
* consumer) cursor
*
- * @version $Revision: 474985 $
+ *
*/
class QueueStorePrefetch extends AbstractStoreCursor {
private static final Logger LOG = LoggerFactory.getLogger(QueueStorePrefetch.class);
Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/cursors/StoreDurableSubscriberCursor.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/cursors/StoreDurableSubscriberCursor.java?rev=1071256&r1=1071255&r2=1071256&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/cursors/StoreDurableSubscriberCursor.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/cursors/StoreDurableSubscriberCursor.java Wed Feb 16 13:58:54 2011
@@ -37,7 +37,7 @@ import org.slf4j.LoggerFactory;
* persist pending messages pending message (messages awaiting dispatch to a
* consumer) cursor
*
- * @version $Revision$
+ *
*/
public class StoreDurableSubscriberCursor extends AbstractPendingMessageCursor {
Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/cursors/StoreQueueCursor.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/cursors/StoreQueueCursor.java?rev=1071256&r1=1071255&r2=1071256&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/cursors/StoreQueueCursor.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/cursors/StoreQueueCursor.java Wed Feb 16 13:58:54 2011
@@ -27,7 +27,7 @@ import org.slf4j.LoggerFactory;
/**
* Store based Cursor for Queues
*
- * @version $Revision: 474985 $
+ *
*/
public class StoreQueueCursor extends AbstractPendingMessageCursor {
Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/cursors/TopicStorePrefetch.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/cursors/TopicStorePrefetch.java?rev=1071256&r1=1071255&r2=1071256&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/cursors/TopicStorePrefetch.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/cursors/TopicStorePrefetch.java Wed Feb 16 13:58:54 2011
@@ -30,7 +30,7 @@ import org.slf4j.LoggerFactory;
* persist pendingCount messages pendingCount message (messages awaiting disptach
* to a consumer) cursor
*
- * @version $Revision$
+ *
*/
class TopicStorePrefetch extends AbstractStoreCursor {
private static final Logger LOG = LoggerFactory.getLogger(TopicStorePrefetch.class);
Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/cursors/VMPendingMessageCursor.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/cursors/VMPendingMessageCursor.java?rev=1071256&r1=1071255&r2=1071256&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/cursors/VMPendingMessageCursor.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/cursors/VMPendingMessageCursor.java Wed Feb 16 13:58:54 2011
@@ -29,7 +29,7 @@ import org.apache.activemq.broker.region
* hold pending messages in a linked list (messages awaiting disptach to a
* consumer) cursor
*
- * @version $Revision$
+ *
*/
public class VMPendingMessageCursor extends AbstractPendingMessageCursor {
private final PendingList list;
Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/group/EmptyMessageGroupSet.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/group/EmptyMessageGroupSet.java?rev=1071256&r1=1071255&r2=1071256&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/group/EmptyMessageGroupSet.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/group/EmptyMessageGroupSet.java Wed Feb 16 13:58:54 2011
@@ -19,7 +19,7 @@ package org.apache.activemq.broker.regio
/**
* Represents an empty {@link MessageGroupSet}
*
- * @version $Revision$
+ *
*/
public class EmptyMessageGroupSet implements MessageGroupSet {
Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/group/MessageGroupHashBucket.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/group/MessageGroupHashBucket.java?rev=1071256&r1=1071255&r2=1071256&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/group/MessageGroupHashBucket.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/group/MessageGroupHashBucket.java Wed Feb 16 13:58:54 2011
@@ -21,7 +21,7 @@ import org.apache.activemq.command.Consu
/**
* Uses hash-code buckets to associate consumers with sets of message group IDs.
*
- * @version $Revision$
+ *
*/
public class MessageGroupHashBucket implements MessageGroupMap {
Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/group/MessageGroupHashBucketFactory.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/group/MessageGroupHashBucketFactory.java?rev=1071256&r1=1071255&r2=1071256&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/group/MessageGroupHashBucketFactory.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/group/MessageGroupHashBucketFactory.java Wed Feb 16 13:58:54 2011
@@ -24,7 +24,7 @@ package org.apache.activemq.broker.regio
*
* @org.apache.xbean.XBean
*
- * @version $Revision$
+ *
*/
public class MessageGroupHashBucketFactory implements MessageGroupMapFactory {
Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/group/MessageGroupMap.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/group/MessageGroupMap.java?rev=1071256&r1=1071255&r2=1071256&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/group/MessageGroupMap.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/group/MessageGroupMap.java Wed Feb 16 13:58:54 2011
@@ -21,7 +21,7 @@ import org.apache.activemq.command.Consu
/**
* Represents a map of JMSXGroupID values to consumer IDs
*
- * @version $Revision$
+ *
*/
public interface MessageGroupMap {
Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/group/MessageGroupMapFactory.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/group/MessageGroupMapFactory.java?rev=1071256&r1=1071255&r2=1071256&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/group/MessageGroupMapFactory.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/group/MessageGroupMapFactory.java Wed Feb 16 13:58:54 2011
@@ -20,7 +20,7 @@ package org.apache.activemq.broker.regio
* Represents a factory used to create new instances of {@link MessageGroupMap}
* for a destination.
*
- * @version $Revision$
+ *
*/
public interface MessageGroupMapFactory {
Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/group/MessageGroupSet.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/group/MessageGroupSet.java?rev=1071256&r1=1071255&r2=1071256&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/group/MessageGroupSet.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/group/MessageGroupSet.java Wed Feb 16 13:58:54 2011
@@ -19,7 +19,7 @@ package org.apache.activemq.broker.regio
/**
* Represents a set of Message Group IDs
*
- * @version $Revision$
+ *
*/
public interface MessageGroupSet {
Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/group/SimpleMessageGroupMap.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/group/SimpleMessageGroupMap.java?rev=1071256&r1=1071255&r2=1071256&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/group/SimpleMessageGroupMap.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/group/SimpleMessageGroupMap.java Wed Feb 16 13:58:54 2011
@@ -27,7 +27,7 @@ import org.apache.activemq.command.Consu
* which can become a memory leak if clients die before they complete a message
* group.
*
- * @version $Revision$
+ *
*/
public class SimpleMessageGroupMap implements MessageGroupMap {
private Map<String, ConsumerId> map = new ConcurrentHashMap<String, ConsumerId>();
Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/group/SimpleMessageGroupMapFactory.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/group/SimpleMessageGroupMapFactory.java?rev=1071256&r1=1071255&r2=1071256&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/group/SimpleMessageGroupMapFactory.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/group/SimpleMessageGroupMapFactory.java Wed Feb 16 13:58:54 2011
@@ -22,7 +22,7 @@ package org.apache.activemq.broker.regio
*
* @org.apache.xbean.XBean
*
- * @version $Revision$
+ *
*/
public class SimpleMessageGroupMapFactory implements MessageGroupMapFactory {
Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/group/SimpleMessageGroupSet.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/group/SimpleMessageGroupSet.java?rev=1071256&r1=1071255&r2=1071256&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/group/SimpleMessageGroupSet.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/group/SimpleMessageGroupSet.java Wed Feb 16 13:58:54 2011
@@ -22,7 +22,7 @@ import java.util.Set;
/**
* A simple implementation which just uses a {@link Set}
*
- * @version $Revision$
+ *
*/
public class SimpleMessageGroupSet implements MessageGroupSet {
Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/AbstractDeadLetterStrategy.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/AbstractDeadLetterStrategy.java?rev=1071256&r1=1071255&r2=1071256&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/AbstractDeadLetterStrategy.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/AbstractDeadLetterStrategy.java Wed Feb 16 13:58:54 2011
@@ -25,7 +25,7 @@ import org.slf4j.LoggerFactory;
* A strategy for choosing which destination is used for dead letter queue
* messages.
*
- * @version $Revision: 426366 $
+ *
*/
public abstract class AbstractDeadLetterStrategy implements DeadLetterStrategy {
private static final Logger LOG = LoggerFactory.getLogger(AbstractDeadLetterStrategy.class);
Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/ConstantPendingMessageLimitStrategy.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/ConstantPendingMessageLimitStrategy.java?rev=1071256&r1=1071255&r2=1071256&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/ConstantPendingMessageLimitStrategy.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/ConstantPendingMessageLimitStrategy.java Wed Feb 16 13:58:54 2011
@@ -23,7 +23,7 @@ import org.apache.activemq.broker.region
*
* @org.apache.xbean.XBean
*
- * @version $Revision$
+ *
*/
public class ConstantPendingMessageLimitStrategy implements PendingMessageLimitStrategy {
Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/DeadLetterStrategy.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/DeadLetterStrategy.java?rev=1071256&r1=1071255&r2=1071256&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/DeadLetterStrategy.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/DeadLetterStrategy.java Wed Feb 16 13:58:54 2011
@@ -22,7 +22,7 @@ import org.apache.activemq.command.Messa
/**
* A strategy for choosing which destination is used for dead letter queue messages.
*
- * @version $Revision$
+ *
*/
public interface DeadLetterStrategy {
Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/IndividualDeadLetterStrategy.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/IndividualDeadLetterStrategy.java?rev=1071256&r1=1071255&r2=1071256&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/IndividualDeadLetterStrategy.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/IndividualDeadLetterStrategy.java Wed Feb 16 13:58:54 2011
@@ -25,7 +25,7 @@ import org.apache.activemq.command.Activ
* DLQ using the subject naming hierarchy.
*
* @org.apache.xbean.XBean
- * @version $Revision$
+ *
*/
public class IndividualDeadLetterStrategy extends AbstractDeadLetterStrategy {
Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/MessageEvictionStrategy.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/MessageEvictionStrategy.java?rev=1071256&r1=1071255&r2=1071256&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/MessageEvictionStrategy.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/MessageEvictionStrategy.java Wed Feb 16 13:58:54 2011
@@ -24,7 +24,7 @@ import org.apache.activemq.broker.region
/**
* A strategy for evicting messages from slow consumers.
*
- * @version $Revision$
+ *
*/
public interface MessageEvictionStrategy {
Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/MessageEvictionStrategySupport.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/MessageEvictionStrategySupport.java?rev=1071256&r1=1071255&r2=1071256&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/MessageEvictionStrategySupport.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/MessageEvictionStrategySupport.java Wed Feb 16 13:58:54 2011
@@ -19,7 +19,7 @@ package org.apache.activemq.broker.regio
/**
* A useful base class for implementation inheritence.
*
- * @version $Revision$
+ *
*/
public abstract class MessageEvictionStrategySupport implements MessageEvictionStrategy {
Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/MessageQuery.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/MessageQuery.java?rev=1071256&r1=1071255&r2=1071256&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/MessageQuery.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/MessageQuery.java Wed Feb 16 13:58:54 2011
@@ -24,7 +24,7 @@ import org.apache.activemq.command.Messa
/**
* Represents some kind of query which will load initial messages from some source for a new topic subscriber.
*
- * @version $Revision$
+ *
*/
public interface MessageQuery {
Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/OldestMessageEvictionStrategy.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/OldestMessageEvictionStrategy.java?rev=1071256&r1=1071255&r2=1071256&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/OldestMessageEvictionStrategy.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/OldestMessageEvictionStrategy.java Wed Feb 16 13:58:54 2011
@@ -26,7 +26,7 @@ import org.apache.activemq.broker.region
*
* @org.apache.xbean.XBean
*
- * @version $Revision$
+ *
*/
public class OldestMessageEvictionStrategy extends MessageEvictionStrategySupport {
Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/OldestMessageWithLowestPriorityEvictionStrategy.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/OldestMessageWithLowestPriorityEvictionStrategy.java?rev=1071256&r1=1071255&r2=1071256&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/OldestMessageWithLowestPriorityEvictionStrategy.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/OldestMessageWithLowestPriorityEvictionStrategy.java Wed Feb 16 13:58:54 2011
@@ -27,7 +27,7 @@ import org.apache.activemq.broker.region
*
* @org.apache.xbean.XBean
*
- * @version $Revision$messageEvictionStrategy
+ * messageEvictionStrategy
*/
public class OldestMessageWithLowestPriorityEvictionStrategy extends MessageEvictionStrategySupport {
Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/PendingMessageLimitStrategy.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/PendingMessageLimitStrategy.java?rev=1071256&r1=1071255&r2=1071256&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/PendingMessageLimitStrategy.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/PendingMessageLimitStrategy.java Wed Feb 16 13:58:54 2011
@@ -26,7 +26,7 @@ import org.apache.activemq.broker.region
* This allows us to keep dispatching messages to slow consumers while not blocking fast consumers
* and discarding the messages oldest first.
*
- * @version $Revision$
+ *
*/
public interface PendingMessageLimitStrategy {
Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/PrefetchRatePendingMessageLimitStrategy.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/PrefetchRatePendingMessageLimitStrategy.java?rev=1071256&r1=1071255&r2=1071256&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/PrefetchRatePendingMessageLimitStrategy.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/PrefetchRatePendingMessageLimitStrategy.java Wed Feb 16 13:58:54 2011
@@ -24,7 +24,7 @@ import org.apache.activemq.broker.region
*
* @org.apache.xbean.XBean
*
- * @version $Revision$
+ *
*/
public class PrefetchRatePendingMessageLimitStrategy implements PendingMessageLimitStrategy {
Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/QueryBasedSubscriptionRecoveryPolicy.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/QueryBasedSubscriptionRecoveryPolicy.java?rev=1071256&r1=1071255&r2=1071256&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/QueryBasedSubscriptionRecoveryPolicy.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/QueryBasedSubscriptionRecoveryPolicy.java Wed Feb 16 13:58:54 2011
@@ -42,7 +42,7 @@ import org.slf4j.LoggerFactory;
* specific query mechanism to load any messages they may have missed.
*
* @org.apache.xbean.XBean
- * @version $Revision$
+ *
*/
public class QueryBasedSubscriptionRecoveryPolicy implements SubscriptionRecoveryPolicy {
Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/SharedDeadLetterStrategy.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/SharedDeadLetterStrategy.java?rev=1071256&r1=1071255&r2=1071256&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/SharedDeadLetterStrategy.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/SharedDeadLetterStrategy.java Wed Feb 16 13:58:54 2011
@@ -26,7 +26,7 @@ import org.apache.activemq.command.Activ
*
* @org.apache.xbean.XBean
*
- * @version $Revision$
+ *
*/
public class SharedDeadLetterStrategy extends AbstractDeadLetterStrategy {
Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/virtual/CompositeDestination.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/virtual/CompositeDestination.java?rev=1071256&r1=1071255&r2=1071256&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/virtual/CompositeDestination.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/virtual/CompositeDestination.java Wed Feb 16 13:58:54 2011
@@ -22,7 +22,7 @@ import org.apache.activemq.broker.region
/**
*
- * @version $Revision$
+ *
*/
public abstract class CompositeDestination implements VirtualDestination {
Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/virtual/CompositeDestinationFilter.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/virtual/CompositeDestinationFilter.java?rev=1071256&r1=1071255&r2=1071256&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/virtual/CompositeDestinationFilter.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/virtual/CompositeDestinationFilter.java Wed Feb 16 13:58:54 2011
@@ -31,7 +31,7 @@ import org.apache.activemq.filter.NonCac
* Represents a composite {@link Destination} where send()s are replicated to
* each Destination instance.
*
- * @version $Revision$
+ *
*/
public class CompositeDestinationFilter extends DestinationFilter {
Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/virtual/CompositeQueue.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/virtual/CompositeQueue.java?rev=1071256&r1=1071255&r2=1071256&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/virtual/CompositeQueue.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/virtual/CompositeQueue.java Wed Feb 16 13:58:54 2011
@@ -25,7 +25,7 @@ import org.apache.activemq.command.Activ
*
* @org.apache.xbean.XBean
*
- * @version $Revision$
+ *
*/
public class CompositeQueue extends CompositeDestination {
Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/virtual/CompositeTopic.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/virtual/CompositeTopic.java?rev=1071256&r1=1071255&r2=1071256&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/virtual/CompositeTopic.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/virtual/CompositeTopic.java Wed Feb 16 13:58:54 2011
@@ -24,7 +24,7 @@ import org.apache.activemq.command.Activ
*
* @org.apache.xbean.XBean
*
- * @version $Revision$
+ *
*/
public class CompositeTopic extends CompositeDestination {
Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/virtual/FilteredDestination.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/virtual/FilteredDestination.java?rev=1071256&r1=1071255&r2=1071256&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/virtual/FilteredDestination.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/virtual/FilteredDestination.java Wed Feb 16 13:58:54 2011
@@ -30,7 +30,7 @@ import org.apache.activemq.selector.Sele
*
* @org.apache.xbean.XBean
*
- * @version $Revision$
+ *
*/
public class FilteredDestination {
Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/virtual/MirroredQueue.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/virtual/MirroredQueue.java?rev=1071256&r1=1071255&r2=1071256&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/virtual/MirroredQueue.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/virtual/MirroredQueue.java Wed Feb 16 13:58:54 2011
@@ -32,7 +32,7 @@ import org.slf4j.LoggerFactory;
* Creates <a href="http://activemq.org/site/mirrored-queues.html">Mirrored
* Queue</a> using a prefix and postfix to define the topic name on which to mirror the queue to.
*
- * @version $Revision$
+ *
* @org.apache.xbean.XBean
*/
public class MirroredQueue implements DestinationInterceptor, BrokerServiceAware {
Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/virtual/VirtualDestination.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/virtual/VirtualDestination.java?rev=1071256&r1=1071255&r2=1071256&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/virtual/VirtualDestination.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/virtual/VirtualDestination.java Wed Feb 16 13:58:54 2011
@@ -23,7 +23,7 @@ import org.apache.activemq.command.Activ
/**
* Represents some kind of virtual destination.
*
- * @version $Revision$
+ *
*/
public interface VirtualDestination extends DestinationInterceptor {
Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/virtual/VirtualDestinationInterceptor.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/virtual/VirtualDestinationInterceptor.java?rev=1071256&r1=1071255&r2=1071256&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/virtual/VirtualDestinationInterceptor.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/virtual/VirtualDestinationInterceptor.java Wed Feb 16 13:58:54 2011
@@ -33,7 +33,7 @@ import org.apache.activemq.filter.Destin
* href="http://activemq.apache.org/virtual-destinations.html">Virtual Topics</a>.
*
* @org.apache.xbean.XBean
- * @version $Revision$
+ *
*/
public class VirtualDestinationInterceptor implements DestinationInterceptor {
Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/virtual/VirtualTopic.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/virtual/VirtualTopic.java?rev=1071256&r1=1071255&r2=1071256&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/virtual/VirtualTopic.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/virtual/VirtualTopic.java Wed Feb 16 13:58:54 2011
@@ -28,7 +28,7 @@ import org.apache.activemq.command.Activ
*
* @org.apache.xbean.XBean
*
- * @version $Revision$
+ *
*/
public class VirtualTopic implements VirtualDestination {
Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/virtual/VirtualTopicInterceptor.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/virtual/VirtualTopicInterceptor.java?rev=1071256&r1=1071255&r2=1071256&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/virtual/VirtualTopicInterceptor.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/virtual/VirtualTopicInterceptor.java Wed Feb 16 13:58:54 2011
@@ -27,7 +27,7 @@ import org.apache.activemq.command.Messa
* A Destination which implements <a
* href="http://activemq.org/site/virtual-destinations.html">Virtual Topic</a>
*
- * @version $Revision$
+ *
*/
public class VirtualTopicInterceptor extends DestinationFilter {
Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/util/CommandAgent.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/util/CommandAgent.java?rev=1071256&r1=1071255&r2=1071256&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/util/CommandAgent.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/util/CommandAgent.java Wed Feb 16 13:58:54 2011
@@ -35,7 +35,7 @@ import org.slf4j.LoggerFactory;
/**
* An agent which listens to commands on a JMS destination
*
- * @version $Revision$
+ *
* @org.apache.xbean.XBean
*/
public class CommandAgent implements Service, ExceptionListener {
Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/util/MulticastTraceBrokerPlugin.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/util/MulticastTraceBrokerPlugin.java?rev=1071256&r1=1071255&r2=1071256&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/util/MulticastTraceBrokerPlugin.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/util/MulticastTraceBrokerPlugin.java Wed Feb 16 13:58:54 2011
@@ -28,7 +28,7 @@ import java.net.URISyntaxException;
*
* @org.apache.xbean.XBean
*
- * @version $Revision: 427613 $
+ *
*/
public class MulticastTraceBrokerPlugin extends UDPTraceBrokerPlugin {
Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/util/UDPTraceBrokerPlugin.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/util/UDPTraceBrokerPlugin.java?rev=1071256&r1=1071255&r2=1071256&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/util/UDPTraceBrokerPlugin.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/util/UDPTraceBrokerPlugin.java Wed Feb 16 13:58:54 2011
@@ -63,7 +63,7 @@ import org.slf4j.LoggerFactory;
* socket.
*
* @org.apache.xbean.XBean element="udpTraceBrokerPlugin"
- * @version $Revision: 427613 $
+ *
*/
public class UDPTraceBrokerPlugin extends BrokerPluginSupport {
Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/BaseEndpoint.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/BaseEndpoint.java?rev=1071256&r1=1071255&r2=1071256&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/BaseEndpoint.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/BaseEndpoint.java Wed Feb 16 13:58:54 2011
@@ -19,7 +19,7 @@ package org.apache.activemq.command;
/**
* A default endpoint.
*
- * @version $Revision$
+ *
*/
public class BaseEndpoint implements Endpoint {
Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/Endpoint.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/Endpoint.java?rev=1071256&r1=1071255&r2=1071256&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/Endpoint.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/Endpoint.java Wed Feb 16 13:58:54 2011
@@ -23,7 +23,7 @@ package org.apache.activemq.command;
* for all commands. For transports like multicast there could be different
* endpoints being used on the same transport.
*
- * @version $Revision$
+ *
*/
public interface Endpoint {
Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/LastPartialCommand.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/LastPartialCommand.java?rev=1071256&r1=1071255&r2=1071256&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/LastPartialCommand.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/LastPartialCommand.java Wed Feb 16 13:58:54 2011
@@ -22,7 +22,7 @@ import org.apache.activemq.state.Command
* Represents the end marker of a stream of {@link PartialCommand} instances.
*
* @openwire:marshaller code="61"
- * @version $Revision$
+ *
*/
public class LastPartialCommand extends PartialCommand {
Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/MessagePull.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/MessagePull.java?rev=1071256&r1=1071255&r2=1071256&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/MessagePull.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/MessagePull.java Wed Feb 16 13:58:54 2011
@@ -23,7 +23,7 @@ import org.apache.activemq.state.Command
*
* @openwire:marshaller code="20"
*
- * @version $Revision$
+ *
*/
public class MessagePull extends BaseCommand {
Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/PartialCommand.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/PartialCommand.java?rev=1071256&r1=1071255&r2=1071256&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/PartialCommand.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/PartialCommand.java Wed Feb 16 13:58:54 2011
@@ -23,7 +23,7 @@ import org.apache.activemq.state.Command
* pieces.
*
* @openwire:marshaller code="60"
- * @version $Revision$
+ *
*/
public class PartialCommand implements Command {
Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ReplayCommand.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ReplayCommand.java?rev=1071256&r1=1071255&r2=1071256&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ReplayCommand.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ReplayCommand.java Wed Feb 16 13:58:54 2011
@@ -25,7 +25,7 @@ import org.apache.activemq.state.Command
* TCP/IP if a socket has been re-established.
*
* @openwire:marshaller code="65"
- * @version $Revision$
+ *
*/
public class ReplayCommand extends BaseCommand {
Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/filter/AnyChildDestinationNode.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/filter/AnyChildDestinationNode.java?rev=1071256&r1=1071255&r2=1071256&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/filter/AnyChildDestinationNode.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/filter/AnyChildDestinationNode.java Wed Feb 16 13:58:54 2011
@@ -25,7 +25,7 @@ import java.util.Set;
* An implementation of {@link DestinationNode} which navigates all the children of the given node
* ignoring the name of the current path (so for navigating using * in a wildcard).
*
- * @version $Revision$
+ *
*/
public class AnyChildDestinationNode implements DestinationNode {
private DestinationNode node;
Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/filter/DefaultDestinationMapEntry.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/filter/DefaultDestinationMapEntry.java?rev=1071256&r1=1071255&r2=1071256&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/filter/DefaultDestinationMapEntry.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/filter/DefaultDestinationMapEntry.java Wed Feb 16 13:58:54 2011
@@ -21,7 +21,7 @@ package org.apache.activemq.filter;
*
* @org.apache.xbean.XBean element="destinationEntry"
*
- * @version $Revision$
+ *
*/
public class DefaultDestinationMapEntry extends DestinationMapEntry {
private Object value;
Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/filter/DestinationNode.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/filter/DestinationNode.java?rev=1071256&r1=1071255&r2=1071256&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/filter/DestinationNode.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/filter/DestinationNode.java Wed Feb 16 13:58:54 2011
@@ -22,7 +22,7 @@ import java.util.Set;
/**
* Represents a node in the {@link DestinationMap} tree
*
- * @version $Revision$
+ *
*/
public interface DestinationNode {
void appendMatchingValues(Set answer, String[] paths, int startIndex);
Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/index/DiskIndexLinkedList.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/index/DiskIndexLinkedList.java?rev=1071256&r1=1071255&r2=1071256&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/index/DiskIndexLinkedList.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/index/DiskIndexLinkedList.java Wed Feb 16 13:58:54 2011
@@ -22,7 +22,7 @@ import org.apache.activemq.kaha.StoreEnt
/**
* A linked list used by IndexItems
*
- * @version $Revision$
+ *
*/
public class DiskIndexLinkedList implements IndexLinkedList {
protected IndexManager indexManager;
Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/index/IndexLinkedList.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/index/IndexLinkedList.java?rev=1071256&r1=1071255&r2=1071256&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/index/IndexLinkedList.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/index/IndexLinkedList.java Wed Feb 16 13:58:54 2011
@@ -21,7 +21,7 @@ import org.apache.activemq.kaha.StoreEnt
/**
* Inteface to LinkedList of Indexes
*
- * @version $Revision$
+ *
*/
public interface IndexLinkedList {
Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/network/CompositeDemandForwardingBridge.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/network/CompositeDemandForwardingBridge.java?rev=1071256&r1=1071255&r2=1071256&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/network/CompositeDemandForwardingBridge.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/network/CompositeDemandForwardingBridge.java Wed Feb 16 13:58:54 2011
@@ -35,7 +35,7 @@ import org.slf4j.LoggerFactory;
*
* @org.apache.xbean.XBean
*
- * @version $Revision$
+ *
*/
public class CompositeDemandForwardingBridge extends DemandForwardingBridgeSupport {
private static final Logger LOG = LoggerFactory.getLogger(CompositeDemandForwardingBridge.class);
Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/network/DemandForwardingBridgeSupport.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/network/DemandForwardingBridgeSupport.java?rev=1071256&r1=1071255&r2=1071256&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/network/DemandForwardingBridgeSupport.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/network/DemandForwardingBridgeSupport.java Wed Feb 16 13:58:54 2011
@@ -87,7 +87,7 @@ import org.slf4j.LoggerFactory;
/**
* A useful base class for implementing demand forwarding bridges.
*
- * @version $Revision$
+ *
*/
public abstract class DemandForwardingBridgeSupport implements NetworkBridge, BrokerServiceAware {
private static final Logger LOG = LoggerFactory.getLogger(DemandForwardingBridgeSupport.class);
Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/network/DiscoveryNetworkConnector.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/network/DiscoveryNetworkConnector.java?rev=1071256&r1=1071255&r2=1071256&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/network/DiscoveryNetworkConnector.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/network/DiscoveryNetworkConnector.java Wed Feb 16 13:58:54 2011
@@ -47,7 +47,7 @@ import javax.management.ObjectName;
* available and setup a connection to each available remote broker
*
* @org.apache.xbean.XBean element="networkConnector"
- * @version $Revision$
+ *
*/
public class DiscoveryNetworkConnector extends NetworkConnector implements DiscoveryListener {
private static final Logger LOG = LoggerFactory.getLogger(DiscoveryNetworkConnector.class);
Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/network/MulticastNetworkConnector.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/network/MulticastNetworkConnector.java?rev=1071256&r1=1071255&r2=1071256&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/network/MulticastNetworkConnector.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/network/MulticastNetworkConnector.java Wed Feb 16 13:58:54 2011
@@ -32,7 +32,7 @@ import org.apache.activemq.util.ServiceS
*
* @org.apache.xbean.XBean
*
- * @version $Revision$
+ *
*/
public class MulticastNetworkConnector extends NetworkConnector {
Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/CommandIdComparator.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/CommandIdComparator.java?rev=1071256&r1=1071255&r2=1071256&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/CommandIdComparator.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/CommandIdComparator.java Wed Feb 16 13:58:54 2011
@@ -23,7 +23,7 @@ import org.apache.activemq.command.Comma
/**
* A @{link Comparator} of commands using their {@link Command#getCommandId()}
*
- * @version $Revision$
+ *
*/
public class CommandIdComparator implements Comparator<Command> {
Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v1/DiscoveryEventMarshaller.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v1/DiscoveryEventMarshaller.java?rev=1071256&r1=1071255&r2=1071256&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v1/DiscoveryEventMarshaller.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v1/DiscoveryEventMarshaller.java Wed Feb 16 13:58:54 2011
@@ -37,7 +37,7 @@ import org.apache.activemq.openwire.Open
* under src/gram/script and then use maven openwire:generate to regenerate
* this file.
*
- * @version $Revision$
+ *
*/
public class DiscoveryEventMarshaller extends BaseDataStreamMarshaller {
Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v1/LastPartialCommandMarshaller.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v1/LastPartialCommandMarshaller.java?rev=1071256&r1=1071255&r2=1071256&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v1/LastPartialCommandMarshaller.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v1/LastPartialCommandMarshaller.java Wed Feb 16 13:58:54 2011
@@ -37,7 +37,7 @@ import org.apache.activemq.openwire.Open
* under src/gram/script and then use maven openwire:generate to regenerate
* this file.
*
- * @version $Revision$
+ *
*/
public class LastPartialCommandMarshaller extends PartialCommandMarshaller {
Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v1/PartialCommandMarshaller.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v1/PartialCommandMarshaller.java?rev=1071256&r1=1071255&r2=1071256&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v1/PartialCommandMarshaller.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v1/PartialCommandMarshaller.java Wed Feb 16 13:58:54 2011
@@ -37,7 +37,7 @@ import org.apache.activemq.openwire.Open
* under src/gram/script and then use maven openwire:generate to regenerate
* this file.
*
- * @version $Revision$
+ *
*/
public class PartialCommandMarshaller extends BaseDataStreamMarshaller {
Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v1/ReplayCommandMarshaller.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v1/ReplayCommandMarshaller.java?rev=1071256&r1=1071255&r2=1071256&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v1/ReplayCommandMarshaller.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v1/ReplayCommandMarshaller.java Wed Feb 16 13:58:54 2011
@@ -37,7 +37,7 @@ import org.apache.activemq.openwire.Open
* under src/gram/script and then use maven openwire:generate to regenerate
* this file.
*
- * @version $Revision$
+ *
*/
public class ReplayCommandMarshaller extends BaseCommandMarshaller {
Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v4/ActiveMQBlobMessageMarshaller.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v4/ActiveMQBlobMessageMarshaller.java?rev=1071256&r1=1071255&r2=1071256&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v4/ActiveMQBlobMessageMarshaller.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v4/ActiveMQBlobMessageMarshaller.java Wed Feb 16 13:58:54 2011
@@ -36,7 +36,7 @@ import org.apache.activemq.command.*;
* under src/gram/script and then use maven openwire:generate to regenerate
* this file.
*
- * @version $Revision$
+ *
*/
public class ActiveMQBlobMessageMarshaller extends ActiveMQMessageMarshaller {