protected final Object wrapMessage(AtmosphereResponse res, String message) {
if (message != null && message.startsWith("heartbeat-")) {
String identity = (String) getContextValue(res.request(), IDENTITY);
return new Heartbeat(String.valueOf(System.nanoTime()), identity);
} else {
Request swaggerSocketRequest = lookupRequest(res.request());
Response.Builder builder = new Response.Builder();
builder.body(message)