log.debug("["+Thread.currentThread().getName()+"] Delivering message to[" + to + "] message:" + jsonstring);\r
}\r
\r
+ if (to!=null) {\r
+ if (to.useJsonFiltered()) {\r
+ if (!event.getHttpServletResponse().isCommitted()) event.getHttpServletResponse().setContentType("text/json-comment-filtered");\r
+ }else { \r
+ if (!event.getHttpServletResponse().isCommitted()) event.getHttpServletResponse().setContentType("text/json");\r
+ }\r
+ }\r
+\r
PrintWriter out = event.getHttpServletResponse().getWriter();\r
if (to==null) {\r
//do nothing\r
clientId = client.getId();\r
client.setSupportedConnTypes(suppConnTypesFlag);\r
client.setUseJsonFiltered(getExt().get(Bayeux.JSON_COMMENT_FILTERED_FIELD) != null);\r
- if (client.useJsonFiltered()) {\r
- event.getHttpServletResponse().setContentType("text/json-comment-filtered");\r
- }else {\r
- event.getHttpServletResponse().setContentType("text/json");\r
- }\r
response.put(Bayeux.CLIENT_FIELD, client.getId());\r
((HashMap) response.get(Bayeux.ADVICE_FIELD)).put(Bayeux.RECONNECT_FIELD, Bayeux.RETRY_RESPONSE);\r
((HashMap) response.get(Bayeux.ADVICE_FIELD)).put(Bayeux.INTERVAL_FIELD, getReconnectInterval());\r