[jboss-cvs] JBoss Messaging SVN: r2712 - trunk/tests/src/org/jboss/test/messaging/jms/clustering.
jboss-cvs-commits at lists.jboss.org
jboss-cvs-commits at lists.jboss.org
Fri May 18 12:17:22 EDT 2007
Author: clebert.suconic at jboss.com
Date: 2007-05-18 12:17:21 -0400 (Fri, 18 May 2007)
New Revision: 2712
Modified:
trunk/tests/src/org/jboss/test/messaging/jms/clustering/HATest.java
Log:
Cleaning garbage out
Modified: trunk/tests/src/org/jboss/test/messaging/jms/clustering/HATest.java
===================================================================
--- trunk/tests/src/org/jboss/test/messaging/jms/clustering/HATest.java 2007-05-18 15:44:50 UTC (rev 2711)
+++ trunk/tests/src/org/jboss/test/messaging/jms/clustering/HATest.java 2007-05-18 16:17:21 UTC (rev 2712)
@@ -272,95 +272,6 @@
}
-// public void testQueueHA() throws Exception
-// {
-// log.info("++testTopicSubscriber");
-//
-// log.info(">>Lookup Queue");
-// Destination destination = (Destination)getCtx1().lookup("queue/testDistributedQueue");
-//
-// log.info("Creating connection server1");
-// JBossConnection conn = (JBossConnection)this.factoryServer1.createConnection();
-// conn.setClientID("testClient");
-// conn.start();
-//
-// JBossSession session = (JBossSession)conn.createSession(true,Session.AUTO_ACKNOWLEDGE);
-// ClientSessionDelegate clientSessionDelegate = (ClientSessionDelegate)session.getDelegate();
-// SessionState sessionState = (SessionState)clientSessionDelegate.getState();
-//
-// MessageConsumer consumerHA = session.createConsumer(destination);
-// JBossMessageConsumer jbossConsumerHA =(JBossMessageConsumer)consumerHA;
-//
-// org.jboss.jms.client.delegate.ClientConsumerDelegate clientDelegate = (org.jboss.jms.client.delegate.ClientConsumerDelegate)jbossConsumerHA.getDelegate();
-// ConsumerState consumerState = (ConsumerState)clientDelegate.getState();
-//
-// log.info("subscriptionName=" + consumerState.getSubscriptionName());
-//
-//
-// log.info(">>Creating Producer");
-// MessageProducer producer = session.createProducer(destination);
-// log.info(">>creating Message");
-// Message message = session.createTextMessage("Hello Before");
-// log.info(">>sending Message");
-// producer.send(message);
-// session.commit();
-//
-// session.commit();
-// //if (true) return;
-//
-// Object txID = sessionState.getCurrentTxId();
-//
-// ClientConnectionDelegate delegate = (ClientConnectionDelegate)conn.getDelegate();
-//
-// JMSRemotingConnection originalRemoting = delegate.getRemotingConnection();
-//
-// log.info(">>Creating alternate connection");
-// JBossConnection conn2 = (JBossConnection)this.factoryServer2.createConnection();
-// log.info("NewConnectionCreated=" + conn2);
-//
-// log.info(">>Failling over");
-// assertSame(originalRemoting,delegate.getRemotingConnection());
-// conn.getDelegate().failOver(conn2.getDelegate());
-//
-// try {
-// originalRemoting.stop();
-// } catch (Throwable throwable) {
-// throwable.printStackTrace();
-// }
-//
-//
-// assertNotSame(originalRemoting,delegate.getRemotingConnection());
-//
-// //System.out.println("Kill server1"); Thread.sleep(10000);
-// assertEquals(txID,sessionState.getCurrentTxId());
-// System.out.println("TransactionID on client = " + txID);
-// log.info(">>Final commit");
-//
-// session.commit();
-//
-// log.info("Calling alternate receiver");
-// receiveMessage("consumerHA",consumerHA,true,false);
-// receiveMessage("consumerHA",consumerHA,true,true);
-//
-// session.commit();
-//
-// for (int i=0;i<30;i++)
-// {
-// log.info("Message Sent " + i);
-// producer.send(session.createTextMessage("Message " + i));
-// }
-// session.commit();
-//
-// Thread.sleep(5000);
-//
-// TextMessage messageLoop = null;
-// while (!((messageLoop = (TextMessage) consumerHA.receive(5000)) == null))
-// {
-// log.info("Message received = " + messageLoop.getText());
-// }
-//
-// }
-
/*
* Test that the failover mapping is created correctly and updated properly when nodes leave
* or join
@@ -1188,237 +1099,6 @@
}
-// public void testConnectionFactoryConnect() throws Exception
-// {
-// try
-// {
-// JBossConnectionFactory factory = (JBossConnectionFactory )ic[2].lookup("/ConnectionFactory");
-// ClientClusteredConnectionFactoryDelegate delegate =
-// (ClientClusteredConnectionFactoryDelegate)factory.getDelegate();
-// log.info ("number of delegates = " + delegate.getDelegates().length);
-// log.info ("number of servers = " + ServerManagement.getServer(0).getNumberOfNodesOnCluster());
-//
-// delegate.init();
-//
-// for (int i = 0; i < 3; i++)
-// {
-// int failNode = delegate.getDelegates()[0].getFailoverNode(i);
-// log.info("Failover node for server" + i + " = " + failNode);
-// log.info("InvokerLocator for server " + i + " = " + delegate.getDelegates()[i].getServerLocatorURI());
-//
-// assertEquals("Server1 should have the same failoverMapping",
-// failNode, delegate.getDelegates()[1].getFailoverNode(i));
-// assertEquals("Server2 should have the same failoverMapping",
-// failNode, delegate.getDelegates()[2].getFailoverNode(i));
-// }
-//
-// assertEquals(3, ServerManagement.getServer(0).getNumberOfNodesOnCluster());
-// assertEquals(3, delegate.getDelegates().length);
-//
-//
-// ServerManagement.log(ServerManagement.INFO,"Stopping server 2 as part of testConnectionFactoryConnect");
-// ServerManagement.stop(2,true);
-//
-// ServerManagement.log(ServerManagement.INFO,"##### Looking up ConnectionFactory at testConnectionFactoryConnect");
-//
-// factory = (JBossConnectionFactory )ic[2].lookup("/ConnectionFactory");
-// delegate = (ClientClusteredConnectionFactoryDelegate)factory.getDelegate();
-//
-// assertEquals(2, ServerManagement.getServer(0).getNumberOfNodesOnCluster());
-// assertEquals(2, delegate.getDelegates().length);
-// }
-// finally
-// {
-// ServerManagement.start("all", 2);
-// }
-//
-//
-// }
-
-
-// public void testTopicSubscriber() throws Exception
-// {
-// try
-// {
-// log.info("++testTopicSubscriber");
-//
-//
-// JBossConnectionFactory jbcf1 = (JBossConnectionFactory)cf;
-// assertTrue(jbcf1.getDelegate() instanceof ClientClusteredConnectionFactoryDelegate);
-//
-// log.info(">>Lookup Queue");
-// Destination destination = (Destination) ic[2].lookup("topic/testDistributedTopic");
-//
-// log.info("Creating connection server1");
-// JBossConnection conn = (JBossConnection) cf.createConnection();
-// conn.setClientID("testClient");
-// conn.start();
-//
-// JBossSession session = (JBossSession) conn.createSession(true, Session.AUTO_ACKNOWLEDGE);
-// ClientSessionDelegate clientSessionDelegate = (ClientSessionDelegate) session.getDelegate();
-// SessionState sessionState = (SessionState) clientSessionDelegate.getState();
-//
-// MessageConsumer consumerHA = session.createDurableSubscriber((Topic) destination, "T1");
-// JBossMessageConsumer jbossConsumerHA = (JBossMessageConsumer) consumerHA;
-//
-// org.jboss.jms.client.delegate.ClientConsumerDelegate clientDelegate = (org.jboss.jms.client.delegate.ClientConsumerDelegate) jbossConsumerHA.getDelegate();
-// ConsumerState consumerState = (ConsumerState) clientDelegate.getState();
-//
-// log.info("subscriptionName=" + consumerState.getSubscriptionName());
-//
-//
-// log.info(">>Creating Producer");
-// MessageProducer producer = session.createProducer(destination);
-// log.info(">>creating Message");
-// Message message = session.createTextMessage("Hello Before");
-// log.info(">>sending Message");
-// producer.send(message);
-// session.commit();
-//
-// receiveMessage("consumerHA", consumerHA, true, false);
-//
-// session.commit();
-// //if (true) return;
-//
-// Object txID = sessionState.getCurrentTxId();
-//
-// producer.send(session.createTextMessage("Hello again before failover"));
-//
-// ClientConnectionDelegate delegate = (ClientConnectionDelegate) conn.getDelegate();
-//
-// ServerManagement.stop(0, false);
-//
-// Thread.sleep(25000);
-//
-// //System.out.println("Kill server1"); Thread.sleep(10000);
-//
-// message = session.createTextMessage("Hello After");
-// log.info(">>Sending new message");
-// producer.send(message);
-//
-// assertEquals(txID, sessionState.getCurrentTxId());
-// System.out.println("TransactionID on client = " + txID);
-// log.info(">>Final commit");
-//
-// /* JBossConnection connSecondServer = (JBossConnection)this.factoryServer2.createConnection();
-// connSecondServer.start();
-// JBossSession sessionSecondServer = (JBossSession)connSecondServer.createSession(false,Session.AUTO_ACKNOWLEDGE);
-// MessageConsumer consumerSecondServer = sessionSecondServer.createConsumer(destination); */
-//
-// session.commit();
-//
-// /* receiveMessage("consumerSecondServer",consumerSecondServer,true,false);
-// receiveMessage("consumerSecondServer",consumerSecondServer,true,false);
-// receiveMessage("consumerSecondServer",consumerSecondServer,true,true); */
-//
-// log.info("Calling alternate receiver");
-// receiveMessage("consumerHA", consumerHA, true, false);
-// receiveMessage("consumerHA", consumerHA, true, false);
-// receiveMessage("consumerHA", consumerHA, true, true);
-//
-//
-// session.commit();
-//
-// }
-// finally
-// {
-// // restart the server as it was probably stopped (tearDown will need that)
-// ServerManagement.start("all", 0);
-// }
-// }
-
-//
-// public void testQueueHA() throws Exception
-// {
-// log.info("++testTopicSubscriber");
-//
-// log.info(">>Lookup Queue");
-// Destination destination = (Destination) ic[1].lookup("queue/testDistributedQueue");
-//
-// log.info("Creating connection server1");
-// JBossConnection conn = (JBossConnection) cf1.createConnection();
-// conn.setClientID("testClient");
-// conn.start();
-//
-// JBossSession session = (JBossSession) conn.createSession(true, Session.AUTO_ACKNOWLEDGE);
-// ClientSessionDelegate clientSessionDelegate = (ClientSessionDelegate) session.getDelegate();
-// SessionState sessionState = (SessionState) clientSessionDelegate.getState();
-//
-// MessageConsumer consumerHA = session.createConsumer(destination);
-// JBossMessageConsumer jbossConsumerHA = (JBossMessageConsumer) consumerHA;
-//
-// org.jboss.jms.client.delegate.ClientConsumerDelegate clientDelegate = (org.jboss.jms.client.delegate.ClientConsumerDelegate) jbossConsumerHA.getDelegate();
-// ConsumerState consumerState = (ConsumerState) clientDelegate.getState();
-//
-// log.info("subscriptionName=" + consumerState.getSubscriptionName());
-//
-//
-// log.info(">>Creating Producer");
-// MessageProducer producer = session.createProducer(destination);
-// log.info(">>creating Message");
-// Message message = session.createTextMessage("Hello Before");
-// log.info(">>sending Message");
-// producer.send(message);
-// session.commit();
-//
-// session.commit();
-// //if (true) return;
-//
-// Object txID = sessionState.getCurrentTxId();
-//
-// ClientConnectionDelegate delegate = (ClientConnectionDelegate) conn.getDelegate();
-//
-// JMSRemotingConnection originalRemoting = delegate.getRemotingConnection();
-//
-// log.info(">>Creating alternate connection");
-// JBossConnection conn2 = (JBossConnection) cf2.createConnection();
-// log.info("NewConnectionCreated=" + conn2);
-//
-// log.info(">>Failling over");
-// assertSame(originalRemoting, delegate.getRemotingConnection());
-// conn.getDelegate().failOver(conn2.getDelegate());
-//
-// try
-// {
-// originalRemoting.stop();
-// } catch (Throwable throwable)
-// {
-// throwable.printStackTrace();
-// }
-//
-//
-// assertNotSame(originalRemoting, delegate.getRemotingConnection());
-//
-// //System.out.println("Kill server1"); Thread.sleep(10000);
-// assertEquals(txID, sessionState.getCurrentTxId());
-// System.out.println("TransactionID on client = " + txID);
-// log.info(">>Final commit");
-//
-// session.commit();
-//
-// log.info("Calling alternate receiver");
-// receiveMessage("consumerHA", consumerHA, true, false);
-// receiveMessage("consumerHA", consumerHA, true, true);
-//
-// session.commit();
-//
-// for (int i = 0; i < 30; i++)
-// {
-// log.info("Message Sent " + i);
-// producer.send(session.createTextMessage("Message " + i));
-// }
-// session.commit();
-//
-// Thread.sleep(5000);
-//
-// TextMessage messageLoop = null;
-// while (!((messageLoop = (TextMessage) consumerHA.receive(5000)) == null))
-// {
-// log.info("Message received = " + messageLoop.getText());
-// }
-//
-// }
-
// Package protected ---------------------------------------------
// Protected -----------------------------------------------------
More information about the jboss-cvs-commits
mailing list