public class PublishRequest extends RequestBase implements BayeuxRequest
Modifier and Type | Field and Description |
---|---|
protected static HashMap<String,Object> |
responseTemplate |
channel, clientId, conType, data, desiredConnTypeFlag, event, ext, id, minVersion, reconnectInterval, response, subscription, suppConnTypes, suppConnTypesFlag, timestampFmt, tomcatBayeux, version
CURRENT_REQ_ATTR, JSON_MSG_ARRAY, LAST_REQ_ATTR
Constructor and Description |
---|
PublishRequest(TomcatBayeux tb,
HttpEvent event,
JSONObject jsReq) |
Modifier and Type | Method and Description |
---|---|
int |
process(int prevops)
Send the event message to all registered subscribers.
|
HttpError |
validate()
Check client request for validity.
|
addToDeliveryQueue, deliver, flushMessages, getChannel, getClientId, getEvent, getExt, getId, getJSONArray, getJSONArray, getReconnectInterval, getTimeStamp, getTomcatBayeux
public PublishRequest(TomcatBayeux tb, HttpEvent event, JSONObject jsReq) throws JSONException
JSONException
public HttpError validate()
validate
in interface BayeuxRequest
validate
in class RequestBase
public int process(int prevops) throws BayeuxException
process
in interface BayeuxRequest
process
in class RequestBase
prevops
- - the operation requested by the previous request, in case of chained requests.BayeuxException
- - if an error was detected, and the appropriate error response couldn't be delivered to the client.Copyright © 2013 JBoss by Red Hat. All rights reserved.