public abstract class RequestBase extends Object implements BayeuxRequest
Modifier and Type | Field and Description |
---|---|
protected String |
channel |
protected String |
clientId |
protected String |
conType |
protected String |
data |
protected int |
desiredConnTypeFlag |
protected HttpEvent |
event |
protected LinkedHashMap<String,Object> |
ext |
protected String |
id |
protected String |
minVersion |
protected int |
reconnectInterval |
protected HashMap<String,Object> |
response |
protected String |
subscription |
protected String[] |
suppConnTypes |
protected int |
suppConnTypesFlag |
protected static SimpleDateFormat |
timestampFmt |
protected TomcatBayeux |
tomcatBayeux |
protected String |
version |
CURRENT_REQ_ATTR, JSON_MSG_ARRAY, LAST_REQ_ATTR
Modifier | Constructor and Description |
---|---|
protected |
RequestBase(TomcatBayeux tb,
HttpEvent event,
JSONObject jsReq) |
Modifier and Type | Method and Description |
---|---|
protected void |
addToDeliveryQueue(ClientImpl to,
JSONObject msg) |
protected static void |
deliver(HttpEvent event,
ClientImpl to) |
protected void |
flushMessages(ClientImpl client) |
String |
getChannel() |
String |
getClientId() |
HttpEvent |
getEvent() |
LinkedHashMap |
getExt() |
String |
getId() |
protected JSONArray |
getJSONArray() |
protected static JSONArray |
getJSONArray(HttpEvent event,
boolean nullok) |
int |
getReconnectInterval() |
String |
getTimeStamp() |
TomcatBayeux |
getTomcatBayeux() |
int |
process(int prevops)
processes a remote client Bayeux message
|
HttpError |
validate()
Validates a specific request.
|
protected static final SimpleDateFormat timestampFmt
protected TomcatBayeux tomcatBayeux
protected String channel
protected String id
protected String clientId
protected String version
protected String[] suppConnTypes
protected int suppConnTypesFlag
protected int desiredConnTypeFlag
protected String minVersion
protected String subscription
protected String data
protected String conType
protected LinkedHashMap<String,Object> ext
protected HttpEvent event
protected int reconnectInterval
protected RequestBase(TomcatBayeux tb, HttpEvent event, JSONObject jsReq) throws JSONException
JSONException
public HttpError validate()
BayeuxRequest
validate
in interface BayeuxRequest
public TomcatBayeux getTomcatBayeux()
public String getChannel()
public String getId()
public String getClientId()
public LinkedHashMap getExt()
public HttpEvent getEvent()
protected static void deliver(HttpEvent event, ClientImpl to) throws IOException, javax.servlet.ServletException, BayeuxException
IOException
javax.servlet.ServletException
BayeuxException
protected JSONArray getJSONArray()
protected void addToDeliveryQueue(ClientImpl to, JSONObject msg) throws IOException, javax.servlet.ServletException, BayeuxException
IOException
javax.servlet.ServletException
BayeuxException
protected void flushMessages(ClientImpl client) throws BayeuxException
BayeuxException
public int process(int prevops) throws BayeuxException
BayeuxRequest
process
in interface BayeuxRequest
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.public int getReconnectInterval()
public String getTimeStamp()
Copyright © 2013 JBoss by Red Hat. All rights reserved.