Author: jstrachan
Date: Thu Nov 16 02:56:07 2006
New Revision: 475680
URL: http://svn.apache.org/viewvc?view=rev&rev=475680
Log:
added test case for AMQ-1027
Added:
incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/transport/failover/FailoverConsumerTest.java
(with props)
Modified:
incubator/activemq/trunk/activemq-core/pom.xml
Modified: incubator/activemq/trunk/activemq-core/pom.xml
URL:
http://svn.apache.org/viewvc/incubator/activemq/trunk/activemq-core/pom.xml?view=diff&rev=475680&r1=475679&r2=475680
==============================================================================
--- incubator/activemq/trunk/activemq-core/pom.xml (original)
+++ incubator/activemq/trunk/activemq-core/pom.xml Thu Nov 16 02:56:07 2006
@@ -254,6 +254,9 @@
<!-- TODO need to get the JUnit test configured to create SSL
sockets nicely via system properties -->
<exclude>**/StompSslTest.*</exclude>
+ <!-- http://issues.apache.org/activemq/browse/AMQ-1027 -->
+ <exclude>**/FailoverConsumerTest.*</exclude>
+
</excludes>
</configuration>
</plugin>
Added:
incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/transport/failover/FailoverConsumerTest.java
URL:
http://svn.apache.org/viewvc/incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/transport/failover/FailoverConsumerTest.java?view=auto&rev=475680
==============================================================================
---
incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/transport/failover/FailoverConsumerTest.java
(added)
+++
incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/transport/failover/FailoverConsumerTest.java
Thu Nov 16 02:56:07 2006
@@ -0,0 +1,116 @@
+/**
+ *
+ * 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.transport.failover;
+
+import java.net.URI;
+
+import javax.jms.Connection;
+import javax.jms.Message;
+import javax.jms.MessageConsumer;
+import javax.jms.MessageProducer;
+import javax.jms.Session;
+
+import org.apache.activemq.ActiveMQConnectionFactory;
+import org.apache.activemq.ActiveMQPrefetchPolicy;
+import org.apache.activemq.command.ActiveMQQueue;
+import org.apache.activemq.network.NetworkTestSupport;
+
+public class FailoverConsumerTest extends NetworkTestSupport {
+
+ private static final org.apache.commons.logging.Log log =
org.apache.commons.logging.LogFactory
+ .getLog(FailoverConsumerTest.class);
+
+ public static final int MSG_COUNT = 100;
+
+ public void testPublisherFailsOver() throws Exception {
+ // Uncomment this if you want to use remote broker created by
NetworkTestSupport.
+ // But it doesn't work. See comments below.
+// URI failoverURI = new
URI("failover://"+remoteConnector.getServer().getConnectURI());
+ URI failoverURI = new URI("failover://tcp://localhost:61616");
+
+ ActiveMQConnectionFactory factory = new
ActiveMQConnectionFactory(failoverURI);
+ ActiveMQPrefetchPolicy prefetchPolicy = new
ActiveMQPrefetchPolicy();
+
+ // Prefetch size must be less than messages in the queue!!
+ prefetchPolicy.setQueuePrefetch(MSG_COUNT - 10);
+ factory.setPrefetchPolicy(prefetchPolicy);
+ Connection connection = factory.createConnection();
+ Session session = connection.createSession(false,
Session.AUTO_ACKNOWLEDGE);
+ MessageProducer producer = session.createProducer(new
ActiveMQQueue("Test"));
+ for (int idx = 0; idx < MSG_COUNT; ++idx) {
+ producer.send(session.createTextMessage("Test"));
+ }
+ producer.close();
+ session.close();
+ int count = 0;
+
+ Session consumerSession = connection.createSession(false,
Session.CLIENT_ACKNOWLEDGE);
+ MessageConsumer consumer = consumerSession.createConsumer(new
ActiveMQQueue("Test"));
+ connection.start();
+ Message msg = consumer.receive(3000);
+
+ // restartRemoteBroker() doesn't work (you won't get received
any messages
+ // after restart, javadoc says, that messages should be
received though).
+ // So we must use external broker ant restart it manually.
+ log.info("You should restart remote broker now and press
enter!");
+ System.in.read();
+// Thread.sleep(20000);
+ restartRemoteBroker();
+ msg.acknowledge();
+ ++count;
+
+ for (int idx = 1; idx < MSG_COUNT; ++idx) {
+ msg = consumer.receive(3000);
+ if (msg == null) {
+ log.error("No messages received! Received:" +
count);
+ break;
+ }
+ msg.acknowledge();
+ ++count;
+ }
+ assertEquals(count, MSG_COUNT);
+ consumer.close();
+ consumerSession.close();
+ connection.close();
+
+ connection = factory.createConnection();
+ consumerSession = connection.createSession(false,
Session.CLIENT_ACKNOWLEDGE);
+ consumer = consumerSession.createConsumer(new
ActiveMQQueue("Test"));
+ connection.start();
+
+ count = 0;
+ do {
+ msg = consumer.receive(1000);
+ if (msg != null) {
+ msg.acknowledge();
+ ++count;
+ }
+ }
+ while (msg != null);
+
+ assertEquals(count, 0);
+
+ consumer.close();
+ consumerSession.close();
+ connection.close();
+ }
+
+ protected String getRemoteURI() {
+ return "tcp://localhost:55555";
+ }
+}
Propchange:
incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/transport/failover/FailoverConsumerTest.java
------------------------------------------------------------------------------
svn:eol-style = native
Propchange:
incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/transport/failover/FailoverConsumerTest.java
------------------------------------------------------------------------------
svn:keywords = Date Author Id Revision HeadURL
Propchange:
incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/transport/failover/FailoverConsumerTest.java
------------------------------------------------------------------------------
svn:mime-type = text/plain
