public abstract class RequestBase extends java.lang.Object implements BayeuxRequest
Modifier and Type | Field and Description |
---|---|
protected java.lang.String |
channel |
protected java.lang.String |
clientId |
protected java.lang.String |
conType |
protected java.lang.String |
data |
protected int |
desiredConnTypeFlag |
protected HttpEvent |
event |
protected java.util.LinkedHashMap<java.lang.String,java.lang.Object> |
ext |
protected java.lang.String |
id |
protected java.lang.String |
minVersion |
protected int |
reconnectInterval |
protected java.util.HashMap<java.lang.String,java.lang.Object> |
response |
protected java.lang.String |
subscription |
protected java.lang.String[] |
suppConnTypes |
protected int |
suppConnTypesFlag |
protected static java.text.SimpleDateFormat |
timestampFmt |
protected TomcatBayeux |
tomcatBayeux |
protected java.lang.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) |
java.lang.String |
getChannel() |
java.lang.String |
getClientId() |
HttpEvent |
getEvent() |
java.util.LinkedHashMap |
getExt() |
java.lang.String |
getId() |
protected JSONArray |
getJSONArray() |
protected static JSONArray |
getJSONArray(HttpEvent event,
boolean nullok) |
int |
getReconnectInterval() |
java.lang.String |
getTimeStamp() |
TomcatBayeux |
getTomcatBayeux() |
int |
process(int prevops)
processes a remote client Bayeux message
|
HttpError |
validate()
Validates a specific request.
|
protected static final java.text.SimpleDateFormat timestampFmt
protected TomcatBayeux tomcatBayeux
protected java.lang.String channel
protected java.lang.String id
protected java.lang.String clientId
protected java.lang.String version
protected java.lang.String[] suppConnTypes
protected int suppConnTypesFlag
protected int desiredConnTypeFlag
protected java.lang.String minVersion
protected java.lang.String subscription
protected java.lang.String data
protected java.lang.String conType
protected java.util.LinkedHashMap<java.lang.String,java.lang.Object> ext
protected HttpEvent event
protected java.util.HashMap<java.lang.String,java.lang.Object> response
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 java.lang.String getChannel()
public java.lang.String getId()
public java.lang.String getClientId()
public java.util.LinkedHashMap getExt()
public HttpEvent getEvent()
protected static void deliver(HttpEvent event, ClientImpl to) throws java.io.IOException, ServletException, BayeuxException
java.io.IOException
ServletException
BayeuxException
protected JSONArray getJSONArray()
protected void addToDeliveryQueue(ClientImpl to, JSONObject msg) throws java.io.IOException, ServletException, BayeuxException
java.io.IOException
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 java.lang.String getTimeStamp()