Made the peer test a little more reliable by using consumer advisory messages to know when the peers have fully connected in the cluster.
incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/transport/peer/PeerTransportTest.java