org.jlab.clara.base

Class ClaraQueries.RegistrationData<T>

java.lang.Object

org.jlab.clara.base.ClaraQueries.RegistrationData<T>

Type Parameters:

T - The registration data class of the component

Enclosing class:

ClaraQueries

public static class ClaraQueries.RegistrationData<T>
extends java.lang.Object

A query to get the registration data of a specific CLARA component.

Field Summary

Fields

Modifier and Type	Field and Description
protected org.jlab.clara.base.core.ClaraBase	base
protected org.jlab.clara.base.ClaraFilter	filter
protected org.jlab.clara.base.core.ClaraComponent	frontEnd

Method Summary

Modifier and Type	Method and Description
protected java.util.Optional<T>	collect(java.util.stream.Stream<org.jlab.coda.xmsg.data.xMsgRegRecord> regData, long timeout)
protected java.util.stream.Stream<T>	query(java.util.stream.Stream<org.jlab.coda.xmsg.data.xMsgRegRecord> regData, long timeout)
protected D	self()
T	syncRun(long wait, java.util.concurrent.TimeUnit unit) Sends the query and waits for a response.

Methods inherited from class java.lang.Object

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

Field Detail

base

protected final org.jlab.clara.base.core.ClaraBase base

frontEnd

protected final org.jlab.clara.base.core.ClaraComponent frontEnd

filter

protected final org.jlab.clara.base.ClaraFilter filter

Method Detail

collect

protected java.util.Optional<T> collect(java.util.stream.Stream<org.jlab.coda.xmsg.data.xMsgRegRecord> regData,
                                        long timeout)

query

protected java.util.stream.Stream<T> query(java.util.stream.Stream<org.jlab.coda.xmsg.data.xMsgRegRecord> regData,
                                           long timeout)

syncRun

public T syncRun(long wait,
                 java.util.concurrent.TimeUnit unit)
          throws ClaraException,
                 java.util.concurrent.TimeoutException

Sends the query and waits for a response.

Parameters:

wait - the amount of time units to wait for a response

unit - the unit of time

Returns:

the result of the query

Throws:

ClaraException - if the query could not be sent or received

java.util.concurrent.TimeoutException - if the response is not received

self

protected D self()