|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectcom.caucho.bam.query.QueryManager
public class QueryManager
QueryCallbackManager is used to generate query ids and to wait for query callbacks.
Constructor Summary | |
---|---|
QueryManager(java.lang.String id)
|
|
QueryManager(java.lang.String id,
long seed)
|
Method Summary | |
---|---|
void |
addQueryCallback(long id,
QueryCallback callback,
long timeout)
Adds a query callback to handle a later message. |
QueryFuture |
addQueryFuture(long id,
java.lang.String to,
java.lang.String from,
java.io.Serializable payload,
long timeout)
Registers a callback future. |
void |
close()
|
long |
getTimeout()
|
boolean |
isEmpty()
|
long |
nextQueryId()
Generates a new unique query identifier. |
boolean |
onQueryError(long id,
java.lang.String to,
java.lang.String from,
java.io.Serializable payload,
BamError error)
Callback from the ActorStream to handle a queryResult. |
boolean |
onQueryResult(long id,
java.lang.String to,
java.lang.String from,
java.io.Serializable payload)
Callback from the ActorStream to handle a queryResult. |
java.io.Serializable |
query(MessageStream stream,
java.lang.String to,
java.lang.String from,
java.io.Serializable payload,
long timeout)
Queries through to a stream. |
void |
query(MessageStream stream,
java.lang.String to,
java.lang.String from,
java.io.Serializable payload,
QueryCallback cb,
long timeout)
Queries through to a stream. |
void |
setTimeout(long timeout)
|
java.lang.String |
toString()
|
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
Constructor Detail |
---|
public QueryManager(java.lang.String id)
public QueryManager(java.lang.String id, long seed)
Method Detail |
---|
public boolean isEmpty()
public long getTimeout()
public void setTimeout(long timeout)
public final long nextQueryId()
public void addQueryCallback(long id, QueryCallback callback, long timeout)
id
- the unique query identifiercallback
- the application's callback for the resultpublic QueryFuture addQueryFuture(long id, java.lang.String to, java.lang.String from, java.io.Serializable payload, long timeout)
public void query(MessageStream stream, java.lang.String to, java.lang.String from, java.io.Serializable payload, QueryCallback cb, long timeout)
public java.io.Serializable query(MessageStream stream, java.lang.String to, java.lang.String from, java.io.Serializable payload, long timeout)
public final boolean onQueryResult(long id, java.lang.String to, java.lang.String from, java.io.Serializable payload)
public final boolean onQueryError(long id, java.lang.String to, java.lang.String from, java.io.Serializable payload, BamError error)
public void close()
public java.lang.String toString()
toString
in class java.lang.Object
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |