Author: rupertlssmith
Date: Wed Jan 23 02:24:30 2008
New Revision: 614482
URL: http://svn.apache.org/viewvc?rev=614482&view=rev
Log:
Qpid-755, Corrected license header.
Modified:
incubator/qpid/branches/M2.1/java/client/src/test/java/org/apache/qpid/test/unit/topic/DurableSubscriptionTest.java
Modified:
incubator/qpid/branches/M2.1/java/client/src/test/java/org/apache/qpid/test/unit/topic/DurableSubscriptionTest.java
URL:
http://svn.apache.org/viewvc/incubator/qpid/branches/M2.1/java/client/src/test/java/org/apache/qpid/test/unit/topic/DurableSubscriptionTest.java?rev=614482&r1=614481&r2=614482&view=diff
==============================================================================
---
incubator/qpid/branches/M2.1/java/client/src/test/java/org/apache/qpid/test/unit/topic/DurableSubscriptionTest.java
(original)
+++
incubator/qpid/branches/M2.1/java/client/src/test/java/org/apache/qpid/test/unit/topic/DurableSubscriptionTest.java
Wed Jan 23 02:24:30 2008
@@ -1,14 +1,25 @@
-/* Copyright Rupert Smith, 2005 to 2007, all rights reserved. */
+/*
+ *
+ * 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.qpid.test.unit.topic;
-import javax.jms.JMSException;
-import javax.jms.Message;
-import javax.jms.MessageConsumer;
-import javax.jms.MessageProducer;
-import javax.jms.Session;
-import javax.jms.TextMessage;
-import javax.jms.TopicSubscriber;
-
import junit.framework.TestCase;
import org.apache.qpid.AMQException;
@@ -21,6 +32,14 @@
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
+import javax.jms.JMSException;
+import javax.jms.Message;
+import javax.jms.MessageConsumer;
+import javax.jms.MessageProducer;
+import javax.jms.Session;
+import javax.jms.TextMessage;
+import javax.jms.TopicSubscriber;
+
/**
* @todo Code to check that a consumer gets only one particular method could
be factored into a re-usable method (as
* a static on a base test helper class, e.g. TestUtils.
@@ -70,14 +89,14 @@
Message msg;
_logger.info("Receive message on consumer 1:expecting A");
msg = consumer1.receive();
- assertEquals("A", ((TextMessage)msg).getText());
+ assertEquals("A", ((TextMessage) msg).getText());
_logger.info("Receive message on consumer 1 :expecting null");
msg = consumer1.receive(1000);
assertEquals(null, msg);
_logger.info("Receive message on consumer 1:expecting A");
msg = consumer2.receive();
- assertEquals("A", ((TextMessage)msg).getText());
+ assertEquals("A", ((TextMessage) msg).getText());
msg = consumer2.receive(1000);
_logger.info("Receive message on consumer 1 :expecting null");
assertEquals(null, msg);
@@ -90,7 +109,7 @@
_logger.info("Receive message on consumer 1 :expecting B");
msg = consumer1.receive();
- assertEquals("B", ((TextMessage)msg).getText());
+ assertEquals("B", ((TextMessage) msg).getText());
_logger.info("Receive message on consumer 1 :expecting null");
msg = consumer1.receive(1000);
assertEquals(null, msg);
@@ -143,14 +162,14 @@
Message msg;
msg = consumer1.receive(500);
assertNotNull("Message should be available", msg);
- assertEquals("Message Text doesn't match", "A",
((TextMessage)msg).getText());
+ assertEquals("Message Text doesn't match", "A", ((TextMessage)
msg).getText());
msg = consumer1.receive(500);
assertNull("There should be no more messages for consumption on
consumer1.", msg);
msg = consumer2.receive();
assertNotNull(msg);
- assertEquals("Consumer 2 should also received the first msg.", "A",
((TextMessage)msg).getText());
+ assertEquals("Consumer 2 should also received the first msg.", "A",
((TextMessage) msg).getText());
msg = consumer2.receive(500);
assertNull("There should be no more messages for consumption on
consumer2.", msg);
@@ -161,7 +180,7 @@
_logger.info("Receive message on consumer 1 :expecting B");
msg = consumer1.receive(500);
assertNotNull("Consumer 1 should get message 'B'.", msg);
- assertEquals("Incorrect Message recevied on consumer1.", "B",
((TextMessage)msg).getText());
+ assertEquals("Incorrect Message recevied on consumer1.", "B",
((TextMessage) msg).getText());
_logger.info("Receive message on consumer 1 :expecting null");
msg = consumer1.receive(500);
assertNull("There should be no more messages for consumption on
consumer1.", msg);
@@ -172,7 +191,7 @@
_logger.info("Receive message on consumer 3 :expecting B");
msg = consumer3.receive(500);
assertNotNull("Consumer 3 should get message 'B'.", msg);
- assertEquals("Incorrect Message recevied on consumer4.", "B",
((TextMessage)msg).getText());
+ assertEquals("Incorrect Message recevied on consumer4.", "B",
((TextMessage) msg).getText());
_logger.info("Receive message on consumer 3 :expecting null");
msg = consumer3.receive(500);
assertNull("There should be no more messages for consumption on
consumer3.", msg);
@@ -216,13 +235,13 @@
msg = consumer1.receive(500);
assertNotNull("Message should be available", msg);
- assertEquals("Message Text doesn't match", "A",
((TextMessage)msg).getText());
+ assertEquals("Message Text doesn't match", "A", ((TextMessage)
msg).getText());
msg = consumer1.receive(500);
assertNull("There should be no more messages for consumption on
consumer1.", msg);
msg = consumer2.receive();
assertNotNull(msg);
- assertEquals("Consumer 2 should also received the first msg.", "A",
((TextMessage)msg).getText());
+ assertEquals("Consumer 2 should also received the first msg.", "A",
((TextMessage) msg).getText());
msg = consumer2.receive(500);
assertNull("There should be no more messages for consumption on
consumer2.", msg);
@@ -237,7 +256,7 @@
_logger.info("Receive message on consumer 1 :expecting B");
msg = consumer1.receive(500);
assertNotNull("Consumer 1 should get message 'B'.", msg);
- assertEquals("Incorrect Message recevied on consumer1.", "B",
((TextMessage)msg).getText());
+ assertEquals("Incorrect Message recevied on consumer1.", "B",
((TextMessage) msg).getText());
_logger.info("Receive message on consumer 1 :expecting null");
msg = consumer1.receive(500);
assertNull("There should be no more messages for consumption on
consumer1.", msg);
@@ -252,7 +271,7 @@
_logger.info("Receive message on consumer 3 :expecting B");
msg = consumer3.receive(500);
assertNotNull("Consumer 3 should get message 'B'.", msg);
- assertEquals("Incorrect Message recevied on consumer4.", "B",
((TextMessage)msg).getText());
+ assertEquals("Incorrect Message recevied on consumer4.", "B",
((TextMessage) msg).getText());
_logger.info("Receive message on consumer 3 :expecting null");
msg = consumer3.receive(500);
assertNull("There should be no more messages for consumption on
consumer3.", msg);
