Mailing-List: contact commits-help@activemq.apache.org; run by ezmlm
Precedence: bulk
Reply-To: dev@activemq.apache.org
Content-Type: text/plain; charset="us-ascii"
MIME-Version: 1.0
Content-Transfer-Encoding: 7bit
From: martyntaylor@apache.org
To: commits@activemq.apache.org
Date: Wed, 30 Nov 2016 13:27:26 -0000
Message-Id: <9bc7a939a7fe49d39855b78b91455c44@git.apache.org>
In-Reply-To: <7d18ccd20710483dbd128f0b5ff1b2bb@git.apache.org>
References: <7d18ccd20710483dbd128f0b5ff1b2bb@git.apache.org>
Subject: [06/27] activemq-artemis git commit: Spelling fix
archived-at: Wed, 30 Nov 2016 13:27:58 -0000

Spelling fix


Project: http://git-wip-us.apache.org/repos/asf/activemq-artemis/repo
Commit: http://git-wip-us.apache.org/repos/asf/activemq-artemis/commit/842c5e5d
Tree: http://git-wip-us.apache.org/repos/asf/activemq-artemis/tree/842c5e5d
Diff: http://git-wip-us.apache.org/repos/asf/activemq-artemis/diff/842c5e5d

Branch: refs/heads/ARTEMIS-780
Commit: 842c5e5d8728655f3609fdbbd3e63fe29c047623
Parents: 617a02b
Author: jbertram <jbertram@apache.com>
Authored: Mon Nov 28 15:32:14 2016 -0600
Committer: jbertram <jbertram@apache.com>
Committed: Mon Nov 28 15:32:14 2016 -0600

----------------------------------------------------------------------
 .../jms/tests/AutoAckMesageListenerTest.java    | 141 -------------------
 .../jms/tests/AutoAckMessageListenerTest.java   | 141 +++++++++++++++++++
 2 files changed, 141 insertions(+), 141 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/842c5e5d/tests/jms-tests/src/test/java/org/apache/activemq/artemis/jms/tests/AutoAckMesageListenerTest.java
----------------------------------------------------------------------
diff --git a/tests/jms-tests/src/test/java/org/apache/activemq/artemis/jms/tests/AutoAckMesageListenerTest.java b/tests/jms-tests/src/test/java/org/apache/activemq/artemis/jms/tests/AutoAckMesageListenerTest.java
deleted file mode 100644
index e7877ce..0000000
--- a/tests/jms-tests/src/test/java/org/apache/activemq/artemis/jms/tests/AutoAckMesageListenerTest.java
+++ /dev/null
@@ -1,141 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License. You may obtain a copy of the License at
- *
- *     http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-package org.apache.activemq.artemis.jms.tests;
-
-import javax.jms.Connection;
-import javax.jms.JMSException;
-import javax.jms.Message;
-import javax.jms.MessageConsumer;
-import javax.jms.MessageListener;
-import javax.jms.MessageProducer;
-import javax.jms.Session;
-import java.util.concurrent.CountDownLatch;
-import java.util.concurrent.TimeUnit;
-
-import org.junit.Test;
-
-public class AutoAckMesageListenerTest extends JMSTestCase {
-
-   // Constants -----------------------------------------------------
-
-   private static final JmsTestLogger log = JmsTestLogger.LOGGER;
-
-   // Attributes ----------------------------------------------------
-
-   // Static --------------------------------------------------------
-
-   // Constructors --------------------------------------------------
-
-   // Public --------------------------------------------------------
-
-   @Test
-   public void testAutoAckMsgListenerQueue() throws Exception {
-      Connection conn = null;
-
-      try {
-         CountDownLatch latch = new CountDownLatch(1);
-
-         conn = createConnection();
-         Session session = conn.createSession(false, Session.AUTO_ACKNOWLEDGE);
-         MessageProducer producer = session.createProducer(queue1);
-         MessageConsumer consumer = session.createConsumer(queue1);
-         AutoAckMsgListener listener = new AutoAckMsgListener(latch, session);
-         consumer.setMessageListener(listener);
-
-         // create and send messages
-         log.info("Send and receive two message");
-         Message messageSent = session.createMessage();
-         messageSent.setBooleanProperty("last", false);
-         producer.send(messageSent);
-         messageSent.setBooleanProperty("last", true);
-         producer.send(messageSent);
-
-         conn.start();
-
-         // wait until message is received
-         log.info("waiting until message has been received by message listener...");
-         latch.await(10, TimeUnit.SECONDS);
-
-         // check message listener status
-         if (listener.getPassed() == false) {
-            throw new Exception("failed");
-         }
-      } finally {
-         if (conn != null) {
-            conn.close();
-         }
-      }
-   }
-
-   // Package protected ---------------------------------------------
-
-   // Protected -----------------------------------------------------
-
-   // Private -------------------------------------------------------
-
-   // Inner classes -------------------------------------------------
-
-   private static class AutoAckMsgListener implements MessageListener {
-
-      private boolean passed;
-
-      private final Session session;
-
-      private final CountDownLatch monitor;
-
-      private AutoAckMsgListener(CountDownLatch latch, Session session) {
-         this.monitor = latch;
-         this.session = session;
-      }
-
-      // get state of test
-      public boolean getPassed() {
-         return passed;
-      }
-
-      // will receive two messages
-      @Override
-      public void onMessage(Message message) {
-         try {
-            if (message.getBooleanProperty("last") == false) {
-               log.info("Received first message.");
-               if (message.getJMSRedelivered() == true) {
-                  // should not re-receive this one
-                  log.info("Error: received first message twice");
-                  passed = false;
-               }
-            } else {
-               if (message.getJMSRedelivered() == false) {
-                  // received second message for first time
-                  log.info("Received second message. Calling recover()");
-                  session.recover();
-               } else {
-                  // should be redelivered after recover
-                  log.info("Received second message again as expected");
-                  passed = true;
-                  monitor.countDown();
-               }
-            }
-         } catch (JMSException e) {
-            log.warn("Exception caught in message listener:\n" + e);
-            passed = false;
-            monitor.countDown();
-         }
-
-      }
-   }
-}

http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/842c5e5d/tests/jms-tests/src/test/java/org/apache/activemq/artemis/jms/tests/AutoAckMessageListenerTest.java
----------------------------------------------------------------------
diff --git a/tests/jms-tests/src/test/java/org/apache/activemq/artemis/jms/tests/AutoAckMessageListenerTest.java b/tests/jms-tests/src/test/java/org/apache/activemq/artemis/jms/tests/AutoAckMessageListenerTest.java
new file mode 100644
index 0000000..b667c58
--- /dev/null
+++ b/tests/jms-tests/src/test/java/org/apache/activemq/artemis/jms/tests/AutoAckMessageListenerTest.java
@@ -0,0 +1,141 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.activemq.artemis.jms.tests;
+
+import javax.jms.Connection;
+import javax.jms.JMSException;
+import javax.jms.Message;
+import javax.jms.MessageConsumer;
+import javax.jms.MessageListener;
+import javax.jms.MessageProducer;
+import javax.jms.Session;
+import java.util.concurrent.CountDownLatch;
+import java.util.concurrent.TimeUnit;
+
+import org.junit.Test;
+
+public class AutoAckMessageListenerTest extends JMSTestCase {
+
+   // Constants -----------------------------------------------------
+
+   private static final JmsTestLogger log = JmsTestLogger.LOGGER;
+
+   // Attributes ----------------------------------------------------
+
+   // Static --------------------------------------------------------
+
+   // Constructors --------------------------------------------------
+
+   // Public --------------------------------------------------------
+
+   @Test
+   public void testAutoAckMsgListenerQueue() throws Exception {
+      Connection conn = null;
+
+      try {
+         CountDownLatch latch = new CountDownLatch(1);
+
+         conn = createConnection();
+         Session session = conn.createSession(false, Session.AUTO_ACKNOWLEDGE);
+         MessageProducer producer = session.createProducer(queue1);
+         MessageConsumer consumer = session.createConsumer(queue1);
+         AutoAckMsgListener listener = new AutoAckMsgListener(latch, session);
+         consumer.setMessageListener(listener);
+
+         // create and send messages
+         log.info("Send and receive two message");
+         Message messageSent = session.createMessage();
+         messageSent.setBooleanProperty("last", false);
+         producer.send(messageSent);
+         messageSent.setBooleanProperty("last", true);
+         producer.send(messageSent);
+
+         conn.start();
+
+         // wait until message is received
+         log.info("waiting until message has been received by message listener...");
+         latch.await(10, TimeUnit.SECONDS);
+
+         // check message listener status
+         if (listener.getPassed() == false) {
+            throw new Exception("failed");
+         }
+      } finally {
+         if (conn != null) {
+            conn.close();
+         }
+      }
+   }
+
+   // Package protected ---------------------------------------------
+
+   // Protected -----------------------------------------------------
+
+   // Private -------------------------------------------------------
+
+   // Inner classes -------------------------------------------------
+
+   private static class AutoAckMsgListener implements MessageListener {
+
+      private boolean passed;
+
+      private final Session session;
+
+      private final CountDownLatch monitor;
+
+      private AutoAckMsgListener(CountDownLatch latch, Session session) {
+         this.monitor = latch;
+         this.session = session;
+      }
+
+      // get state of test
+      public boolean getPassed() {
+         return passed;
+      }
+
+      // will receive two messages
+      @Override
+      public void onMessage(Message message) {
+         try {
+            if (message.getBooleanProperty("last") == false) {
+               log.info("Received first message.");
+               if (message.getJMSRedelivered() == true) {
+                  // should not re-receive this one
+                  log.info("Error: received first message twice");
+                  passed = false;
+               }
+            } else {
+               if (message.getJMSRedelivered() == false) {
+                  // received second message for first time
+                  log.info("Received second message. Calling recover()");
+                  session.recover();
+               } else {
+                  // should be redelivered after recover
+                  log.info("Received second message again as expected");
+                  passed = true;
+                  monitor.countDown();
+               }
+            }
+         } catch (JMSException e) {
+            log.warn("Exception caught in message listener:\n" + e);
+            passed = false;
+            monitor.countDown();
+         }
+
+      }
+   }
+}