throw new WebApplicationException(Response.ok(getItemStateListBean(itemNames,System.currentTimeMillis()), responseType).build());
} else {
throw new WebApplicationException(Response.notAcceptable(null).build());
}
}
CometVisuBroadcaster itemBroadcaster = (CometVisuBroadcaster) BroadcasterFactory.getDefault().lookup(CometVisuBroadcaster.class, resource.getRequest().getPathInfo(), true);
itemBroadcaster.addStateChangeListener(new ItemStateChangeListener(itemNames));
return new SuspendResponse.SuspendResponseBuilder<Response>()
.scope(SCOPE.REQUEST)
.resumeOnBroadcast(!ResponseTypeHelper.isStreamingTransport(resource.getRequest()))
.broadcaster(itemBroadcaster)
.outputComments(true).build();