<<extension>> A listener adapter in the spirit of the Java AWT listener adapters. (The Adapter provides empty implementations for the listener methods) More...

Inheritance diagram for DomainParticipantAdapter:

Public Member Functions
void	on_inconsistent_topic (Topic topic, InconsistentTopicStatus status)
	Handle the com.rti.dds.infrastructure.StatusKind.StatusKind.INCONSISTENT_TOPIC_STATUS status. More...

void	on_offered_deadline_missed (DataWriter writer, OfferedDeadlineMissedStatus status)
	Handles the com.rti.dds.infrastructure.StatusKind.StatusKind.OFFERED_DEADLINE_MISSED_STATUS status. More...

void	on_offered_incompatible_qos (DataWriter writer, OfferedIncompatibleQosStatus status)
	Handles the com.rti.dds.infrastructure.StatusKind.StatusKind.OFFERED_INCOMPATIBLE_QOS_STATUS status. More...

void	on_liveliness_lost (DataWriter writer, LivelinessLostStatus status)
	Handles the com.rti.dds.infrastructure.StatusKind.StatusKind.LIVELINESS_LOST_STATUS status. More...

void	on_publication_matched (DataWriter writer, PublicationMatchedStatus status)
	Handles the com.rti.dds.infrastructure.StatusKind.StatusKind.PUBLICATION_MATCHED_STATUS status. More...

void	on_reliable_reader_activity_changed (DataWriter writer, ReliableReaderActivityChangedStatus status)
	<<extension>> A matched reliable reader has become active or become inactive. More...

void	on_reliable_writer_cache_changed (DataWriter writer, ReliableWriterCacheChangedStatus status)
	<<extension>> A change has occurred in the writer's cache of unacknowledged samples. More...

void	on_instance_replaced (DataWriter writer, InstanceHandle_t handle)
	<<extension>> Notifies when an instance is replaced in DataWriter queue. More...

void	on_application_acknowledgment (DataWriter writer, AcknowledgmentInfo ackInfo)
	<<extension>> Called when a sample is application-acknowledged More...

void	on_service_request_accepted (DataWriter writer, ServiceRequestAcceptedStatus status)
	<<extension>> Called when a com.rti.dds.topic.builtin.ServiceRequest for the com.rti.dds.subscription.TopicQuery service is dispatched to this com.rti.dds.publication.DataWriter for processing. More...

Public Member Functions inherited from SubscriberAdapter
void	on_data_on_readers (Subscriber subs)
	Handles the com.rti.dds.infrastructure.StatusKind.StatusKind.DATA_ON_READERS_STATUS communication status. More...

Public Member Functions inherited from DataReaderAdapter
void	on_requested_deadline_missed (DataReader reader, RequestedDeadlineMissedStatus status)
	Handles the com.rti.dds.infrastructure.StatusKind.StatusKind.REQUESTED_DEADLINE_MISSED_STATUS communication status. More...

void	on_requested_incompatible_qos (DataReader reader, RequestedIncompatibleQosStatus status)
	Handles the com.rti.dds.infrastructure.StatusKind.StatusKind.REQUESTED_INCOMPATIBLE_QOS_STATUS communication status. More...

void	on_sample_rejected (DataReader reader, SampleRejectedStatus status)
	Handles the com.rti.dds.infrastructure.StatusKind.StatusKind.SAMPLE_REJECTED_STATUS communication status. More...

void	on_liveliness_changed (DataReader reader, LivelinessChangedStatus status)
	Handles the com.rti.dds.infrastructure.StatusKind.StatusKind.LIVELINESS_CHANGED_STATUS communication status. More...

void	on_data_available (DataReader reader)
	Handle the com.rti.dds.infrastructure.StatusKind.StatusKind.DATA_AVAILABLE_STATUS communication status. More...

void	on_sample_lost (DataReader reader, SampleLostStatus status)
	Handles the com.rti.dds.infrastructure.StatusKind.StatusKind.SAMPLE_LOST_STATUS_STATUS communication status. More...

void	on_subscription_matched (DataReader reader, SubscriptionMatchedStatus status)
	Handles the com.rti.dds.infrastructure.StatusKind.StatusKind.SUBSCRIPTION_MATCHED_STATUS communication status. More...

Detailed Description

<<extension>> A listener adapter in the spirit of the Java AWT listener adapters. (The Adapter provides empty implementations for the listener methods)

Clients who do not wish to implement all listener methods can subclass this class and override only the methods of interest.

Member Function Documentation

◆ on_inconsistent_topic()

void on_inconsistent_topic	(	Topic	topic,
		InconsistentTopicStatus	status
	)

Handle the com.rti.dds.infrastructure.StatusKind.StatusKind.INCONSISTENT_TOPIC_STATUS status.

This callback is called when a remote com.rti.dds.topic.Topic is discovered but is inconsistent with the locally created com.rti.dds.topic.Topic of the same topic name.

Parameters

topic	<<out>> Locally created com.rti.dds.topic.Topic that triggers the listener callback
status	<<out>> Current inconsistent status of locally created com.rti.dds.topic.Topic

Implements TopicListener.

◆ on_offered_deadline_missed()

void on_offered_deadline_missed	(	DataWriter	writer,
		OfferedDeadlineMissedStatus	status
	)

Handles the com.rti.dds.infrastructure.StatusKind.StatusKind.OFFERED_DEADLINE_MISSED_STATUS status.

This callback is called when the deadline that the com.rti.dds.publication.DataWriter has committed through its DEADLINE qos policy was not respected for a specific instance. This callback is called for each deadline period elapsed during which the com.rti.dds.publication.DataWriter failed to provide data for an instance.

Parameters

writer	<<out>> Locally created com.rti.dds.publication.DataWriter that triggers the listener callback
status	<<out>> Current deadline missed status of locally created com.rti.dds.publication.DataWriter

Implements DataWriterListener.

◆ on_offered_incompatible_qos()

void on_offered_incompatible_qos	(	DataWriter	writer,
		OfferedIncompatibleQosStatus	status
	)

Handles the com.rti.dds.infrastructure.StatusKind.StatusKind.OFFERED_INCOMPATIBLE_QOS_STATUS status.

This callback is called when the com.rti.dds.publication.DataWriterQos of the com.rti.dds.publication.DataWriter was incompatible with what was requested by a com.rti.dds.subscription.DataReader. This callback is called when a com.rti.dds.publication.DataWriter has discovered a com.rti.dds.subscription.DataReader for the same com.rti.dds.topic.Topic and common partition, but with a requested QoS that is incompatible with that offered by the com.rti.dds.publication.DataWriter.

Parameters

writer	<<out>> Locally created com.rti.dds.publication.DataWriter that triggers the listener callback
status	<<out>> Current incompatible qos status of locally created com.rti.dds.publication.DataWriter

Implements DataWriterListener.

◆ on_liveliness_lost()

void on_liveliness_lost	(	DataWriter	writer,
		LivelinessLostStatus	status
	)

Handles the com.rti.dds.infrastructure.StatusKind.StatusKind.LIVELINESS_LOST_STATUS status.

This callback is called when the liveliness that the com.rti.dds.publication.DataWriter has committed through its LIVELINESS qos policy was not respected; this com.rti.dds.subscription.DataReader entities will consider the com.rti.dds.publication.DataWriter as no longer "alive/active". This callback will not be called when an already not alive com.rti.dds.publication.DataWriter simply remains not alive for another liveliness period.

Parameters

writer	<<out>> Locally created com.rti.dds.publication.DataWriter that triggers the listener callback
status	<<out>> Current liveliness lost status of locally created com.rti.dds.publication.DataWriter

Implements DataWriterListener.

◆ on_publication_matched()

void on_publication_matched	(	DataWriter	writer,
		PublicationMatchedStatus	status
	)

Handles the com.rti.dds.infrastructure.StatusKind.StatusKind.PUBLICATION_MATCHED_STATUS status.

This callback is called when the com.rti.dds.publication.DataWriter has found a com.rti.dds.subscription.DataReader that matches the com.rti.dds.topic.Topic, has a common partition and compatible QoS, or has ceased to be matched with a com.rti.dds.subscription.DataReader that was previously considered to be matched.

Parameters

writer	<<out>> Locally created com.rti.dds.publication.DataWriter that triggers the listener callback
status	<<out>> Current publication match status of locally created com.rti.dds.publication.DataWriter

Implements DataWriterListener.

◆ on_reliable_reader_activity_changed()

void on_reliable_reader_activity_changed	(	DataWriter	writer,
		ReliableReaderActivityChangedStatus	status
	)

<<extension>> A matched reliable reader has become active or become inactive.

Parameters

writer	<<out>> Locally created com.rti.dds.publication.DataWriter that triggers the listener callback
status	<<out>> Current reliable reader activity changed status of locally created com.rti.dds.publication.DataWriter

Implements DataWriterListener.

◆ on_reliable_writer_cache_changed()

void on_reliable_writer_cache_changed	(	DataWriter	writer,
		ReliableWriterCacheChangedStatus	status
	)

<<extension>> A change has occurred in the writer's cache of unacknowledged samples.

This listener callback is triggered when:

The cache is empty (contains no unacknowledged samples).
The cache is full (the number of unacknowledged samples has reached the value specified in com.rti.dds.infrastructure.ResourceLimitsQosPolicy.max_samples).
The number of unacknowledged samples has reached com.rti.dds.infrastructure.RtpsReliableWriterProtocol_t.high_watermark or com.rti.dds.infrastructure.RtpsReliableWriterProtocol_t.low_watermark.

Parameters

writer	<<out>> Locally created com.rti.dds.publication.DataWriter that triggers the listener callback
status	<<out>> Current reliable writer cache changed status of locally created com.rti.dds.publication.DataWriter

Implements DataWriterListener.

◆ on_instance_replaced()

void on_instance_replaced	(	DataWriter	writer,
		InstanceHandle_t	handle
	)

<<extension>> Notifies when an instance is replaced in DataWriter queue.

This callback is called when an instance is replaced by the com.rti.dds.publication.DataWriter due to instance resource limits being reached. This callback returns to the user the handle of the replaced instance, which can be used to get the key of the replaced instance.

Parameters

writer	<<out>> Locally created com.rti.dds.publication.DataWriter that triggers the listener callback
handle	<<out>> Handle of the replaced instance

Implements DataWriterListener.

◆ on_application_acknowledgment()

void on_application_acknowledgment	(	DataWriter	writer,
		AcknowledgmentInfo	info
	)

<<extension>> Called when a sample is application-acknowledged

Applicable only when com.rti.dds.infrastructure.ReliabilityQosPolicy.acknowledgment_kind = com.rti.dds.infrastructure.ReliabilityQosPolicyAcknowledgmentModeKind.APPLICATION_AUTO_ACKNOWLEDGMENT_MODE or com.rti.dds.infrastructure.ReliabilityQosPolicyAcknowledgmentModeKind.APPLICATION_EXPLICIT_ACKNOWLEDGMENT_MODE

Called when a sample is application-level acknowledged. Provides identities of the sample and the acknowledging com.rti.dds.subscription.DataReader. Also provides user-specified response data sent from the com.rti.dds.subscription.DataReader by the acknowledgment message.

Parameters

writer	<<out>> Locally created com.rti.dds.publication.DataWriter that triggers the listener callback
info	<<out>> com.rti.dds.publication.AcknowledgmentInfo of the acknowledged sample

Implements DataWriterListener.

◆ on_service_request_accepted()

void on_service_request_accepted	(	DataWriter	writer,
		ServiceRequestAcceptedStatus	status
	)

<<extension>> Called when a com.rti.dds.topic.builtin.ServiceRequest for the com.rti.dds.subscription.TopicQuery service is dispatched to this com.rti.dds.publication.DataWriter for processing.

Parameters

writer	<<out>> Locally created com.rti.dds.publication.DataWriter that triggers the listener callback
status	<<out>> Current service request accepted status of locally created com.rti.dds.publication.DataWriter

See also: Topic Queries

Implements DataWriterListener.

Public Member Functions

Detailed Description

Member Function Documentation

◆ on_inconsistent_topic()

◆ on_offered_deadline_missed()

◆ on_offered_incompatible_qos()

◆ on_liveliness_lost()

◆ on_publication_matched()

◆ on_reliable_reader_activity_changed()

◆ on_reliable_writer_cache_changed()

◆ on_instance_replaced()

◆ on_application_acknowledgment()

◆ on_service_request_accepted()