@Override
public void stop() throws Exception {
super.stop();
endpoint.disconnect(this);
}
<BUG>public void process(final Exchange exchange) {
Collection<Client> clients = bayeux.getClients();
for (Iterator<Client> iterator = clients.iterator(); iterator.hasNext();) {
Client client = (Client) iterator.next();
client.deliver(client, endpoint.getPath(), exchange.getIn().getBody(), null);</BUG>
}

@Override
public void start() throws Exception {
super.start();
endpoint.connect(this);
