activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From chir...@apache.org
Subject svn commit: r359567 [4/13] - in /incubator/activemq/trunk/activemq-core: ./ src/gram/java/org/activemq/openwire/tool/ src/gram/script/ src/main/grammar/ src/main/java/org/activemq/ src/main/java/org/activemq/advisory/ src/main/java/org/activemq/broker/...
Date Wed, 28 Dec 2005 17:28:57 GMT
Copied: incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/Queue.java (from r359554, incubator/activemq/trunk/activemq-core/src/main/java/org/activemq/broker/region/Queue.java)
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/Queue.java?p2=incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/Queue.java&p1=incubator/activemq/trunk/activemq-core/src/main/java/org/activemq/broker/region/Queue.java&r1=359554&r2=359567&rev=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/main/java/org/activemq/broker/region/Queue.java (original)
+++ incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/Queue.java Wed Dec 28 09:24:02 2005
@@ -14,28 +14,28 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package org.activemq.broker.region;
+package org.apache.activemq.broker.region;
 
 import java.io.IOException;
 import java.util.HashSet;
 import java.util.Iterator;
 import java.util.LinkedList;
 
-import org.activemq.broker.ConnectionContext;
-import org.activemq.broker.region.policy.DispatchPolicy;
-import org.activemq.broker.region.policy.RoundRobinDispatchPolicy;
-import org.activemq.command.ActiveMQDestination;
-import org.activemq.command.ConsumerId;
-import org.activemq.command.Message;
-import org.activemq.command.MessageAck;
-import org.activemq.command.MessageId;
-import org.activemq.filter.MessageEvaluationContext;
-import org.activemq.memory.UsageManager;
-import org.activemq.store.MessageRecoveryListener;
-import org.activemq.store.MessageStore;
-import org.activemq.thread.TaskRunnerFactory;
-import org.activemq.thread.Valve;
-import org.activemq.transaction.Synchronization;
+import org.apache.activemq.broker.ConnectionContext;
+import org.apache.activemq.broker.region.policy.DispatchPolicy;
+import org.apache.activemq.broker.region.policy.RoundRobinDispatchPolicy;
+import org.apache.activemq.command.ActiveMQDestination;
+import org.apache.activemq.command.ConsumerId;
+import org.apache.activemq.command.Message;
+import org.apache.activemq.command.MessageAck;
+import org.apache.activemq.command.MessageId;
+import org.apache.activemq.filter.MessageEvaluationContext;
+import org.apache.activemq.memory.UsageManager;
+import org.apache.activemq.store.MessageRecoveryListener;
+import org.apache.activemq.store.MessageStore;
+import org.apache.activemq.thread.TaskRunnerFactory;
+import org.apache.activemq.thread.Valve;
+import org.apache.activemq.transaction.Synchronization;
 import org.apache.commons.logging.Log;
 import org.apache.commons.logging.LogFactory;
 

Copied: incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/QueueBrowserSubscription.java (from r359554, incubator/activemq/trunk/activemq-core/src/main/java/org/activemq/broker/region/QueueBrowserSubscription.java)
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/QueueBrowserSubscription.java?p2=incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/QueueBrowserSubscription.java&p1=incubator/activemq/trunk/activemq-core/src/main/java/org/activemq/broker/region/QueueBrowserSubscription.java&r1=359554&r2=359567&rev=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/main/java/org/activemq/broker/region/QueueBrowserSubscription.java (original)
+++ incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/QueueBrowserSubscription.java Wed Dec 28 09:24:02 2005
@@ -14,15 +14,15 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package org.activemq.broker.region;
+package org.apache.activemq.broker.region;
 
 import javax.jms.InvalidSelectorException;
 
-import org.activemq.broker.ConnectionContext;
-import org.activemq.command.ConsumerInfo;
-import org.activemq.command.Message;
-import org.activemq.command.MessageDispatch;
-import org.activemq.filter.MessageEvaluationContext;
+import org.apache.activemq.broker.ConnectionContext;
+import org.apache.activemq.command.ConsumerInfo;
+import org.apache.activemq.command.Message;
+import org.apache.activemq.command.MessageDispatch;
+import org.apache.activemq.filter.MessageEvaluationContext;
 
 public class QueueBrowserSubscription extends PrefetchSubscription {
         

Copied: incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/QueueRegion.java (from r359554, incubator/activemq/trunk/activemq-core/src/main/java/org/activemq/broker/region/QueueRegion.java)
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/QueueRegion.java?p2=incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/QueueRegion.java&p1=incubator/activemq/trunk/activemq-core/src/main/java/org/activemq/broker/region/QueueRegion.java&r1=359554&r2=359567&rev=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/main/java/org/activemq/broker/region/QueueRegion.java (original)
+++ incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/QueueRegion.java Wed Dec 28 09:24:02 2005
@@ -14,18 +14,18 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package org.activemq.broker.region;
+package org.apache.activemq.broker.region;
 
-import org.activemq.broker.ConnectionContext;
-import org.activemq.broker.region.policy.PolicyEntry;
-import org.activemq.broker.region.policy.PolicyMap;
-import org.activemq.command.ActiveMQDestination;
-import org.activemq.command.ActiveMQQueue;
-import org.activemq.command.ConsumerInfo;
-import org.activemq.memory.UsageManager;
-import org.activemq.store.MessageStore;
-import org.activemq.store.PersistenceAdapter;
-import org.activemq.thread.TaskRunnerFactory;
+import org.apache.activemq.broker.ConnectionContext;
+import org.apache.activemq.broker.region.policy.PolicyEntry;
+import org.apache.activemq.broker.region.policy.PolicyMap;
+import org.apache.activemq.command.ActiveMQDestination;
+import org.apache.activemq.command.ActiveMQQueue;
+import org.apache.activemq.command.ConsumerInfo;
+import org.apache.activemq.memory.UsageManager;
+import org.apache.activemq.store.MessageStore;
+import org.apache.activemq.store.PersistenceAdapter;
+import org.apache.activemq.thread.TaskRunnerFactory;
 
 import javax.jms.InvalidSelectorException;
 

Copied: incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/QueueSubscription.java (from r359554, incubator/activemq/trunk/activemq-core/src/main/java/org/activemq/broker/region/QueueSubscription.java)
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/QueueSubscription.java?p2=incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/QueueSubscription.java&p1=incubator/activemq/trunk/activemq-core/src/main/java/org/activemq/broker/region/QueueSubscription.java&r1=359554&r2=359567&rev=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/main/java/org/activemq/broker/region/QueueSubscription.java (original)
+++ incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/QueueSubscription.java Wed Dec 28 09:24:02 2005
@@ -14,17 +14,17 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package org.activemq.broker.region;
+package org.apache.activemq.broker.region;
 
 import java.io.IOException;
 
 import javax.jms.InvalidSelectorException;
 
-import org.activemq.broker.ConnectionContext;
-import org.activemq.command.ConsumerId;
-import org.activemq.command.ConsumerInfo;
-import org.activemq.command.MessageAck;
-import org.activemq.transaction.Synchronization;
+import org.apache.activemq.broker.ConnectionContext;
+import org.apache.activemq.command.ConsumerId;
+import org.apache.activemq.command.ConsumerInfo;
+import org.apache.activemq.command.MessageAck;
+import org.apache.activemq.transaction.Synchronization;
 
 import edu.emory.mathcs.backport.java.util.concurrent.ConcurrentHashMap;
 

Copied: incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/Region.java (from r359554, incubator/activemq/trunk/activemq-core/src/main/java/org/activemq/broker/region/Region.java)
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/Region.java?p2=incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/Region.java&p1=incubator/activemq/trunk/activemq-core/src/main/java/org/activemq/broker/region/Region.java&r1=359554&r2=359567&rev=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/main/java/org/activemq/broker/region/Region.java (original)
+++ incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/Region.java Wed Dec 28 09:24:02 2005
@@ -14,14 +14,14 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package org.activemq.broker.region;
+package org.apache.activemq.broker.region;
 
-import org.activemq.broker.ConnectionContext;
-import org.activemq.command.ActiveMQDestination;
-import org.activemq.command.ConsumerInfo;
-import org.activemq.command.Message;
-import org.activemq.command.MessageAck;
-import org.activemq.command.RemoveSubscriptionInfo;
+import org.apache.activemq.broker.ConnectionContext;
+import org.apache.activemq.command.ActiveMQDestination;
+import org.apache.activemq.command.ConsumerInfo;
+import org.apache.activemq.command.Message;
+import org.apache.activemq.command.MessageAck;
+import org.apache.activemq.command.RemoveSubscriptionInfo;
 
 /**
  * A Region is used to implement the different QOS options available to 

Copied: incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/RegionBroker.java (from r359554, incubator/activemq/trunk/activemq-core/src/main/java/org/activemq/broker/region/RegionBroker.java)
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/RegionBroker.java?p2=incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/RegionBroker.java&p1=incubator/activemq/trunk/activemq-core/src/main/java/org/activemq/broker/region/RegionBroker.java&r1=359554&r2=359567&rev=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/main/java/org/activemq/broker/region/RegionBroker.java (original)
+++ incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/RegionBroker.java Wed Dec 28 09:24:02 2005
@@ -14,31 +14,31 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package org.activemq.broker.region;
+package org.apache.activemq.broker.region;
 
 import edu.emory.mathcs.backport.java.util.concurrent.CopyOnWriteArrayList;
 import edu.emory.mathcs.backport.java.util.concurrent.CopyOnWriteArraySet;
 
-import org.activemq.broker.Broker;
-import org.activemq.broker.Connection;
-import org.activemq.broker.ConnectionContext;
-import org.activemq.broker.region.policy.PolicyMap;
-import org.activemq.command.ActiveMQDestination;
-import org.activemq.command.BrokerId;
-import org.activemq.command.ConnectionInfo;
-import org.activemq.command.ConsumerInfo;
-import org.activemq.command.Message;
-import org.activemq.command.MessageAck;
-import org.activemq.command.ProducerInfo;
-import org.activemq.command.RemoveSubscriptionInfo;
-import org.activemq.command.SessionInfo;
-import org.activemq.command.TransactionId;
-import org.activemq.memory.UsageManager;
-import org.activemq.store.PersistenceAdapter;
-import org.activemq.store.memory.MemoryPersistenceAdapter;
-import org.activemq.thread.TaskRunnerFactory;
-import org.activemq.util.IdGenerator;
-import org.activemq.util.LongSequenceGenerator;
+import org.apache.activemq.broker.Broker;
+import org.apache.activemq.broker.Connection;
+import org.apache.activemq.broker.ConnectionContext;
+import org.apache.activemq.broker.region.policy.PolicyMap;
+import org.apache.activemq.command.ActiveMQDestination;
+import org.apache.activemq.command.BrokerId;
+import org.apache.activemq.command.ConnectionInfo;
+import org.apache.activemq.command.ConsumerInfo;
+import org.apache.activemq.command.Message;
+import org.apache.activemq.command.MessageAck;
+import org.apache.activemq.command.ProducerInfo;
+import org.apache.activemq.command.RemoveSubscriptionInfo;
+import org.apache.activemq.command.SessionInfo;
+import org.apache.activemq.command.TransactionId;
+import org.apache.activemq.memory.UsageManager;
+import org.apache.activemq.store.PersistenceAdapter;
+import org.apache.activemq.store.memory.MemoryPersistenceAdapter;
+import org.apache.activemq.thread.TaskRunnerFactory;
+import org.apache.activemq.util.IdGenerator;
+import org.apache.activemq.util.LongSequenceGenerator;
 
 import javax.jms.JMSException;
 

Copied: incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/Subscription.java (from r359554, incubator/activemq/trunk/activemq-core/src/main/java/org/activemq/broker/region/Subscription.java)
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/Subscription.java?p2=incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/Subscription.java&p1=incubator/activemq/trunk/activemq-core/src/main/java/org/activemq/broker/region/Subscription.java&r1=359554&r2=359567&rev=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/main/java/org/activemq/broker/region/Subscription.java (original)
+++ incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/Subscription.java Wed Dec 28 09:24:02 2005
@@ -14,15 +14,15 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package org.activemq.broker.region;
+package org.apache.activemq.broker.region;
 
 import java.io.IOException;
 
-import org.activemq.broker.ConnectionContext;
-import org.activemq.command.ActiveMQDestination;
-import org.activemq.command.ConsumerInfo;
-import org.activemq.command.MessageAck;
-import org.activemq.filter.MessageEvaluationContext;
+import org.apache.activemq.broker.ConnectionContext;
+import org.apache.activemq.command.ActiveMQDestination;
+import org.apache.activemq.command.ConsumerInfo;
+import org.apache.activemq.command.MessageAck;
+import org.apache.activemq.filter.MessageEvaluationContext;
 
 /**
  * @version $Revision: 1.5 $

Copied: incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/TempQueueRegion.java (from r359554, incubator/activemq/trunk/activemq-core/src/main/java/org/activemq/broker/region/TempQueueRegion.java)
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/TempQueueRegion.java?p2=incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/TempQueueRegion.java&p1=incubator/activemq/trunk/activemq-core/src/main/java/org/activemq/broker/region/TempQueueRegion.java&r1=359554&r2=359567&rev=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/main/java/org/activemq/broker/region/TempQueueRegion.java (original)
+++ incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/TempQueueRegion.java Wed Dec 28 09:24:02 2005
@@ -14,17 +14,17 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package org.activemq.broker.region;
+package org.apache.activemq.broker.region;
 
 import javax.jms.InvalidSelectorException;
 import javax.jms.JMSException;
 
-import org.activemq.broker.ConnectionContext;
-import org.activemq.command.ActiveMQDestination;
-import org.activemq.command.ActiveMQTempDestination;
-import org.activemq.command.ConsumerInfo;
-import org.activemq.memory.UsageManager;
-import org.activemq.thread.TaskRunnerFactory;
+import org.apache.activemq.broker.ConnectionContext;
+import org.apache.activemq.command.ActiveMQDestination;
+import org.apache.activemq.command.ActiveMQTempDestination;
+import org.apache.activemq.command.ConsumerInfo;
+import org.apache.activemq.memory.UsageManager;
+import org.apache.activemq.thread.TaskRunnerFactory;
 
 /**
  * 

Copied: incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/TempTopicRegion.java (from r359554, incubator/activemq/trunk/activemq-core/src/main/java/org/activemq/broker/region/TempTopicRegion.java)
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/TempTopicRegion.java?p2=incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/TempTopicRegion.java&p1=incubator/activemq/trunk/activemq-core/src/main/java/org/activemq/broker/region/TempTopicRegion.java&r1=359554&r2=359567&rev=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/main/java/org/activemq/broker/region/TempTopicRegion.java (original)
+++ incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/TempTopicRegion.java Wed Dec 28 09:24:02 2005
@@ -14,16 +14,16 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package org.activemq.broker.region;
+package org.apache.activemq.broker.region;
 
 import javax.jms.JMSException;
 
-import org.activemq.broker.ConnectionContext;
-import org.activemq.command.ActiveMQDestination;
-import org.activemq.command.ActiveMQTempDestination;
-import org.activemq.command.ConsumerInfo;
-import org.activemq.memory.UsageManager;
-import org.activemq.thread.TaskRunnerFactory;
+import org.apache.activemq.broker.ConnectionContext;
+import org.apache.activemq.command.ActiveMQDestination;
+import org.apache.activemq.command.ActiveMQTempDestination;
+import org.apache.activemq.command.ConsumerInfo;
+import org.apache.activemq.memory.UsageManager;
+import org.apache.activemq.thread.TaskRunnerFactory;
 
 /**
  * 

Copied: incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/Topic.java (from r359554, incubator/activemq/trunk/activemq-core/src/main/java/org/activemq/broker/region/Topic.java)
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/Topic.java?p2=incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/Topic.java&p1=incubator/activemq/trunk/activemq-core/src/main/java/org/activemq/broker/region/Topic.java&r1=359554&r2=359567&rev=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/main/java/org/activemq/broker/region/Topic.java (original)
+++ incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/Topic.java Wed Dec 28 09:24:02 2005
@@ -14,29 +14,29 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package org.activemq.broker.region;
+package org.apache.activemq.broker.region;
 
 import java.io.IOException;
 
-import org.activemq.broker.ConnectionContext;
-import org.activemq.broker.region.policy.DispatchPolicy;
-import org.activemq.broker.region.policy.LastImageSubscriptionRecoveryPolicy;
-import org.activemq.broker.region.policy.SimpleDispatchPolicy;
-import org.activemq.broker.region.policy.SubscriptionRecoveryPolicy;
-import org.activemq.command.ActiveMQDestination;
-import org.activemq.command.Message;
-import org.activemq.command.MessageAck;
-import org.activemq.command.MessageId;
-import org.activemq.command.SubscriptionInfo;
-import org.activemq.filter.MessageEvaluationContext;
-import org.activemq.memory.UsageManager;
-import org.activemq.store.MessageRecoveryListener;
-import org.activemq.store.MessageStore;
-import org.activemq.store.TopicMessageStore;
-import org.activemq.thread.TaskRunnerFactory;
-import org.activemq.thread.Valve;
-import org.activemq.transaction.Synchronization;
-import org.activemq.util.SubscriptionKey;
+import org.apache.activemq.broker.ConnectionContext;
+import org.apache.activemq.broker.region.policy.DispatchPolicy;
+import org.apache.activemq.broker.region.policy.LastImageSubscriptionRecoveryPolicy;
+import org.apache.activemq.broker.region.policy.SimpleDispatchPolicy;
+import org.apache.activemq.broker.region.policy.SubscriptionRecoveryPolicy;
+import org.apache.activemq.command.ActiveMQDestination;
+import org.apache.activemq.command.Message;
+import org.apache.activemq.command.MessageAck;
+import org.apache.activemq.command.MessageId;
+import org.apache.activemq.command.SubscriptionInfo;
+import org.apache.activemq.filter.MessageEvaluationContext;
+import org.apache.activemq.memory.UsageManager;
+import org.apache.activemq.store.MessageRecoveryListener;
+import org.apache.activemq.store.MessageStore;
+import org.apache.activemq.store.TopicMessageStore;
+import org.apache.activemq.thread.TaskRunnerFactory;
+import org.apache.activemq.thread.Valve;
+import org.apache.activemq.transaction.Synchronization;
+import org.apache.activemq.util.SubscriptionKey;
 
 import edu.emory.mathcs.backport.java.util.concurrent.CopyOnWriteArrayList;
 

Copied: incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/TopicRegion.java (from r359554, incubator/activemq/trunk/activemq-core/src/main/java/org/activemq/broker/region/TopicRegion.java)
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/TopicRegion.java?p2=incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/TopicRegion.java&p1=incubator/activemq/trunk/activemq-core/src/main/java/org/activemq/broker/region/TopicRegion.java&r1=359554&r2=359567&rev=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/main/java/org/activemq/broker/region/TopicRegion.java (original)
+++ incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/TopicRegion.java Wed Dec 28 09:24:02 2005
@@ -14,22 +14,22 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package org.activemq.broker.region;
+package org.apache.activemq.broker.region;
 
 import edu.emory.mathcs.backport.java.util.concurrent.ConcurrentHashMap;
 
-import org.activemq.broker.ConnectionContext;
-import org.activemq.broker.region.policy.PolicyEntry;
-import org.activemq.broker.region.policy.PolicyMap;
-import org.activemq.command.ActiveMQDestination;
-import org.activemq.command.ActiveMQTopic;
-import org.activemq.command.ConsumerInfo;
-import org.activemq.command.RemoveSubscriptionInfo;
-import org.activemq.memory.UsageManager;
-import org.activemq.store.PersistenceAdapter;
-import org.activemq.store.TopicMessageStore;
-import org.activemq.thread.TaskRunnerFactory;
-import org.activemq.util.SubscriptionKey;
+import org.apache.activemq.broker.ConnectionContext;
+import org.apache.activemq.broker.region.policy.PolicyEntry;
+import org.apache.activemq.broker.region.policy.PolicyMap;
+import org.apache.activemq.command.ActiveMQDestination;
+import org.apache.activemq.command.ActiveMQTopic;
+import org.apache.activemq.command.ConsumerInfo;
+import org.apache.activemq.command.RemoveSubscriptionInfo;
+import org.apache.activemq.memory.UsageManager;
+import org.apache.activemq.store.PersistenceAdapter;
+import org.apache.activemq.store.TopicMessageStore;
+import org.apache.activemq.thread.TaskRunnerFactory;
+import org.apache.activemq.util.SubscriptionKey;
 
 import javax.jms.InvalidDestinationException;
 import javax.jms.JMSException;

Copied: incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/TopicSubscription.java (from r359554, incubator/activemq/trunk/activemq-core/src/main/java/org/activemq/broker/region/TopicSubscription.java)
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/TopicSubscription.java?p2=incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/TopicSubscription.java&p1=incubator/activemq/trunk/activemq-core/src/main/java/org/activemq/broker/region/TopicSubscription.java&r1=359554&r2=359567&rev=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/main/java/org/activemq/broker/region/TopicSubscription.java (original)
+++ incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/TopicSubscription.java Wed Dec 28 09:24:02 2005
@@ -14,7 +14,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package org.activemq.broker.region;
+package org.apache.activemq.broker.region;
 
 import java.io.IOException;
 import java.util.Iterator;
@@ -23,15 +23,15 @@
 import javax.jms.InvalidSelectorException;
 import javax.jms.JMSException;
 
-import org.activemq.broker.ConnectionContext;
-import org.activemq.command.ActiveMQDestination;
-import org.activemq.command.ActiveMQQueue;
-import org.activemq.command.ConsumerInfo;
-import org.activemq.command.Message;
-import org.activemq.command.MessageAck;
-import org.activemq.command.MessageDispatch;
-import org.activemq.memory.UsageManager;
-import org.activemq.transaction.Synchronization;
+import org.apache.activemq.broker.ConnectionContext;
+import org.apache.activemq.command.ActiveMQDestination;
+import org.apache.activemq.command.ActiveMQQueue;
+import org.apache.activemq.command.ConsumerInfo;
+import org.apache.activemq.command.Message;
+import org.apache.activemq.command.MessageAck;
+import org.apache.activemq.command.MessageDispatch;
+import org.apache.activemq.memory.UsageManager;
+import org.apache.activemq.transaction.Synchronization;
 
 public class TopicSubscription extends AbstractSubscription {
     

Modified: incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/DispatchPolicy.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/DispatchPolicy.java?rev=359567&r1=359554&r2=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/DispatchPolicy.java (original)
+++ incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/DispatchPolicy.java Wed Dec 28 09:24:02 2005
@@ -14,11 +14,11 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package org.activemq.broker.region.policy;
+package org.apache.activemq.broker.region.policy;
 
-import org.activemq.broker.ConnectionContext;
-import org.activemq.broker.region.MessageReference;
-import org.activemq.filter.MessageEvaluationContext;
+import org.apache.activemq.broker.ConnectionContext;
+import org.apache.activemq.broker.region.MessageReference;
+import org.apache.activemq.filter.MessageEvaluationContext;
 
 import edu.emory.mathcs.backport.java.util.concurrent.CopyOnWriteArrayList;
 

Modified: incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/FixedSizedSubscriptionRecoveryPolicy.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/FixedSizedSubscriptionRecoveryPolicy.java?rev=359567&r1=359554&r2=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/FixedSizedSubscriptionRecoveryPolicy.java (original)
+++ incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/FixedSizedSubscriptionRecoveryPolicy.java Wed Dec 28 09:24:02 2005
@@ -14,19 +14,19 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package org.activemq.broker.region.policy;
+package org.apache.activemq.broker.region.policy;
 
 import java.util.Iterator;
 import java.util.List;
 
-import org.activemq.broker.ConnectionContext;
-import org.activemq.broker.region.MessageReference;
-import org.activemq.broker.region.Subscription;
-import org.activemq.broker.region.Topic;
-import org.activemq.filter.MessageEvaluationContext;
-import org.activemq.memory.list.DestinationBasedMessageList;
-import org.activemq.memory.list.MessageList;
-import org.activemq.memory.list.SimpleMessageList;
+import org.apache.activemq.broker.ConnectionContext;
+import org.apache.activemq.broker.region.MessageReference;
+import org.apache.activemq.broker.region.Subscription;
+import org.apache.activemq.broker.region.Topic;
+import org.apache.activemq.filter.MessageEvaluationContext;
+import org.apache.activemq.memory.list.DestinationBasedMessageList;
+import org.apache.activemq.memory.list.MessageList;
+import org.apache.activemq.memory.list.SimpleMessageList;
 
 /**
  * This implementation of {@link SubscriptionRecoveryPolicy} will keep a fixed

Modified: incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/LastImageSubscriptionRecoveryPolicy.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/LastImageSubscriptionRecoveryPolicy.java?rev=359567&r1=359554&r2=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/LastImageSubscriptionRecoveryPolicy.java (original)
+++ incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/LastImageSubscriptionRecoveryPolicy.java Wed Dec 28 09:24:02 2005
@@ -14,13 +14,13 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package org.activemq.broker.region.policy;
+package org.apache.activemq.broker.region.policy;
 
-import org.activemq.broker.ConnectionContext;
-import org.activemq.broker.region.MessageReference;
-import org.activemq.broker.region.Subscription;
-import org.activemq.broker.region.Topic;
-import org.activemq.filter.MessageEvaluationContext;
+import org.apache.activemq.broker.ConnectionContext;
+import org.apache.activemq.broker.region.MessageReference;
+import org.apache.activemq.broker.region.Subscription;
+import org.apache.activemq.broker.region.Topic;
+import org.apache.activemq.filter.MessageEvaluationContext;
 
 /**
  * This implementation of {@link SubscriptionRecoveryPolicy} will only keep 

Modified: incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/MessageQuery.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/MessageQuery.java?rev=359567&r1=359554&r2=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/MessageQuery.java (original)
+++ incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/MessageQuery.java Wed Dec 28 09:24:02 2005
@@ -14,10 +14,10 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package org.activemq.broker.region.policy;
+package org.apache.activemq.broker.region.policy;
 
-import org.activemq.command.ActiveMQDestination;
-import org.activemq.command.Message;
+import org.apache.activemq.command.ActiveMQDestination;
+import org.apache.activemq.command.Message;
 
 import javax.jms.MessageListener;
 

Modified: incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/NoSubscriptionRecoveryPolicy.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/NoSubscriptionRecoveryPolicy.java?rev=359567&r1=359554&r2=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/NoSubscriptionRecoveryPolicy.java (original)
+++ incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/NoSubscriptionRecoveryPolicy.java Wed Dec 28 09:24:02 2005
@@ -14,12 +14,12 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package org.activemq.broker.region.policy;
+package org.apache.activemq.broker.region.policy;
 
-import org.activemq.broker.ConnectionContext;
-import org.activemq.broker.region.MessageReference;
-import org.activemq.broker.region.Subscription;
-import org.activemq.broker.region.Topic;
+import org.apache.activemq.broker.ConnectionContext;
+import org.apache.activemq.broker.region.MessageReference;
+import org.apache.activemq.broker.region.Subscription;
+import org.apache.activemq.broker.region.Topic;
 
 /**
  * This is the default Topic recovery policy which does not recover any messages.

Modified: incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/PolicyEntry.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/PolicyEntry.java?rev=359567&r1=359554&r2=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/PolicyEntry.java (original)
+++ incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/PolicyEntry.java Wed Dec 28 09:24:02 2005
@@ -14,12 +14,12 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package org.activemq.broker.region.policy;
+package org.apache.activemq.broker.region.policy;
 
-import org.activemq.broker.region.Queue;
-import org.activemq.broker.region.Topic;
-import org.activemq.command.RedeliveryPolicy;
-import org.activemq.filter.DestinationMapEntry;
+import org.apache.activemq.broker.region.Queue;
+import org.apache.activemq.broker.region.Topic;
+import org.apache.activemq.command.RedeliveryPolicy;
+import org.apache.activemq.filter.DestinationMapEntry;
 
 /**
  * Represents an entry in a {@link PolicyMap} for assigning policies to a

Modified: incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/PolicyMap.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/PolicyMap.java?rev=359567&r1=359554&r2=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/PolicyMap.java (original)
+++ incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/PolicyMap.java Wed Dec 28 09:24:02 2005
@@ -14,10 +14,10 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package org.activemq.broker.region.policy;
+package org.apache.activemq.broker.region.policy;
 
-import org.activemq.command.ActiveMQDestination;
-import org.activemq.filter.DestinationMap;
+import org.apache.activemq.command.ActiveMQDestination;
+import org.apache.activemq.filter.DestinationMap;
 
 import java.util.List;
 
@@ -45,7 +45,7 @@
     /**
      * Sets the individual entries on the policy map
      * 
-     * @org.xbean.ElementType class="org.activemq.broker.region.policy.PolicyEntry"
+     * @org.xbean.ElementType class="org.apache.activemq.broker.region.policy.PolicyEntry"
      */
     public void setPolicyEntries(List entries) {
         super.setEntries(entries);

Modified: incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/QueryBasedSubscriptionRecoveryPolicy.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/QueryBasedSubscriptionRecoveryPolicy.java?rev=359567&r1=359554&r2=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/QueryBasedSubscriptionRecoveryPolicy.java (original)
+++ incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/QueryBasedSubscriptionRecoveryPolicy.java Wed Dec 28 09:24:02 2005
@@ -14,24 +14,24 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package org.activemq.broker.region.policy;
+package org.apache.activemq.broker.region.policy;
 
 import edu.emory.mathcs.backport.java.util.concurrent.atomic.AtomicLong;
 
-import org.activemq.ActiveMQMessageTransformation;
-import org.activemq.broker.ConnectionContext;
-import org.activemq.broker.region.Destination;
-import org.activemq.broker.region.MessageReference;
-import org.activemq.broker.region.Subscription;
-import org.activemq.broker.region.Topic;
-import org.activemq.command.ActiveMQDestination;
-import org.activemq.command.ActiveMQMessage;
-import org.activemq.command.ConnectionId;
-import org.activemq.command.MessageId;
-import org.activemq.command.ProducerId;
-import org.activemq.command.SessionId;
-import org.activemq.filter.MessageEvaluationContext;
-import org.activemq.util.IdGenerator;
+import org.apache.activemq.ActiveMQMessageTransformation;
+import org.apache.activemq.broker.ConnectionContext;
+import org.apache.activemq.broker.region.Destination;
+import org.apache.activemq.broker.region.MessageReference;
+import org.apache.activemq.broker.region.Subscription;
+import org.apache.activemq.broker.region.Topic;
+import org.apache.activemq.command.ActiveMQDestination;
+import org.apache.activemq.command.ActiveMQMessage;
+import org.apache.activemq.command.ConnectionId;
+import org.apache.activemq.command.MessageId;
+import org.apache.activemq.command.ProducerId;
+import org.apache.activemq.command.SessionId;
+import org.apache.activemq.filter.MessageEvaluationContext;
+import org.apache.activemq.util.IdGenerator;
 import org.apache.commons.logging.Log;
 import org.apache.commons.logging.LogFactory;
 

Modified: incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/RoundRobinDispatchPolicy.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/RoundRobinDispatchPolicy.java?rev=359567&r1=359554&r2=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/RoundRobinDispatchPolicy.java (original)
+++ incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/RoundRobinDispatchPolicy.java Wed Dec 28 09:24:02 2005
@@ -14,14 +14,14 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package org.activemq.broker.region.policy;
+package org.apache.activemq.broker.region.policy;
 
 import java.util.Iterator;
 
-import org.activemq.broker.ConnectionContext;
-import org.activemq.broker.region.MessageReference;
-import org.activemq.broker.region.Subscription;
-import org.activemq.filter.MessageEvaluationContext;
+import org.apache.activemq.broker.ConnectionContext;
+import org.apache.activemq.broker.region.MessageReference;
+import org.apache.activemq.broker.region.Subscription;
+import org.apache.activemq.filter.MessageEvaluationContext;
 
 import edu.emory.mathcs.backport.java.util.concurrent.CopyOnWriteArrayList;
 

Modified: incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/SimpleDispatchPolicy.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/SimpleDispatchPolicy.java?rev=359567&r1=359554&r2=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/SimpleDispatchPolicy.java (original)
+++ incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/SimpleDispatchPolicy.java Wed Dec 28 09:24:02 2005
@@ -14,14 +14,14 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package org.activemq.broker.region.policy;
+package org.apache.activemq.broker.region.policy;
 
 import java.util.Iterator;
 
-import org.activemq.broker.ConnectionContext;
-import org.activemq.broker.region.MessageReference;
-import org.activemq.broker.region.Subscription;
-import org.activemq.filter.MessageEvaluationContext;
+import org.apache.activemq.broker.ConnectionContext;
+import org.apache.activemq.broker.region.MessageReference;
+import org.apache.activemq.broker.region.Subscription;
+import org.apache.activemq.filter.MessageEvaluationContext;
 
 import edu.emory.mathcs.backport.java.util.concurrent.CopyOnWriteArrayList;
 

Modified: incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/StrictOrderDispatchPolicy.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/StrictOrderDispatchPolicy.java?rev=359567&r1=359554&r2=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/StrictOrderDispatchPolicy.java (original)
+++ incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/StrictOrderDispatchPolicy.java Wed Dec 28 09:24:02 2005
@@ -14,14 +14,14 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package org.activemq.broker.region.policy;
+package org.apache.activemq.broker.region.policy;
 
 import java.util.Iterator;
 
-import org.activemq.broker.ConnectionContext;
-import org.activemq.broker.region.MessageReference;
-import org.activemq.broker.region.Subscription;
-import org.activemq.filter.MessageEvaluationContext;
+import org.apache.activemq.broker.ConnectionContext;
+import org.apache.activemq.broker.region.MessageReference;
+import org.apache.activemq.broker.region.Subscription;
+import org.apache.activemq.filter.MessageEvaluationContext;
 
 import edu.emory.mathcs.backport.java.util.concurrent.CopyOnWriteArrayList;
 

Modified: incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/SubscriptionRecoveryPolicy.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/SubscriptionRecoveryPolicy.java?rev=359567&r1=359554&r2=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/SubscriptionRecoveryPolicy.java (original)
+++ incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/SubscriptionRecoveryPolicy.java Wed Dec 28 09:24:02 2005
@@ -14,13 +14,13 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package org.activemq.broker.region.policy;
+package org.apache.activemq.broker.region.policy;
 
-import org.activemq.Service;
-import org.activemq.broker.ConnectionContext;
-import org.activemq.broker.region.MessageReference;
-import org.activemq.broker.region.Subscription;
-import org.activemq.broker.region.Topic;
+import org.apache.activemq.Service;
+import org.apache.activemq.broker.ConnectionContext;
+import org.apache.activemq.broker.region.MessageReference;
+import org.apache.activemq.broker.region.Subscription;
+import org.apache.activemq.broker.region.Topic;
 
 /**
  * Abstraction to allow different recovery policies to be plugged

Modified: incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/TimedSubscriptionRecoveryPolicy.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/TimedSubscriptionRecoveryPolicy.java?rev=359567&r1=359554&r2=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/TimedSubscriptionRecoveryPolicy.java (original)
+++ incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/TimedSubscriptionRecoveryPolicy.java Wed Dec 28 09:24:02 2005
@@ -14,7 +14,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package org.activemq.broker.region.policy;
+package org.apache.activemq.broker.region.policy;
 
 import java.util.ArrayList;
 import java.util.Collections;
@@ -22,12 +22,12 @@
 import java.util.LinkedList;
 import java.util.List;
 
-import org.activemq.broker.ConnectionContext;
-import org.activemq.broker.region.MessageReference;
-import org.activemq.broker.region.Subscription;
-import org.activemq.broker.region.Topic;
-import org.activemq.filter.MessageEvaluationContext;
-import org.activemq.thread.Scheduler;
+import org.apache.activemq.broker.ConnectionContext;
+import org.apache.activemq.broker.region.MessageReference;
+import org.apache.activemq.broker.region.Subscription;
+import org.apache.activemq.broker.region.Topic;
+import org.apache.activemq.filter.MessageEvaluationContext;
+import org.apache.activemq.thread.Scheduler;
 
 /**
  * This implementation of {@link SubscriptionRecoveryPolicy} will keep a timed

Modified: incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ActiveMQBytesMessage.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ActiveMQBytesMessage.java?rev=359567&r1=359554&r2=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ActiveMQBytesMessage.java (original)
+++ incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ActiveMQBytesMessage.java Wed Dec 28 09:24:02 2005
@@ -14,7 +14,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package org.activemq.command;
+package org.apache.activemq.command;
 
 import java.io.DataInputStream;
 import java.io.DataOutputStream;
@@ -39,8 +39,8 @@
 import org.activeio.ByteSequence;
 import org.activeio.PacketData;
 import org.activeio.packet.ByteArrayPacket;
-import org.activemq.ActiveMQConnection;
-import org.activemq.util.JMSExceptionSupport;
+import org.apache.activemq.ActiveMQConnection;
+import org.apache.activemq.util.JMSExceptionSupport;
 
 /**
  * A <CODE>BytesMessage</CODE> object is used to send a message containing a stream of uninterpreted bytes. It inherits

Modified: incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ActiveMQDestination.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ActiveMQDestination.java?rev=359567&r1=359554&r2=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ActiveMQDestination.java (original)
+++ incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ActiveMQDestination.java Wed Dec 28 09:24:02 2005
@@ -14,7 +14,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package org.activemq.command;
+package org.apache.activemq.command;
 
 import java.io.Externalizable;
 import java.io.IOException;
@@ -33,7 +33,7 @@
 import javax.jms.TemporaryTopic;
 import javax.jms.Topic;
 
-import org.activemq.util.URISupport;
+import org.apache.activemq.util.URISupport;
 
 /**
  * @openwire:marshaller

Modified: incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ActiveMQMapMessage.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ActiveMQMapMessage.java?rev=359567&r1=359554&r2=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ActiveMQMapMessage.java (original)
+++ incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ActiveMQMapMessage.java Wed Dec 28 09:24:02 2005
@@ -14,7 +14,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package org.activemq.command;
+package org.apache.activemq.command;
 
 import java.io.DataInputStream;
 import java.io.DataOutputStream;
@@ -36,9 +36,9 @@
 import org.activeio.ByteArrayOutputStream;
 import org.activeio.ByteSequence;
 import org.activeio.command.WireFormat;
-import org.activemq.ActiveMQConnection;
-import org.activemq.util.JMSExceptionSupport;
-import org.activemq.util.MarshallingSupport;
+import org.apache.activemq.ActiveMQConnection;
+import org.apache.activemq.util.JMSExceptionSupport;
+import org.apache.activemq.util.MarshallingSupport;
 
 /**
  * A <CODE>MapMessage</CODE> object is used to send a set of name-value pairs. The names are <CODE>String</CODE>

Modified: incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ActiveMQMessage.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ActiveMQMessage.java?rev=359567&r1=359554&r2=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ActiveMQMessage.java (original)
+++ incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ActiveMQMessage.java Wed Dec 28 09:24:02 2005
@@ -14,7 +14,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package org.activemq.command;
+package org.apache.activemq.command;
 
 import java.io.IOException;
 import java.io.UnsupportedEncodingException;
@@ -28,11 +28,11 @@
 import javax.jms.MessageFormatException;
 import javax.jms.MessageNotWriteableException;
 
-import org.activemq.filter.PropertyExpression;
-import org.activemq.state.CommandVisitor;
-import org.activemq.util.Callback;
-import org.activemq.util.JMSExceptionSupport;
-import org.activemq.util.TypeConversionSupport;
+import org.apache.activemq.filter.PropertyExpression;
+import org.apache.activemq.state.CommandVisitor;
+import org.apache.activemq.util.Callback;
+import org.apache.activemq.util.JMSExceptionSupport;
+import org.apache.activemq.util.TypeConversionSupport;
 
 /**
  * @version $Revision$

Modified: incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ActiveMQObjectMessage.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ActiveMQObjectMessage.java?rev=359567&r1=359554&r2=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ActiveMQObjectMessage.java (original)
+++ incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ActiveMQObjectMessage.java Wed Dec 28 09:24:02 2005
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package org.activemq.command;
+package org.apache.activemq.command;
 
 
 
@@ -23,9 +23,9 @@
 import org.activeio.ByteArrayInputStream;
 import org.activeio.ByteArrayOutputStream;
 import org.activeio.ByteSequence;
-import org.activemq.ActiveMQConnection;
-import org.activemq.util.ClassLoading;
-import org.activemq.util.JMSExceptionSupport;
+import org.apache.activemq.ActiveMQConnection;
+import org.apache.activemq.util.ClassLoading;
+import org.apache.activemq.util.JMSExceptionSupport;
 
 import javax.jms.JMSException;
 import javax.jms.ObjectMessage;

Modified: incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ActiveMQQueue.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ActiveMQQueue.java?rev=359567&r1=359554&r2=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ActiveMQQueue.java (original)
+++ incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ActiveMQQueue.java Wed Dec 28 09:24:02 2005
@@ -14,7 +14,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package org.activemq.command;
+package org.apache.activemq.command;
 
 import javax.jms.JMSException;
 import javax.jms.Queue;

Modified: incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ActiveMQStreamMessage.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ActiveMQStreamMessage.java?rev=359567&r1=359554&r2=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ActiveMQStreamMessage.java (original)
+++ incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ActiveMQStreamMessage.java Wed Dec 28 09:24:02 2005
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package org.activemq.command;
+package org.apache.activemq.command;
 
 import javax.jms.JMSException;
 import javax.jms.MessageEOFException;
@@ -27,8 +27,8 @@
 import org.activeio.ByteArrayInputStream;
 import org.activeio.ByteArrayOutputStream;
 import org.activeio.ByteSequence;
-import org.activemq.ActiveMQConnection;
-import org.activemq.util.JMSExceptionSupport;
+import org.apache.activemq.ActiveMQConnection;
+import org.apache.activemq.util.JMSExceptionSupport;
 
 import java.io.BufferedInputStream;
 import java.io.DataInputStream;

Modified: incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ActiveMQTempDestination.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ActiveMQTempDestination.java?rev=359567&r1=359554&r2=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ActiveMQTempDestination.java (original)
+++ incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ActiveMQTempDestination.java Wed Dec 28 09:24:02 2005
@@ -14,11 +14,11 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package org.activemq.command;
+package org.apache.activemq.command;
 
 import javax.jms.JMSException;
 
-import org.activemq.ActiveMQConnection;
+import org.apache.activemq.ActiveMQConnection;
 
 /**
  * @openwire:marshaller

Modified: incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ActiveMQTempQueue.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ActiveMQTempQueue.java?rev=359567&r1=359554&r2=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ActiveMQTempQueue.java (original)
+++ incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ActiveMQTempQueue.java Wed Dec 28 09:24:02 2005
@@ -14,7 +14,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package org.activemq.command;
+package org.apache.activemq.command;
 
 import javax.jms.JMSException;
 import javax.jms.TemporaryQueue;

Modified: incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ActiveMQTempTopic.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ActiveMQTempTopic.java?rev=359567&r1=359554&r2=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ActiveMQTempTopic.java (original)
+++ incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ActiveMQTempTopic.java Wed Dec 28 09:24:02 2005
@@ -14,7 +14,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package org.activemq.command;
+package org.apache.activemq.command;
 
 import javax.jms.JMSException;
 import javax.jms.TemporaryTopic;

Modified: incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ActiveMQTextMessage.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ActiveMQTextMessage.java?rev=359567&r1=359554&r2=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ActiveMQTextMessage.java (original)
+++ incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ActiveMQTextMessage.java Wed Dec 28 09:24:02 2005
@@ -14,7 +14,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package org.activemq.command;
+package org.apache.activemq.command;
 
 import java.io.DataInputStream;
 import java.io.DataOutputStream;
@@ -32,9 +32,9 @@
 import org.activeio.ByteArrayOutputStream;
 import org.activeio.ByteSequence;
 import org.activeio.command.WireFormat;
-import org.activemq.ActiveMQConnection;
-import org.activemq.util.JMSExceptionSupport;
-import org.activemq.util.MarshallingSupport;
+import org.apache.activemq.ActiveMQConnection;
+import org.apache.activemq.util.JMSExceptionSupport;
+import org.apache.activemq.util.MarshallingSupport;
 
 /**
  * 

Modified: incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ActiveMQTopic.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ActiveMQTopic.java?rev=359567&r1=359554&r2=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ActiveMQTopic.java (original)
+++ incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ActiveMQTopic.java Wed Dec 28 09:24:02 2005
@@ -14,7 +14,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package org.activemq.command;
+package org.apache.activemq.command;
 
 import javax.jms.JMSException;
 import javax.jms.Topic;

Modified: incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/BaseCommand.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/BaseCommand.java?rev=359567&r1=359554&r2=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/BaseCommand.java (original)
+++ incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/BaseCommand.java Wed Dec 28 09:24:02 2005
@@ -14,7 +14,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package org.activemq.command;
+package org.apache.activemq.command;
 
 import java.lang.reflect.Field;
 import java.lang.reflect.Modifier;

Modified: incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/BrokerId.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/BrokerId.java?rev=359567&r1=359554&r2=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/BrokerId.java (original)
+++ incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/BrokerId.java Wed Dec 28 09:24:02 2005
@@ -14,7 +14,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package org.activemq.command;
+package org.apache.activemq.command;
 
 
 /**

Modified: incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/BrokerInfo.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/BrokerInfo.java?rev=359567&r1=359554&r2=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/BrokerInfo.java (original)
+++ incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/BrokerInfo.java Wed Dec 28 09:24:02 2005
@@ -14,9 +14,9 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package org.activemq.command;
+package org.apache.activemq.command;
 
-import org.activemq.state.CommandVisitor;
+import org.apache.activemq.state.CommandVisitor;
 
 
 /**

Modified: incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/Command.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/Command.java?rev=359567&r1=359554&r2=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/Command.java (original)
+++ incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/Command.java Wed Dec 28 09:24:02 2005
@@ -14,9 +14,9 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package org.activemq.command;
+package org.apache.activemq.command;
 
-import org.activemq.state.CommandVisitor;
+import org.apache.activemq.state.CommandVisitor;
 
 /**
  * The Command Pattern so that we can send and receive commands

Modified: incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/CommandTypes.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/CommandTypes.java?rev=359567&r1=359554&r2=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/CommandTypes.java (original)
+++ incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/CommandTypes.java Wed Dec 28 09:24:02 2005
@@ -14,7 +14,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package org.activemq.command;
+package org.apache.activemq.command;
 
 /**
  * Holds the command id constants used by the command objects.

Modified: incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ConnectionId.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ConnectionId.java?rev=359567&r1=359554&r2=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ConnectionId.java (original)
+++ incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ConnectionId.java Wed Dec 28 09:24:02 2005
@@ -14,7 +14,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package org.activemq.command;
+package org.apache.activemq.command;
 
 
 /**

Modified: incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ConnectionInfo.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ConnectionInfo.java?rev=359567&r1=359554&r2=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ConnectionInfo.java (original)
+++ incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ConnectionInfo.java Wed Dec 28 09:24:02 2005
@@ -14,9 +14,9 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package org.activemq.command;
+package org.apache.activemq.command;
 
-import org.activemq.state.CommandVisitor;
+import org.apache.activemq.state.CommandVisitor;
 
 
 /**

Modified: incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ConsumerId.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ConsumerId.java?rev=359567&r1=359554&r2=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ConsumerId.java (original)
+++ incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ConsumerId.java Wed Dec 28 09:24:02 2005
@@ -14,7 +14,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package org.activemq.command;
+package org.apache.activemq.command;
 
 
 /**

Modified: incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ConsumerInfo.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ConsumerInfo.java?rev=359567&r1=359554&r2=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ConsumerInfo.java (original)
+++ incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ConsumerInfo.java Wed Dec 28 09:24:02 2005
@@ -14,10 +14,10 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package org.activemq.command;
+package org.apache.activemq.command;
 
-import org.activemq.filter.BooleanExpression;
-import org.activemq.state.CommandVisitor;
+import org.apache.activemq.filter.BooleanExpression;
+import org.apache.activemq.state.CommandVisitor;
 
 
 /**

Modified: incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ControlCommand.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ControlCommand.java?rev=359567&r1=359554&r2=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ControlCommand.java (original)
+++ incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ControlCommand.java Wed Dec 28 09:24:02 2005
@@ -14,9 +14,9 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package org.activemq.command;
+package org.apache.activemq.command;
 
-import org.activemq.state.CommandVisitor;
+import org.apache.activemq.state.CommandVisitor;
 
 /**
  * Used to start and stop transports as well as terminating clients.

Modified: incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/DataArrayResponse.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/DataArrayResponse.java?rev=359567&r1=359554&r2=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/DataArrayResponse.java (original)
+++ incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/DataArrayResponse.java Wed Dec 28 09:24:02 2005
@@ -14,7 +14,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package org.activemq.command;
+package org.apache.activemq.command;
 
 /**
  * 

Modified: incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/DataResponse.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/DataResponse.java?rev=359567&r1=359554&r2=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/DataResponse.java (original)
+++ incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/DataResponse.java Wed Dec 28 09:24:02 2005
@@ -14,7 +14,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package org.activemq.command;
+package org.apache.activemq.command;
 
 /**
  * 

Modified: incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/DataStructure.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/DataStructure.java?rev=359567&r1=359554&r2=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/DataStructure.java (original)
+++ incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/DataStructure.java Wed Dec 28 09:24:02 2005
@@ -16,7 +16,7 @@
 * limitations under the License.
 *
 **/
-package org.activemq.command;
+package org.apache.activemq.command;
 
 /**
  * @version $Revision$

Modified: incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/DestinationInfo.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/DestinationInfo.java?rev=359567&r1=359554&r2=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/DestinationInfo.java (original)
+++ incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/DestinationInfo.java Wed Dec 28 09:24:02 2005
@@ -14,11 +14,11 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package org.activemq.command;
+package org.apache.activemq.command;
 
 import java.io.IOException;
 
-import org.activemq.state.CommandVisitor;
+import org.apache.activemq.state.CommandVisitor;
 
 /**
  * Used to create and destroy destinations on the broker.

Modified: incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/DiscoveryEvent.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/DiscoveryEvent.java?rev=359567&r1=359554&r2=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/DiscoveryEvent.java (original)
+++ incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/DiscoveryEvent.java Wed Dec 28 09:24:02 2005
@@ -14,7 +14,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package org.activemq.command;
+package org.apache.activemq.command;
 
 
 /**

Modified: incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ExceptionResponse.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ExceptionResponse.java?rev=359567&r1=359554&r2=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ExceptionResponse.java (original)
+++ incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ExceptionResponse.java Wed Dec 28 09:24:02 2005
@@ -14,7 +14,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package org.activemq.command;
+package org.apache.activemq.command;
 
 /**
  * 

Modified: incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/FlushCommand.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/FlushCommand.java?rev=359567&r1=359554&r2=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/FlushCommand.java (original)
+++ incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/FlushCommand.java Wed Dec 28 09:24:02 2005
@@ -14,9 +14,9 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package org.activemq.command;
+package org.apache.activemq.command;
 
-import org.activemq.state.CommandVisitor;
+import org.apache.activemq.state.CommandVisitor;
 
 /**
  * An indication to the transport layer that a flush is required.

Modified: incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/IntegerResponse.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/IntegerResponse.java?rev=359567&r1=359554&r2=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/IntegerResponse.java (original)
+++ incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/IntegerResponse.java Wed Dec 28 09:24:02 2005
@@ -14,7 +14,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package org.activemq.command;
+package org.apache.activemq.command;
 
 /**
  * 

Modified: incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/JournalQueueAck.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/JournalQueueAck.java?rev=359567&r1=359554&r2=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/JournalQueueAck.java (original)
+++ incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/JournalQueueAck.java Wed Dec 28 09:24:02 2005
@@ -14,7 +14,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package org.activemq.command;
+package org.apache.activemq.command;
 
 /**
  * 

Modified: incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/JournalTopicAck.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/JournalTopicAck.java?rev=359567&r1=359554&r2=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/JournalTopicAck.java (original)
+++ incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/JournalTopicAck.java Wed Dec 28 09:24:02 2005
@@ -14,7 +14,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package org.activemq.command;
+package org.apache.activemq.command;
 
 /**
  * 

Modified: incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/JournalTrace.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/JournalTrace.java?rev=359567&r1=359554&r2=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/JournalTrace.java (original)
+++ incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/JournalTrace.java Wed Dec 28 09:24:02 2005
@@ -14,7 +14,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package org.activemq.command;
+package org.apache.activemq.command;
 
 /**
  * 

Modified: incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/JournalTransaction.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/JournalTransaction.java?rev=359567&r1=359554&r2=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/JournalTransaction.java (original)
+++ incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/JournalTransaction.java Wed Dec 28 09:24:02 2005
@@ -14,7 +14,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package org.activemq.command;
+package org.apache.activemq.command;
 
 
 /**

Modified: incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/KeepAliveInfo.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/KeepAliveInfo.java?rev=359567&r1=359554&r2=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/KeepAliveInfo.java (original)
+++ incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/KeepAliveInfo.java Wed Dec 28 09:24:02 2005
@@ -14,9 +14,9 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package org.activemq.command;
+package org.apache.activemq.command;
 
-import org.activemq.state.CommandVisitor;
+import org.apache.activemq.state.CommandVisitor;
 
 /**
  * @openwire:marshaller

Modified: incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/LocalTransactionId.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/LocalTransactionId.java?rev=359567&r1=359554&r2=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/LocalTransactionId.java (original)
+++ incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/LocalTransactionId.java Wed Dec 28 09:24:02 2005
@@ -14,7 +14,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package org.activemq.command;
+package org.apache.activemq.command;
 
 /**
  * @openwire:marshaller

Modified: incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/MarshallAware.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/MarshallAware.java?rev=359567&r1=359554&r2=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/MarshallAware.java (original)
+++ incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/MarshallAware.java Wed Dec 28 09:24:02 2005
@@ -14,7 +14,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package org.activemq.command;
+package org.apache.activemq.command;
 
 import java.io.IOException;
 

Modified: incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/Message.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/Message.java?rev=359567&r1=359554&r2=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/Message.java (original)
+++ incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/Message.java Wed Dec 28 09:24:02 2005
@@ -14,7 +14,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package org.activemq.command;
+package org.apache.activemq.command;
 
 import java.io.DataInputStream;
 import java.io.DataOutputStream;
@@ -27,10 +27,10 @@
 import org.activeio.ByteArrayOutputStream;
 import org.activeio.ByteSequence;
 import org.activeio.command.WireFormat;
-import org.activemq.ActiveMQConnection;
-import org.activemq.advisory.AdvisorySupport;
-import org.activemq.broker.region.MessageReference;
-import org.activemq.util.MarshallingSupport;
+import org.apache.activemq.ActiveMQConnection;
+import org.apache.activemq.advisory.AdvisorySupport;
+import org.apache.activemq.broker.region.MessageReference;
+import org.apache.activemq.util.MarshallingSupport;
 
 /**
  * Represents an ActiveMQ message
@@ -78,7 +78,7 @@
     private BrokerId [] brokerPath;
     private transient short referenceCount;
     private transient ActiveMQConnection connection;
-    private transient org.activemq.broker.region.Destination regionDestination;
+    private transient org.apache.activemq.broker.region.Destination regionDestination;
     private WireFormat cachedWireFormat;
     private ByteSequence cachedWireFormatData;
     
@@ -516,11 +516,11 @@
         return this;
     }
 
-    public org.activemq.broker.region.Destination getRegionDestination() {
+    public org.apache.activemq.broker.region.Destination getRegionDestination() {
         return regionDestination;
     }
 
-    public void setRegionDestination(org.activemq.broker.region.Destination destination) {
+    public void setRegionDestination(org.apache.activemq.broker.region.Destination destination) {
         this.regionDestination = destination;
     }
 

Modified: incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/MessageAck.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/MessageAck.java?rev=359567&r1=359554&r2=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/MessageAck.java (original)
+++ incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/MessageAck.java Wed Dec 28 09:24:02 2005
@@ -14,9 +14,9 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package org.activemq.command;
+package org.apache.activemq.command;
 
-import org.activemq.state.CommandVisitor;
+import org.apache.activemq.state.CommandVisitor;
 
 
 /**

Modified: incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/MessageDispatch.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/MessageDispatch.java?rev=359567&r1=359554&r2=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/MessageDispatch.java (original)
+++ incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/MessageDispatch.java Wed Dec 28 09:24:02 2005
@@ -14,9 +14,9 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package org.activemq.command;
+package org.apache.activemq.command;
 
-import org.activemq.state.CommandVisitor;
+import org.apache.activemq.state.CommandVisitor;
 
 
 /**

Modified: incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/MessageId.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/MessageId.java?rev=359567&r1=359554&r2=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/MessageId.java (original)
+++ incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/MessageId.java Wed Dec 28 09:24:02 2005
@@ -14,7 +14,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package org.activemq.command;
+package org.apache.activemq.command;
 
 
 /**

Modified: incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ProducerId.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ProducerId.java?rev=359567&r1=359554&r2=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ProducerId.java (original)
+++ incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ProducerId.java Wed Dec 28 09:24:02 2005
@@ -14,7 +14,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package org.activemq.command;
+package org.apache.activemq.command;
 
 /**
  * 



Mime
View raw message