291292293294295296297298299300301
continue; } } if (message != null) transport.send(message); if (mesgImpl != null) mesgImpl.decRef(); } if (metaConnectReply != null)
299300301302303304305306307308309
} if (metaConnectReply != null) { metaConnectReply=_bayeux.extendSendMeta(client,metaConnectReply); transport.send(metaConnectReply); if (metaConnectReply instanceof MessageImpl) ((MessageImpl)metaConnectReply).decRef(); } } }
244245246247248249250251252253254
for (int i = 0;i<size;i++) { message=messages.getUnsafe(i); message=_bayeux.extendSendClient(null, client, message); if (message!=null) transport.send(message); } } if (pollReply!=null) { transport.send(pollReply);
249250251252253254255256257258259
transport.send(message); } } if (pollReply!=null) { transport.send(pollReply); } transport.complete(); flushed=true; } }
229230231232233234235236237238239
request.setAttribute("org.mortbay.jetty.ResponseBuffer",buffer); ((MessageImpl)message).decRef(); flushed=true; } else transport.send(pollReply); } else transport.send(pollReply); }
232233234235236237238239240241242
} else transport.send(pollReply); } else transport.send(pollReply); } if (!flushed) { Message message = null;
241242243244245246247248249250251
{ Message message = null; for (int i = 0;i<size;i++) { message=messages.getUnsafe(i); transport.send(message); } transport.complete(); flushed=true; }