final LocalSession session0 = _bayeux.newLocalSession("s0");
session0.handshake();
//final LocalSession session1 = _bayeux.newLocalSession("s1");
//session1.handshake();
session0.addExtension(new ClientSession.Extension.Adapter()
{
@Override
public boolean send(ClientSession session, org.cometd.bayeux.Message.Mutable message)
{
if ("zero".equals(message.getData()))