org.richfaces.application.push.impl
public class RequestImpl extends Object implements org.richfaces.application.push.Request, org.atmosphere.cpr.AtmosphereResourceEventListener
Constructor and Description |
---|
RequestImpl(org.atmosphere.cpr.Meteor meteor,
org.richfaces.application.push.Session session) |
Modifier and Type | Method and Description |
---|---|
org.richfaces.application.push.Session |
getSession() |
boolean |
isPolling() |
void |
onBroadcast(org.atmosphere.cpr.AtmosphereResourceEvent event)
This method is called once the broadcast event occurs.
|
void |
onDisconnect(org.atmosphere.cpr.AtmosphereResourceEvent event) |
void |
onResume(org.atmosphere.cpr.AtmosphereResourceEvent event) |
void |
onSuspend(org.atmosphere.cpr.AtmosphereResourceEvent event) |
void |
onThrowable(org.atmosphere.cpr.AtmosphereResourceEvent event) |
void |
postMessages()
Tries to push messages, when there are some in the session's queue.
|
void |
resume() |
void |
suspend() |
public RequestImpl(org.atmosphere.cpr.Meteor meteor, org.richfaces.application.push.Session session)
public void suspend()
suspend
in interface org.richfaces.application.push.Request
public void resume()
resume
in interface org.richfaces.application.push.Request
public boolean isPolling()
isPolling
in interface org.richfaces.application.push.Request
public org.richfaces.application.push.Session getSession()
getSession
in interface org.richfaces.application.push.Request
public void postMessages()
Tries to push messages, when there are some in the session's queue.
When detects that request is currently broadcasting, it ignores the call, since the sending of the messages will be
proceed later as stated by onBroadcast(AtmosphereResourceEvent)
method.
postMessages
in interface org.richfaces.application.push.Request
public void onSuspend(org.atmosphere.cpr.AtmosphereResourceEvent event)
onSuspend
in interface org.atmosphere.cpr.AtmosphereResourceEventListener
public void onResume(org.atmosphere.cpr.AtmosphereResourceEvent event)
onResume
in interface org.atmosphere.cpr.AtmosphereResourceEventListener
public void onDisconnect(org.atmosphere.cpr.AtmosphereResourceEvent event)
onDisconnect
in interface org.atmosphere.cpr.AtmosphereResourceEventListener
public void onBroadcast(org.atmosphere.cpr.AtmosphereResourceEvent event)
This method is called once the broadcast event occurs.
Once this event occurs, he broadcasting is done, so we can clean up.
This method clears the broadcasted messages from session and then opens the request for further broadcasting.
In case this request is long-polling, the request is completed and client needs to start new request for receiving new messages.
In another case - the request is done by websocket - it tries to send messages which could be posted when broadcasting.
onBroadcast
in interface org.atmosphere.cpr.AtmosphereResourceEventListener
public void onThrowable(org.atmosphere.cpr.AtmosphereResourceEvent event)
onThrowable
in interface org.atmosphere.cpr.AtmosphereResourceEventListener
Copyright © 2014 JBoss by Red Hat. All Rights Reserved.