OpenSplice Java 5 DCPS  v6.x
OpenSplice Java 5 OpenSplice Data Distribution Service Data-Centric Publish-Subscribe API
Public Member Functions | List of all members
org.opensplice.dds.sub.ReflectionDataReader< TYPE, OUT_TYPE > Class Template Reference
Inheritance diagram for org.opensplice.dds.sub.ReflectionDataReader< TYPE, OUT_TYPE >:
Inheritance graph
Collaboration diagram for org.opensplice.dds.sub.ReflectionDataReader< TYPE, OUT_TYPE >:
Collaboration graph

Public Member Functions

 ReflectionDataReader (OsplServiceEnvironment environment, AbstractDataReader< OUT_TYPE > reader, Class< TYPE > ddsTypeClz)
 
ServiceEnvironment getEnvironment ()
 
TYPE getKeyValue (TYPE keyHolder, InstanceHandle handle)
 
TYPE getKeyValue (InstanceHandle handle)
 
LivelinessChangedStatus getLivelinessChangedStatus ()
 
PublicationBuiltinTopicData getMatchedPublicationData (InstanceHandle publicationHandle)
 
Set< InstanceHandle > getMatchedPublications ()
 
DataReaderQos getQos ()
 
RequestedDeadlineMissedStatus getRequestedDeadlineMissedStatus ()
 
RequestedIncompatibleQosStatus getRequestedIncompatibleQosStatus ()
 
SampleLostStatus getSampleLostStatus ()
 
SampleRejectedStatus getSampleRejectedStatus ()
 
Field getSampleSeqHolderValueField ()
 
SubscriptionMatchedStatus getSubscriptionMatchedStatus ()
 
InstanceHandle lookupInstance (TYPE keyHolder)
 
Iterator< OUT_TYPE > read ()
 
Iterator< OUT_TYPE > read (org.omg.dds.sub.DataReader.Selector< OUT_TYPE > query)
 
Iterator< OUT_TYPE > read (int maxSamples)
 
List< Sample< OUT_TYPE > > read (List< Sample< OUT_TYPE >> samples, org.omg.dds.sub.DataReader.Selector< OUT_TYPE > selector)
 
List< Sample< OUT_TYPE > > read (List< Sample< OUT_TYPE >> samples)
 
boolean readNextSample (SampleImpl< TYPE > sample)
 
void returnLoan (Object sampleSeqHolder, DDS.SampleInfoSeqHolder infoSeqHolder)
 
void setQos (DataReaderQos qos)
 
Iterator< OUT_TYPE > take ()
 
Iterator< OUT_TYPE > take (int maxSamples)
 
Iterator< OUT_TYPE > take (org.omg.dds.sub.DataReader.Selector< OUT_TYPE > query)
 
List< Sample< OUT_TYPE > > take (List< Sample< OUT_TYPE >> samples)
 
List< Sample< OUT_TYPE > > take (List< Sample< OUT_TYPE >> samples, org.omg.dds.sub.DataReader.Selector< OUT_TYPE > selector)
 
boolean takeNextSample (SampleImpl< TYPE > sample)
 
void waitForHistoricalData (Duration maxWait) throws TimeoutException
 
void waitForHistoricalData (long maxWait, TimeUnit unit) throws TimeoutException
 
void waitForHistoricalData (String filterExpression, List< String > filterParameters, Time minSourceTimestamp, Time maxSourceTimestamp, ResourceLimits resourceLimits, Duration maxWait) throws TimeoutException
 
void waitForHistoricalData (String filterExpression, List< String > filterParameters, Time minSourceTimestamp, Time maxSourceTimestamp, ResourceLimits resourceLimits, long maxWait, TimeUnit unit) throws TimeoutException
 

Detailed Description

Definition at line 63 of file ReflectionDataReader.java.

Constructor & Destructor Documentation

◆ ReflectionDataReader()

org.opensplice.dds.sub.ReflectionDataReader< TYPE, OUT_TYPE >.ReflectionDataReader ( OsplServiceEnvironment  environment,
AbstractDataReader< OUT_TYPE >  reader,
Class< TYPE >  ddsTypeClz 
)

Definition at line 91 of file ReflectionDataReader.java.

Member Function Documentation

◆ getEnvironment()

ServiceEnvironment org.opensplice.dds.sub.ReflectionDataReader< TYPE, OUT_TYPE >.getEnvironment ( )
Returns
the org.omg.dds.core.ServiceEnvironment object that directly or indirectly was used to create this object.

Implements org.omg.dds.core.DDSObject.

Definition at line 190 of file ReflectionDataReader.java.

◆ getKeyValue() [1/2]

TYPE org.opensplice.dds.sub.ReflectionDataReader< TYPE, OUT_TYPE >.getKeyValue ( TYPE  keyHolder,
InstanceHandle  handle 
)

Definition at line 361 of file ReflectionDataReader.java.

◆ getKeyValue() [2/2]

TYPE org.opensplice.dds.sub.ReflectionDataReader< TYPE, OUT_TYPE >.getKeyValue ( InstanceHandle  handle)

Definition at line 398 of file ReflectionDataReader.java.

◆ getLivelinessChangedStatus()

LivelinessChangedStatus org.opensplice.dds.sub.ReflectionDataReader< TYPE, OUT_TYPE >.getLivelinessChangedStatus ( )

Definition at line 231 of file ReflectionDataReader.java.

◆ getMatchedPublicationData()

PublicationBuiltinTopicData org.opensplice.dds.sub.ReflectionDataReader< TYPE, OUT_TYPE >.getMatchedPublicationData ( InstanceHandle  publicationHandle)

Definition at line 346 of file ReflectionDataReader.java.

◆ getMatchedPublications()

Set<InstanceHandle> org.opensplice.dds.sub.ReflectionDataReader< TYPE, OUT_TYPE >.getMatchedPublications ( )

Definition at line 330 of file ReflectionDataReader.java.

◆ getQos()

DataReaderQos org.opensplice.dds.sub.ReflectionDataReader< TYPE, OUT_TYPE >.getQos ( )

Definition at line 194 of file ReflectionDataReader.java.

◆ getRequestedDeadlineMissedStatus()

RequestedDeadlineMissedStatus org.opensplice.dds.sub.ReflectionDataReader< TYPE, OUT_TYPE >.getRequestedDeadlineMissedStatus ( )

Definition at line 241 of file ReflectionDataReader.java.

◆ getRequestedIncompatibleQosStatus()

RequestedIncompatibleQosStatus org.opensplice.dds.sub.ReflectionDataReader< TYPE, OUT_TYPE >.getRequestedIncompatibleQosStatus ( )

Definition at line 251 of file ReflectionDataReader.java.

◆ getSampleLostStatus()

SampleLostStatus org.opensplice.dds.sub.ReflectionDataReader< TYPE, OUT_TYPE >.getSampleLostStatus ( )

Definition at line 271 of file ReflectionDataReader.java.

◆ getSampleRejectedStatus()

SampleRejectedStatus org.opensplice.dds.sub.ReflectionDataReader< TYPE, OUT_TYPE >.getSampleRejectedStatus ( )

Definition at line 221 of file ReflectionDataReader.java.

◆ getSampleSeqHolderValueField()

Field org.opensplice.dds.sub.ReflectionDataReader< TYPE, OUT_TYPE >.getSampleSeqHolderValueField ( )

Definition at line 635 of file ReflectionDataReader.java.

◆ getSubscriptionMatchedStatus()

SubscriptionMatchedStatus org.opensplice.dds.sub.ReflectionDataReader< TYPE, OUT_TYPE >.getSubscriptionMatchedStatus ( )

Definition at line 261 of file ReflectionDataReader.java.

◆ lookupInstance()

InstanceHandle org.opensplice.dds.sub.ReflectionDataReader< TYPE, OUT_TYPE >.lookupInstance ( TYPE  keyHolder)

Definition at line 430 of file ReflectionDataReader.java.

◆ read() [1/5]

Iterator<OUT_TYPE> org.opensplice.dds.sub.ReflectionDataReader< TYPE, OUT_TYPE >.read ( )

Definition at line 474 of file ReflectionDataReader.java.

◆ read() [2/5]

Iterator<OUT_TYPE> org.opensplice.dds.sub.ReflectionDataReader< TYPE, OUT_TYPE >.read ( org.omg.dds.sub.DataReader.Selector< OUT_TYPE >  query)

Definition at line 479 of file ReflectionDataReader.java.

◆ read() [3/5]

Iterator<OUT_TYPE> org.opensplice.dds.sub.ReflectionDataReader< TYPE, OUT_TYPE >.read ( int  maxSamples)

Definition at line 570 of file ReflectionDataReader.java.

◆ read() [4/5]

List<Sample<OUT_TYPE> > org.opensplice.dds.sub.ReflectionDataReader< TYPE, OUT_TYPE >.read ( List< Sample< OUT_TYPE >>  samples,
org.omg.dds.sub.DataReader.Selector< OUT_TYPE >  selector 
)

Definition at line 945 of file ReflectionDataReader.java.

◆ read() [5/5]

List<Sample<OUT_TYPE> > org.opensplice.dds.sub.ReflectionDataReader< TYPE, OUT_TYPE >.read ( List< Sample< OUT_TYPE >>  samples)

Definition at line 1035 of file ReflectionDataReader.java.

◆ readNextSample()

boolean org.opensplice.dds.sub.ReflectionDataReader< TYPE, OUT_TYPE >.readNextSample ( SampleImpl< TYPE >  sample)

Definition at line 731 of file ReflectionDataReader.java.

◆ returnLoan()

void org.opensplice.dds.sub.ReflectionDataReader< TYPE, OUT_TYPE >.returnLoan ( Object  sampleSeqHolder,
DDS.SampleInfoSeqHolder  infoSeqHolder 
)

Definition at line 458 of file ReflectionDataReader.java.

◆ setQos()

void org.opensplice.dds.sub.ReflectionDataReader< TYPE, OUT_TYPE >.setQos ( DataReaderQos  qos)

Definition at line 203 of file ReflectionDataReader.java.

◆ take() [1/5]

Iterator<OUT_TYPE> org.opensplice.dds.sub.ReflectionDataReader< TYPE, OUT_TYPE >.take ( )

Definition at line 600 of file ReflectionDataReader.java.

◆ take() [2/5]

Iterator<OUT_TYPE> org.opensplice.dds.sub.ReflectionDataReader< TYPE, OUT_TYPE >.take ( int  maxSamples)

Definition at line 605 of file ReflectionDataReader.java.

◆ take() [3/5]

Iterator<OUT_TYPE> org.opensplice.dds.sub.ReflectionDataReader< TYPE, OUT_TYPE >.take ( org.omg.dds.sub.DataReader.Selector< OUT_TYPE >  query)

Definition at line 640 of file ReflectionDataReader.java.

◆ take() [4/5]

List<Sample<OUT_TYPE> > org.opensplice.dds.sub.ReflectionDataReader< TYPE, OUT_TYPE >.take ( List< Sample< OUT_TYPE >>  samples)

Definition at line 829 of file ReflectionDataReader.java.

◆ take() [5/5]

List<Sample<OUT_TYPE> > org.opensplice.dds.sub.ReflectionDataReader< TYPE, OUT_TYPE >.take ( List< Sample< OUT_TYPE >>  samples,
org.omg.dds.sub.DataReader.Selector< OUT_TYPE >  selector 
)

Definition at line 857 of file ReflectionDataReader.java.

◆ takeNextSample()

boolean org.opensplice.dds.sub.ReflectionDataReader< TYPE, OUT_TYPE >.takeNextSample ( SampleImpl< TYPE >  sample)

Definition at line 781 of file ReflectionDataReader.java.

◆ waitForHistoricalData() [1/4]

void org.opensplice.dds.sub.ReflectionDataReader< TYPE, OUT_TYPE >.waitForHistoricalData ( Duration  maxWait) throws TimeoutException

Definition at line 281 of file ReflectionDataReader.java.

◆ waitForHistoricalData() [2/4]

void org.opensplice.dds.sub.ReflectionDataReader< TYPE, OUT_TYPE >.waitForHistoricalData ( long  maxWait,
TimeUnit  unit 
) throws TimeoutException

Definition at line 289 of file ReflectionDataReader.java.

◆ waitForHistoricalData() [3/4]

void org.opensplice.dds.sub.ReflectionDataReader< TYPE, OUT_TYPE >.waitForHistoricalData ( String  filterExpression,
List< String >  filterParameters,
Time  minSourceTimestamp,
Time  maxSourceTimestamp,
ResourceLimits  resourceLimits,
Duration  maxWait 
) throws TimeoutException

Definition at line 295 of file ReflectionDataReader.java.

◆ waitForHistoricalData() [4/4]

void org.opensplice.dds.sub.ReflectionDataReader< TYPE, OUT_TYPE >.waitForHistoricalData ( String  filterExpression,
List< String >  filterParameters,
Time  minSourceTimestamp,
Time  maxSourceTimestamp,
ResourceLimits  resourceLimits,
long  maxWait,
TimeUnit  unit 
) throws TimeoutException

Definition at line 321 of file ReflectionDataReader.java.

The documentation for this class was generated from the following file: