interconnect/core/src/it/java/de/taimos/dvalin/interconnect/core/InterconnectConnectorBurstTest.java
/**
	 * @param args Arguments
	 * @throws Exception If ...
	 */
@param args Arguments
@throws Exception If
@param args Arguments @throws Exception If
public static void main(String[] args) throws Exception {
		TestHelper.initBrokerEnv("failover:tcp://localhost:61616");
		try {
			System.out.println("begin");
			for (int i = 0; i < InterconnectConnectorBurstTest.THREADS; i++) {
				new Thread(new InterconnectConnectorBurstTest()).start();
			}
			InterconnectConnectorBurstTest.cdl1.await();
			final Long begin = System.nanoTime();
			InterconnectConnectorBurstTest.cdl2.await();
			final Long end = System.nanoTime();
			System.out.println("end");
			System.out.println("duration: " + ((end - begin) / 1000L / 1000L) + " ms");
		} finally {
			TestHelper.closeBrokerEnv();
		}
	}
public static void main ( String [ ] args ) throws Exception { TestHelper . initBrokerEnv ( "failover:tcp://localhost:61616" ) ; try { System . out . println ( "begin" ) ; for ( int i = 0 ; i < InterconnectConnectorBurstTest . THREADS ; i ++ ) { new Thread ( new InterconnectConnectorBurstTest ( ) ) . start ( ) ; } InterconnectConnectorBurstTest . cdl1 . await ( ) ; final Long begin = System . nanoTime ( ) ; InterconnectConnectorBurstTest . cdl2 . await ( ) ; final Long end = System . nanoTime ( ) ; System . out . println ( "end" ) ; System . out . println ( "duration: " + ( ( end - begin ) / 1000L / 1000L ) + " ms" ) ; } finally { TestHelper . closeBrokerEnv ( ) ; } }
@param args Arguments
 @throws Exception If ...
@param args Arguments @throws Exception If ...