AbstractDataReader(OsplServiceEnvironment environment, SubscriberImpl parent, TopicDescriptionExt< TYPE > topicDescription) | org.opensplice.dds.sub.AbstractDataReader< TYPE > | |
org::opensplice::dds::core::DomainEntityImpl.close() | org.opensplice.dds.core.EntityImpl< OLD, OLDPARENT, QOS, LISTENER, LISTENERIMPL > | |
org::omg::dds::sub::DataReader.close() | org.omg.dds.core.Entity< LISTENER, QOS > | |
closeContainedEntities() | org.opensplice.dds.sub.AbstractDataReader< TYPE > | |
conditions | org.opensplice.dds.sub.AbstractDataReader< TYPE > | protected |
createIterator(Object sampleSeqHolder, Field sampleSeqHolderValueField, DDS.SampleInfoSeqHolder info) | org.opensplice.dds.sub.AbstractDataReader< TYPE > | |
createQueryCondition(String queryExpression, List< String > queryParameters) | org.opensplice.dds.sub.AbstractDataReader< TYPE > | |
createQueryCondition(DataState states, String queryExpression, List< String > queryParameters) | org.opensplice.dds.sub.AbstractDataReader< TYPE > | |
createQueryCondition(String queryExpression, String... queryParameters) | org.opensplice.dds.sub.AbstractDataReader< TYPE > | |
createQueryCondition(DataState states, String queryExpression, String... queryParameters) | org.opensplice.dds.sub.AbstractDataReader< TYPE > | |
createReadCondition(DataState states) | org.opensplice.dds.sub.AbstractDataReader< TYPE > | |
deregisterIterator(AbstractIterator< TYPE > iterator) | org.opensplice.dds.sub.AbstractDataReader< TYPE > | |
destroy() | org.opensplice.dds.sub.AbstractDataReader< TYPE > | protected |
destroyReadCondition(ReadConditionImpl< TYPE > condition) | org.opensplice.dds.sub.AbstractDataReader< TYPE > | |
DomainEntityImpl(OsplServiceEnvironment environment, PARENT parent, OLDPARENT oldParent) | org.opensplice.dds.core.DomainEntityImpl< OLD extends DDS.Entity, PARENT extends EntityImpl<?, ?, ?, ?, ?, OLDPARENT extends DDS.Entity, QOS extends EntityQos<?, LISTENER extends EventListener, LISTENERIMPL extends Listener< LISTENER > | |
org::opensplice::dds::core::DomainEntityImpl.enable() | org.opensplice.dds.core.EntityImpl< OLD, OLDPARENT, QOS, LISTENER, LISTENERIMPL > | |
org::omg::dds::sub::DataReader.enable() | org.omg.dds.core.Entity< LISTENER, QOS > | |
EntityImpl(OsplServiceEnvironment environment, OLDPARENT oldParent) | org.opensplice.dds.core.EntityImpl< OLD, OLDPARENT, QOS, LISTENER, LISTENERIMPL > | |
environment | org.opensplice.dds.core.EntityImpl< OLD, OLDPARENT, QOS, LISTENER, LISTENERIMPL > | protected |
getEnvironment() | org.opensplice.dds.core.EntityImpl< OLD, OLDPARENT, QOS, LISTENER, LISTENERIMPL > | |
org::opensplice::dds::core::DomainEntityImpl.getInstanceHandle() | org.opensplice.dds.core.EntityImpl< OLD, OLDPARENT, QOS, LISTENER, LISTENERIMPL > | |
org::omg::dds::sub::DataReader.getInstanceHandle() | org.omg.dds.core.Entity< LISTENER, QOS > | |
getKeyValue(TYPE keyHolder, InstanceHandle handle) | org.omg.dds.sub.DataReader< TYPE > | |
getKeyValue(InstanceHandle handle) | org.omg.dds.sub.DataReader< TYPE > | |
org::opensplice::dds::core::DomainEntityImpl.getListener() | org.opensplice.dds.core.EntityImpl< OLD, OLDPARENT, QOS, LISTENER, LISTENERIMPL > | |
org::omg::dds::sub::DataReader.getListener() | org.omg.dds.core.Entity< LISTENER, QOS > | |
getLivelinessChangedStatus() | org.opensplice.dds.sub.AbstractDataReader< TYPE > | |
getMatchedPublicationData(InstanceHandle publicationHandle) | org.opensplice.dds.sub.AbstractDataReader< TYPE > | |
getMatchedPublications() | org.opensplice.dds.sub.AbstractDataReader< TYPE > | |
getOld() | org.opensplice.dds.core.EntityImpl< OLD, OLDPARENT, QOS, LISTENER, LISTENERIMPL > | |
getOldParent() | org.opensplice.dds.core.EntityImpl< OLD, OLDPARENT, QOS, LISTENER, LISTENERIMPL > | |
getParent() | org.opensplice.dds.sub.AbstractDataReader< TYPE > | |
getPreAllocator(List< Sample< TYPE >> samples, Class<?> sampleSeqHolderClz, Field sampleSeqHolderValueField) | org.opensplice.dds.sub.AbstractDataReader< TYPE > | |
getProperty(String key) | org.opensplice.dds.sub.AbstractDataReader< TYPE > | |
getQos() | org.opensplice.dds.sub.AbstractDataReader< TYPE > | |
getReflectionReader() | org.opensplice.dds.sub.AbstractDataReader< TYPE > | protected |
getRequestedDeadlineMissedStatus() | org.opensplice.dds.sub.AbstractDataReader< TYPE > | |
getRequestedIncompatibleQosStatus() | org.opensplice.dds.sub.AbstractDataReader< TYPE > | |
getSampleLostStatus() | org.opensplice.dds.sub.AbstractDataReader< TYPE > | |
getSampleRejectedStatus() | org.opensplice.dds.sub.AbstractDataReader< TYPE > | |
org::opensplice::dds::core::DomainEntityImpl.getStatusChanges() | org.opensplice.dds.core.EntityImpl< OLD, OLDPARENT, QOS, LISTENER, LISTENERIMPL > | |
org::omg::dds::sub::DataReader.getStatusChanges() | org.omg.dds.core.Entity< LISTENER, QOS > | |
getStatusCondition() | org.opensplice.dds.sub.AbstractDataReader< TYPE > | |
getSubscriptionMatchedStatus() | org.opensplice.dds.sub.AbstractDataReader< TYPE > | |
getTopicDescription() | org.opensplice.dds.sub.AbstractDataReader< TYPE > | |
iterators | org.opensplice.dds.sub.AbstractDataReader< TYPE > | protected |
listener | org.opensplice.dds.core.EntityImpl< OLD, OLDPARENT, QOS, LISTENER, LISTENERIMPL > | protected |
lookupInstance(TYPE keyHolder) | org.omg.dds.sub.DataReader< TYPE > | |
parent | org.opensplice.dds.core.DomainEntityImpl< OLD extends DDS.Entity, PARENT extends EntityImpl<?, ?, ?, ?, ?, OLDPARENT extends DDS.Entity, QOS extends EntityQos<?, LISTENER extends EventListener, LISTENERIMPL extends Listener< LISTENER > | protected |
printReferences() | org.opensplice.dds.core.EntityImpl< OLD, OLDPARENT, QOS, LISTENER, LISTENERIMPL > | static |
read() | org.opensplice.dds.sub.AbstractDataReader< TYPE > | |
read(org.omg.dds.sub.DataReader.Selector< TYPE > query) | org.opensplice.dds.sub.AbstractDataReader< TYPE > | |
read(int maxSamples) | org.opensplice.dds.sub.AbstractDataReader< TYPE > | |
read(List< Sample< TYPE >> samples) | org.opensplice.dds.sub.AbstractDataReader< TYPE > | |
read(List< Sample< TYPE >> samples, org.omg.dds.sub.DataReader.Selector< TYPE > selector) | org.opensplice.dds.sub.AbstractDataReader< TYPE > | |
org::omg::dds::sub::DataReader.read(Selector< TYPE > query) | org.omg.dds.sub.DataReader< TYPE > | |
org::omg::dds::sub::DataReader.read(List< Sample< TYPE >> samples, Selector< TYPE > selector) | org.omg.dds.sub.DataReader< TYPE > | |
readNextSample(Sample< TYPE > sample) | org.omg.dds.sub.DataReader< TYPE > | |
registerIterator(AbstractIterator< TYPE > iterator) | org.opensplice.dds.sub.AbstractDataReader< TYPE > | |
org::opensplice::dds::core::DomainEntityImpl.retain() | org.opensplice.dds.core.EntityImpl< OLD, OLDPARENT, QOS, LISTENER, LISTENERIMPL > | |
org::omg::dds::sub::DataReader.retain() | org.omg.dds.core.Entity< LISTENER, QOS > | |
returnLoan(Object sampleSeqHolder, DDS.SampleInfoSeqHolder infoSeqHolder) | org.opensplice.dds.sub.AbstractDataReader< TYPE > | |
select() | org.opensplice.dds.sub.AbstractDataReader< TYPE > | |
selector | org.opensplice.dds.sub.AbstractDataReader< TYPE > | protected |
setListener(DataReaderListener< TYPE > listener) | org.opensplice.dds.sub.AbstractDataReader< TYPE > | |
setListener(DataReaderListener< TYPE > listener, Collection< Class<? extends Status >> statuses) | org.opensplice.dds.sub.AbstractDataReader< TYPE > | |
setListener(DataReaderListener< TYPE > listener, Class<? extends Status >... statuses) | org.opensplice.dds.sub.AbstractDataReader< TYPE > | |
org::omg::dds::sub::DataReader.setListener(LISTENER listener) | org.omg.dds.core.Entity< LISTENER, QOS > | |
org::omg::dds::sub::DataReader.setListener(LISTENER listener, Collection< Class<? extends Status >> statuses) | org.omg.dds.core.Entity< LISTENER, QOS > | |
org::omg::dds::sub::DataReader.setListener(LISTENER listener, Class<? extends Status >... statuses) | org.omg.dds.core.Entity< LISTENER, QOS > | |
setOld(OLD old) | org.opensplice.dds.core.EntityImpl< OLD, OLDPARENT, QOS, LISTENER, LISTENERIMPL > | protected |
setProperty(String key, String value) | org.opensplice.dds.sub.AbstractDataReader< TYPE > | |
setQos(DataReaderQos qos) | org.opensplice.dds.sub.AbstractDataReader< TYPE > | |
org::omg::dds::sub::DataReader.setQos(QOS qos) | org.omg.dds.core.Entity< LISTENER, QOS > | |
take() | org.opensplice.dds.sub.AbstractDataReader< TYPE > | |
take(int maxSamples) | org.opensplice.dds.sub.AbstractDataReader< TYPE > | |
take(org.omg.dds.sub.DataReader.Selector< TYPE > query) | org.opensplice.dds.sub.AbstractDataReader< TYPE > | |
take(List< Sample< TYPE >> samples) | org.opensplice.dds.sub.AbstractDataReader< TYPE > | |
take(List< Sample< TYPE >> samples, org.omg.dds.sub.DataReader.Selector< TYPE > selector) | org.opensplice.dds.sub.AbstractDataReader< TYPE > | |
org::omg::dds::sub::DataReader.take(Selector< TYPE > query) | org.omg.dds.sub.DataReader< TYPE > | |
org::omg::dds::sub::DataReader.take(List< Sample< TYPE >> samples, Selector< TYPE > query) | org.omg.dds.sub.DataReader< TYPE > | |
takeNextSample(Sample< TYPE > sample) | org.omg.dds.sub.DataReader< TYPE > | |
topicDescription | org.opensplice.dds.sub.AbstractDataReader< TYPE > | protected |
waitForHistoricalData(Duration maxWait) | org.opensplice.dds.sub.AbstractDataReader< TYPE > | |
waitForHistoricalData(long maxWait, TimeUnit unit) | org.opensplice.dds.sub.AbstractDataReader< TYPE > | |
waitForHistoricalData(String filterExpression, List< String > filterParameters, Time minSourceTimestamp, Time maxSourceTimestamp, ResourceLimits resourceLimits, Duration maxWait) | org.opensplice.dds.sub.AbstractDataReader< TYPE > | |
waitForHistoricalData(String filterExpression, List< String > filterParameters, Time minSourceTimestamp, Time maxSourceTimestamp, Duration maxWait) | org.opensplice.dds.sub.AbstractDataReader< TYPE > | |
waitForHistoricalData(String filterExpression, List< String > filterParameters, ResourceLimits resourceLimits, Duration maxWait) | org.opensplice.dds.sub.AbstractDataReader< TYPE > | |
waitForHistoricalData(String filterExpression, List< String > filterParameters, Duration maxWait) | org.opensplice.dds.sub.AbstractDataReader< TYPE > | |
waitForHistoricalData(Time minSourceTimestamp, Time maxSourceTimestamp, ResourceLimits resourceLimits, Duration maxWait) | org.opensplice.dds.sub.AbstractDataReader< TYPE > | |
waitForHistoricalData(Time minSourceTimestamp, Time maxSourceTimestamp, Duration maxWait) | org.opensplice.dds.sub.AbstractDataReader< TYPE > | |
waitForHistoricalData(ResourceLimits resourceLimits, Duration maxWait) | org.opensplice.dds.sub.AbstractDataReader< TYPE > | |
waitForHistoricalData(String filterExpression, List< String > filterParameters, Time minSourceTimestamp, Time maxSourceTimestamp, ResourceLimits resourceLimits, long maxWait, TimeUnit unit) | org.opensplice.dds.sub.AbstractDataReader< TYPE > | |
waitForHistoricalData(String filterExpression, List< String > filterParameters, Time minSourceTimestamp, Time maxSourceTimestamp, long maxWait, TimeUnit unit) | org.opensplice.dds.sub.AbstractDataReader< TYPE > | |
waitForHistoricalData(String filterExpression, List< String > filterParameters, ResourceLimits resourceLimits, long maxWait, TimeUnit unit) | org.opensplice.dds.sub.AbstractDataReader< TYPE > | |
waitForHistoricalData(String filterExpression, List< String > filterParameters, long maxWait, TimeUnit unit) | org.opensplice.dds.sub.AbstractDataReader< TYPE > | |
waitForHistoricalData(Time minSourceTimestamp, Time maxSourceTimestamp, ResourceLimits resourceLimits, long maxWait, TimeUnit unit) | org.opensplice.dds.sub.AbstractDataReader< TYPE > | |
waitForHistoricalData(Time minSourceTimestamp, Time maxSourceTimestamp, long maxWait, TimeUnit unit) | org.opensplice.dds.sub.AbstractDataReader< TYPE > | |
waitForHistoricalData(ResourceLimits resourceLimits, long maxWait, TimeUnit unit) | org.opensplice.dds.sub.AbstractDataReader< TYPE > | |