com.toc.coredx.DDS.DataReaderListener Interface Reference

The DataReaderListener provides asynchronous notification of DataReader events. This listener can be installed during DataReader creation, DomainParticipant_create_yyy(), as well as by calling DataReader_set_listener(). More...

Inherited by com.toc.coredx.DDS.rpc.Replier< TReq extends RequestType, TRep extends ReplyType >.ReplierDRListener, and com.toc.coredx.DDS.rpc.ServiceProxy< TReq extends RequestType, TRep extends ReplyType >.ServiceProxyDRListener.

Public Member Functions
void	on_requested_deadline_missed (DataReader the_reader, RequestedDeadlineMissedStatus status)
void	on_requested_incompatible_qos (DataReader the_reader, RequestedIncompatibleQosStatus status)
void	on_sample_rejected (DataReader the_reader, SampleRejectedStatus status)
void	on_liveliness_changed (DataReader the_reader, LivelinessChangedStatus status)
void	on_data_available (DataReader the_reader)
void	on_subscription_matched (DataReader the_reader, SubscriptionMatchedStatus status)
void	on_sample_lost (DataReader the_reader, SampleLostStatus status)
long	get_nil_mask ()

Detailed Description

The DataReaderListener provides asynchronous notification of DataReader events. This listener can be installed during DataReader creation, DomainParticipant_create_yyy(), as well as by calling DataReader_set_listener().

Member Function Documentation

get_nil_mask()

long com.toc.coredx.DDS.DataReaderListener.get_nil_mask

(

)

get_nil_mask() returns a bitmask indicating which listener methods (if any) should be considered NIL, and therefore, should not be invoked.

on_data_available()

void com.toc.coredx.DDS.DataReaderListener.on_data_available

(

DataReader

the_reader

)

Called when the CoreDX DDS middleware detects that new data or data state information is available.

The status argument provides a snapshot of the status at the time the listener was invoked.

on_liveliness_changed()

void com.toc.coredx.DDS.DataReaderListener.on_liveliness_changed	(	DataReader	the_reader,
		LivelinessChangedStatus	status
	)

Called when the CoreDX DDS middleware detects that the liveliness of a matched DataWriter has changed (either 'active' or 'inactive').

The status argument provides a snapshot of the status at the time the listener was invoked.

on_requested_deadline_missed()

void com.toc.coredx.DDS.DataReaderListener.on_requested_deadline_missed	(	DataReader	the_reader,
		RequestedDeadlineMissedStatus	status
	)

Called when the CoreDX DDS middleware detects that the deadline specified in the DataReader QoS DEADLINE policy was not satisfied for a data instance.

The status argument provides a snapshot of the status at the time the listener was invoked.

on_requested_incompatible_qos()

void com.toc.coredx.DDS.DataReaderListener.on_requested_incompatible_qos	(	DataReader	the_reader,
		RequestedIncompatibleQosStatus	status
	)

Called when the CoreDX DDS middleware detects that the DataReader requested a QoS policy that was incompatible with that offered by a DataWriter.

The status argument provides a snapshot of the status at the time the listener was invoked.

on_sample_lost()

void com.toc.coredx.DDS.DataReaderListener.on_sample_lost	(	DataReader	the_reader,
		SampleLostStatus	status
	)

Called when the CoreDX DDS middleware detects that a sample has been lost (never received).

The status argument provides a snapshot of the status at the time the listener was invoked.

on_sample_rejected()

void com.toc.coredx.DDS.DataReaderListener.on_sample_rejected	(	DataReader	the_reader,
		SampleRejectedStatus	status
	)

Called when the CoreDX DDS middleware detects that a sample has been rejected.

The status argument provides a snapshot of the status at the time the listener was invoked.

on_subscription_matched()

void com.toc.coredx.DDS.DataReaderListener.on_subscription_matched	(	DataReader	the_reader,
		SubscriptionMatchedStatus	status
	)

Called when the CoreDX DDS middleware detects that the DataReader has matched or ceased to be matched with a DataWriter.

The status argument provides a snapshot of the status at the time the listener was invoked.