flex.messaging.client
Class FlexClient.AsyncPollWithTimeout

java.lang.Object
  flex.messaging.util.TimeoutAbstractObject
      flex.messaging.client.FlexClient.AsyncPollWithTimeout

Enclosing class:

FlexClient

public class FlexClient.AsyncPollWithTimeout
extends TimeoutAbstractObject

Helper class for handling async poll requests. This class allows the response for an async poll to be delayed until data arrives to return to the client or the specified wait interval elapses. Wait timeouts are monitored by the FlexClientManager which contains a TimeoutManager instance that is started and stopped during application bootstrap and shutdown. Managing timeouts locally or statically isn't a good option because they lack a useful shutdown hook that's necessary in order to close down the timeout manager cleanly.

Constructor Summary

FlexClient.AsyncPollWithTimeout(FlexClient flexClient, FlexSession session, FlexClient.EndpointQueue queue, AsyncPollHandler handler, long waitIntervalMillis, String endpointId)

Method Summary

String	getEndpointId()
FlexClient.EndpointQueue	getEndpointQueue()
FlexClient	getFlexClient()
FlexSession	getFlexSession()
AsyncPollHandler	getHandler()
void	timeout()

Methods inherited from class flex.messaging.util.TimeoutAbstractObject

cancelTimeout, getLastUse, getTimeoutFuture, getTimeoutManager, getTimeoutPeriod, getTimeoutTask, setLastUse, setTimeoutFuture, setTimeoutManager, setTimeoutPeriod, setTimeoutTask, updateLastUse

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

FlexClient.AsyncPollWithTimeout

public FlexClient.AsyncPollWithTimeout(FlexClient flexClient,
                                       FlexSession session,
                                       FlexClient.EndpointQueue queue,
                                       AsyncPollHandler handler,
                                       long waitIntervalMillis,
                                       String endpointId)

Method Detail

getFlexClient

public FlexClient getFlexClient()

getFlexSession

public FlexSession getFlexSession()

getEndpointQueue

public FlexClient.EndpointQueue getEndpointQueue()

getHandler

public AsyncPollHandler getHandler()

getEndpointId

public String getEndpointId()

timeout

public void timeout()