@Test
public void oneBusShouldNotifyRegisteredListeners() throws Exception {

    // Create three observers ...
    TestListener listener1 = new TestListener(1);
    
    startBusWithRegisteredListener(listener1);
   
    // Send a change from the first bus ...
    ChangeSet changeSet = new TestChangeSet("ws1");
    ChangeBus bus1 = buses.get(1);
    bus1.notify(changeSet);          
  
    listener1.assertExpectedEvents(changeSet);
}