AMQ-4885: Renamed some API methods in MessageStore due typos.

activemq-broker/src/main/java/org/apache/activemq/broker/region/Topic.java

@@ -255,7 +255,7 @@ public class Topic extends BaseDestination implements Task {
                 // This destination might be a pattern
                 synchronized (consumers) {
                     consumers.add(subscription);
-                    topicStore.addSubsciption(info, subscription.getConsumerInfo().isRetroactive());
+                    topicStore.addSubscription(info, subscription.getConsumerInfo().isRetroactive());
                 }
             }
 

activemq-broker/src/main/java/org/apache/activemq/store/MessageStore.java

@@ -147,10 +147,10 @@ public interface MessageStore extends Service {
     ActiveMQDestination getDestination();
 
     /**
-     * @param memoeyUSage The SystemUsage that is controlling the
+     * @param memoryUsage The SystemUsage that is controlling the
      *                destination's memory usage.
      */
-    void setMemoryUsage(MemoryUsage memoeyUSage);
+    void setMemoryUsage(MemoryUsage memoryUsage);
 
     /**
      * @return the number of messages ready to deliver

activemq-broker/src/main/java/org/apache/activemq/store/ProxyTopicMessageStore.java

@@ -94,8 +94,8 @@ public class ProxyTopicMessageStore implements TopicMessageStore {
     }
 
     @Override
-    public void addSubsciption(SubscriptionInfo subscriptionInfo, boolean retroactive) throws IOException {
+    public void addSubscription(SubscriptionInfo subscriptionInfo, boolean retroactive) throws IOException {
-        delegate.addSubsciption(subscriptionInfo, retroactive);
+        delegate.addSubscription(subscriptionInfo, retroactive);
     }
 
     @Override

activemq-broker/src/main/java/org/apache/activemq/store/TopicMessageStore.java

@@ -129,5 +129,5 @@ public interface TopicMessageStore extends MessageStore {
      * @param retroactive
      * @throws IOException
      */
-    void addSubsciption(SubscriptionInfo subscriptionInfo, boolean retroactive) throws IOException;
+    void addSubscription(SubscriptionInfo subscriptionInfo, boolean retroactive) throws IOException;
 }

activemq-broker/src/main/java/org/apache/activemq/store/memory/MemoryTopicMessageStore.java

@@ -80,7 +80,7 @@ public class MemoryTopicMessageStore extends MemoryMessageStore implements Topic
         return subscriberDatabase.get(new SubscriptionKey(clientId, subscriptionName));
     }
 
-    public synchronized void addSubsciption(SubscriptionInfo info, boolean retroactive) throws IOException {
+    public synchronized void addSubscription(SubscriptionInfo info, boolean retroactive) throws IOException {
         SubscriptionKey key = new SubscriptionKey(info);
         MemoryTopicSub sub = new MemoryTopicSub();
         topicSubMap.put(key, sub);

activemq-jdbc-store/src/main/java/org/apache/activemq/store/jdbc/JDBCTopicMessageStore.java

@@ -330,7 +330,7 @@ public class JDBCTopicMessageStore extends JDBCMessageStore implements TopicMess
     }
 
 
-    public void addSubsciption(SubscriptionInfo subscriptionInfo, boolean retroactive) throws IOException {
+    public void addSubscription(SubscriptionInfo subscriptionInfo, boolean retroactive) throws IOException {
         TransactionContext c = persistenceAdapter.getTransactionContext();
         try {
             c = persistenceAdapter.getTransactionContext();

activemq-jdbc-store/src/main/java/org/apache/activemq/store/journal/JournalTopicMessageStore.java

@@ -71,9 +71,9 @@ public class JournalTopicMessageStore extends JournalMessageStore implements Top
         return longTermStore.lookupSubscription(clientId, subscriptionName);
     }
 
-    public void addSubsciption(SubscriptionInfo subscriptionInfo, boolean retroactive) throws IOException {
+    public void addSubscription(SubscriptionInfo subscriptionInfo, boolean retroactive) throws IOException {
         this.peristenceAdapter.checkpoint(true, true);
-        longTermStore.addSubsciption(subscriptionInfo, retroactive);
+        longTermStore.addSubscription(subscriptionInfo, retroactive);
     }
 
     public void addMessage(ConnectionContext context, Message message) throws IOException {

activemq-kahadb-store/src/main/java/org/apache/activemq/store/kahadb/KahaDBStore.java

@@ -662,7 +662,7 @@ public class KahaDBStore extends MessageDatabase implements PersistenceAdapter {
         }
 
         @Override
-        public void setMemoryUsage(MemoryUsage memoeyUSage) {
+        public void setMemoryUsage(MemoryUsage memoryUsage) {
         }
         @Override
         public void start() throws Exception {
@@ -765,7 +765,7 @@ public class KahaDBStore extends MessageDatabase implements PersistenceAdapter {
         }
 
         @Override
-        public void addSubsciption(SubscriptionInfo subscriptionInfo, boolean retroactive) throws IOException {
+        public void addSubscription(SubscriptionInfo subscriptionInfo, boolean retroactive) throws IOException {
             String subscriptionKey = subscriptionKey(subscriptionInfo.getClientId(), subscriptionInfo
                     .getSubscriptionName());
             KahaSubscriptionCommand command = new KahaSubscriptionCommand();

activemq-kahadb-store/src/main/java/org/apache/activemq/store/kahadb/TempKahaDBStore.java

@@ -265,7 +265,7 @@ public class TempKahaDBStore extends TempMessageDatabase implements PersistenceA
         }
 
         @Override
-        public void setMemoryUsage(MemoryUsage memoeyUSage) {
+        public void setMemoryUsage(MemoryUsage memoryUsage) {
         }
         @Override
         public void start() throws Exception {
@@ -294,7 +294,7 @@ public class TempKahaDBStore extends TempMessageDatabase implements PersistenceA
             processRemove(command, null);
         }
 
-        public void addSubsciption(SubscriptionInfo subscriptionInfo, boolean retroactive) throws IOException {
+        public void addSubscription(SubscriptionInfo subscriptionInfo, boolean retroactive) throws IOException {
             String subscriptionKey = subscriptionKey(subscriptionInfo.getClientId(), subscriptionInfo.getSubscriptionName());
             KahaSubscriptionCommand command = new KahaSubscriptionCommand();
             command.setDestination(dest);

activemq-leveldb-store/src/main/scala/org/apache/activemq/leveldb/LevelDBStore.scala

@@ -816,7 +816,7 @@ class LevelDBStore extends LockableServiceSupport with BrokerServiceAware with P
       }
     }
 
-    def addSubsciption(info: SubscriptionInfo, retroactive: Boolean) = {
+    def addSubscription(info: SubscriptionInfo, retroactive: Boolean) = {
       check_running
       var sub = db.addSubscription(key, info)
       subscriptions.synchronized {