To try out the peer protocol, perform the following steps:

Start a consumer that consumes messages from the TEST.FOO queue belonging to the group peer group. To start the consumer, run the consumer tool with a peer group URL as follows:

cd InstallDir/example
ant consumer -Durl="peer://group/broker1?persistent=false" -Dmax=100

Where the first component of the URL path, group, specifies that this peer belongs to the group peer group. The second component, broker1, specifies the name of the embedded broker and the setting, persistent=false, sets a broker option. When the consumer starts up, you should see output like the following in the command window:

consumer:
     [echo] Running consumer against server at $url = peer://group/broker1?persistent=false for subject $subject = TEST.FOO
     [java] Connecting to URL: peer://group/broker1?persistent=false
     [java] Consuming queue: TEST.FOO
     [java] Using a non-durable subscription
     [java] 15:43:10 INFO  ActiveMQ null JMS Message Broker (broker1) is starting
     [java] 15:43:10 INFO  For help or more information please see:
http://activemq.apache.org/
     [java] 15:43:10 INFO  Using Persistence Adapter: MemoryPersistenceAdapter
     [java] 15:43:10 INFO  Listening for connections at: tcp://fboltond820:2399
     [java] 15:43:10 INFO  Connector tcp://fboltond820:2399 Started
     [java] 15:43:10 INFO  Network Connector org.apache.activemq.transport.discovery.multicast.MulticastDiscoveryAgent@da4b71 Started
     [java] 15:43:10 INFO  ActiveMQ JMS Message Broker (broker1, ID:fboltond820-2398-1192200190327-2:0) started
     [java] 15:43:10 INFO  Connector vm://broker1 Started
     [java] 15:43:10 INFO  JMX consoles can connect to service:jmx:rmi:///jndi/rmi://localhost:1099/jmxrmi
     [java] We are about to wait until we consume: 100 message(s) then we will shutdown

While the consumer is starting up, it activates an embedded broker with broker name, broker1, and attempts to connect to its peers using a multicast discovery agent.

Start a producer that sends messages to the TEST.FOO queue on the group peer group. To start the producer, run the producer tool with a peer group URL as follows:

cd InstallDir/example
ant producer -Durl="peer://group/broker2?persistent=false" -DsleepTime=1000

Where the name of the embedded broker is set to broker2 and the sleep time (time between successive messages) is set to 1000 ms. When the producer starts up, the output log should include some lines like the following:

     [java] 15:43:27 INFO  Establishing network connection between from vm://broker2 to tcp://fboltond820:2399
     [java] 15:43:28 INFO  Network connection between vm://broker2#2 and tcp://localhost/127.0.0.1:2399(broker1) has been established.

These lines indicate that a peer-to-peer connection was successfully established between the embedded brokers, broker1 and broker2. The consumer should now be able to receive the messages sent by the producer.