Inheritance diagram for org.opensplice.dds.pub.DataWriterProtobuf< PROTOBUF_TYPE, DDS_TYPE >:

Collaboration diagram for org.opensplice.dds.pub.DataWriterProtobuf< PROTOBUF_TYPE, DDS_TYPE >:

Public Member Functions
	DataWriterProtobuf (OsplServiceEnvironment environment, PublisherImpl parent, TopicProtobuf< PROTOBUF_TYPE > topic, DataWriterQos qos, DataWriterListener< PROTOBUF_TYPE > listener, Collection< Class<? extends Status >> statuses)

void	assertLiveliness ()

void	dispose (InstanceHandle instanceHandle) throws TimeoutException

void	dispose (InstanceHandle instanceHandle, PROTOBUF_TYPE instanceData) throws TimeoutException

void	dispose (InstanceHandle instanceHandle, PROTOBUF_TYPE instanceData, Time sourceTimestamp) throws TimeoutException

void	dispose (InstanceHandle instanceHandle, PROTOBUF_TYPE instanceData, long sourceTimeStamp, TimeUnit unit) throws TimeoutException

ServiceEnvironment	getEnvironment ()

PROTOBUF_TYPE	getKeyValue (InstanceHandle instanceHandle)

PROTOBUF_TYPE	getKeyValue (PROTOBUF_TYPE instanceData, InstanceHandle instanceHandle)

LivelinessLostStatus	getLivelinessLostStatus ()

SubscriptionBuiltinTopicData	getMatchedSubscriptionData (InstanceHandle instanceHandle)

Set< InstanceHandle >	getMatchedSubscriptions ()

OfferedDeadlineMissedStatus	getOfferedDeadlineMissedStatus ()

OfferedIncompatibleQosStatus	getOfferedIncompatibleQosStatus ()

Publisher	getParent ()

PublicationMatchedStatus	getPublicationMatchedStatus ()

DataWriterQos	getQos ()

StatusCondition< org.omg.dds.pub.DataWriter< PROTOBUF_TYPE > >	getStatusCondition ()

Topic< PROTOBUF_TYPE >	getTopic ()

InstanceHandle	lookupInstance (PROTOBUF_TYPE instanceData)

InstanceHandle	registerInstance (PROTOBUF_TYPE instanceData) throws TimeoutException

InstanceHandle	registerInstance (PROTOBUF_TYPE instanceData, Time sourceTimestamp) throws TimeoutException

InstanceHandle	registerInstance (PROTOBUF_TYPE instanceData, long sourceTimestamp, TimeUnit unit) throws TimeoutException

void	setListener (DataWriterListener< PROTOBUF_TYPE > listener)

void	setListener (DataWriterListener< PROTOBUF_TYPE > listener, Collection< Class<? extends Status >> statuses)

void	setListener (DataWriterListener< PROTOBUF_TYPE > listener, Class<? extends Status >... statuses)

void	setQos (DataWriterQos qos)

void	unregisterInstance (InstanceHandle handle) throws TimeoutException

void	unregisterInstance (InstanceHandle handle, PROTOBUF_TYPE instanceData) throws TimeoutException

void	unregisterInstance (InstanceHandle handle, PROTOBUF_TYPE instanceData, Time sourceTimestamp) throws TimeoutException

void	unregisterInstance (InstanceHandle handle, PROTOBUF_TYPE instanceData, long sourceTimestamp, TimeUnit unit) throws TimeoutException

void	waitForAcknowledgments (Duration maxWait) throws TimeoutException

void	waitForAcknowledgments (long maxWait, TimeUnit unit) throws TimeoutException

void	write (PROTOBUF_TYPE instanceData) throws TimeoutException

void	write (PROTOBUF_TYPE instanceData, Time sourceTimestamp) throws TimeoutException

void	write (PROTOBUF_TYPE instanceData, InstanceHandle handle) throws TimeoutException

void	write (PROTOBUF_TYPE instanceData, long sourceTimestamp, TimeUnit unit) throws TimeoutException

void	write (PROTOBUF_TYPE instanceData, InstanceHandle handle, Time sourceTimestamp) throws TimeoutException

void	write (PROTOBUF_TYPE instanceData, InstanceHandle handle, long sourceTimestamp, TimeUnit unit) throws TimeoutException

void	writeDispose (PROTOBUF_TYPE instanceData) throws TimeoutException

void	writeDispose (PROTOBUF_TYPE instanceData, Time sourceTimestamp) throws TimeoutException

void	writeDispose (PROTOBUF_TYPE instanceData, InstanceHandle handle) throws TimeoutException

void	writeDispose (PROTOBUF_TYPE instanceData, long sourceTimestamp, TimeUnit unit) throws TimeoutException

void	writeDispose (PROTOBUF_TYPE instanceData, InstanceHandle handle, Time sourceTimestamp) throws TimeoutException

void	writeDispose (PROTOBUF_TYPE instanceData, InstanceHandle instanceHandle, long sourceTimestamp, TimeUnit unit) throws TimeoutException

Protected Member Functions
void	destroy ()

Protected Attributes
final TypeSupportProtobuf< PROTOBUF_TYPE, DDS_TYPE >	typeSupport

Detailed Description

Definition at line 53 of file DataWriterProtobuf.java.

Constructor & Destructor Documentation

◆ DataWriterProtobuf()

org.opensplice.dds.pub.DataWriterProtobuf< PROTOBUF_TYPE, DDS_TYPE >.DataWriterProtobuf	(	OsplServiceEnvironment	environment,
		PublisherImpl	parent,
		TopicProtobuf< PROTOBUF_TYPE >	topic,
		DataWriterQos	qos,
		DataWriterListener< PROTOBUF_TYPE >	listener,
		Collection< Class<? extends Status >>	statuses
	)

Definition at line 60 of file DataWriterProtobuf.java.

Member Function Documentation

◆ assertLiveliness()

void org.opensplice.dds.pub.DataWriterProtobuf< PROTOBUF_TYPE, DDS_TYPE >.assertLiveliness ( )

Definition at line 117 of file DataWriterProtobuf.java.

◆ destroy()

void org.opensplice.dds.pub.DataWriterProtobuf< PROTOBUF_TYPE, DDS_TYPE >.destroy ( )

protected

Definition at line 447 of file DataWriterProtobuf.java.

◆ dispose() [1/4]

void org.opensplice.dds.pub.DataWriterProtobuf< PROTOBUF_TYPE, DDS_TYPE >.dispose ( InstanceHandle instanceHandle ) throws TimeoutException

Definition at line 112 of file DataWriterProtobuf.java.

◆ dispose() [2/4]

void org.opensplice.dds.pub.DataWriterProtobuf< PROTOBUF_TYPE, DDS_TYPE >.dispose	(	InstanceHandle	instanceHandle,
		PROTOBUF_TYPE	instanceData
	)		throws TimeoutException

Definition at line 136 of file DataWriterProtobuf.java.

◆ dispose() [3/4]

void org.opensplice.dds.pub.DataWriterProtobuf< PROTOBUF_TYPE, DDS_TYPE >.dispose	(	InstanceHandle	instanceHandle,
		PROTOBUF_TYPE	instanceData,
		Time	sourceTimestamp
	)		throws TimeoutException

Definition at line 143 of file DataWriterProtobuf.java.

◆ dispose() [4/4]

void org.opensplice.dds.pub.DataWriterProtobuf< PROTOBUF_TYPE, DDS_TYPE >.dispose	(	InstanceHandle	instanceHandle,
		PROTOBUF_TYPE	instanceData,
		long	sourceTimeStamp,
		TimeUnit	unit
	)		throws TimeoutException

Definition at line 152 of file DataWriterProtobuf.java.

◆ getEnvironment()

ServiceEnvironment org.opensplice.dds.pub.DataWriterProtobuf< PROTOBUF_TYPE, DDS_TYPE >.getEnvironment ( )

Definition at line 395 of file DataWriterProtobuf.java.

◆ getKeyValue() [1/2]

PROTOBUF_TYPE org.opensplice.dds.pub.DataWriterProtobuf< PROTOBUF_TYPE, DDS_TYPE >.getKeyValue ( InstanceHandle instanceHandle )

Definition at line 161 of file DataWriterProtobuf.java.

◆ getKeyValue() [2/2]

PROTOBUF_TYPE org.opensplice.dds.pub.DataWriterProtobuf< PROTOBUF_TYPE, DDS_TYPE >.getKeyValue	(	PROTOBUF_TYPE	instanceData,
		InstanceHandle	instanceHandle
	)

Definition at line 171 of file DataWriterProtobuf.java.

◆ getLivelinessLostStatus()

LivelinessLostStatus org.opensplice.dds.pub.DataWriterProtobuf< PROTOBUF_TYPE, DDS_TYPE >.getLivelinessLostStatus ( )

Definition at line 183 of file DataWriterProtobuf.java.

◆ getMatchedSubscriptionData()

SubscriptionBuiltinTopicData org.opensplice.dds.pub.DataWriterProtobuf< PROTOBUF_TYPE, DDS_TYPE >.getMatchedSubscriptionData ( InstanceHandle instanceHandle )

Definition at line 188 of file DataWriterProtobuf.java.

◆ getMatchedSubscriptions()

Set<InstanceHandle> org.opensplice.dds.pub.DataWriterProtobuf< PROTOBUF_TYPE, DDS_TYPE >.getMatchedSubscriptions ( )

Definition at line 194 of file DataWriterProtobuf.java.

◆ getOfferedDeadlineMissedStatus()

OfferedDeadlineMissedStatus org.opensplice.dds.pub.DataWriterProtobuf< PROTOBUF_TYPE, DDS_TYPE >.getOfferedDeadlineMissedStatus ( )

Definition at line 199 of file DataWriterProtobuf.java.

◆ getOfferedIncompatibleQosStatus()

OfferedIncompatibleQosStatus org.opensplice.dds.pub.DataWriterProtobuf< PROTOBUF_TYPE, DDS_TYPE >.getOfferedIncompatibleQosStatus ( )

Definition at line 204 of file DataWriterProtobuf.java.

◆ getParent()

Publisher org.opensplice.dds.pub.AbstractDataWriter< TYPE >.getParent ( )

inherited

Returns: the factory object that created this entity.

Definition at line 45 of file AbstractDataWriter.java.

◆ getPublicationMatchedStatus()

PublicationMatchedStatus org.opensplice.dds.pub.DataWriterProtobuf< PROTOBUF_TYPE, DDS_TYPE >.getPublicationMatchedStatus ( )

Definition at line 209 of file DataWriterProtobuf.java.

◆ getQos()

DataWriterQos org.opensplice.dds.pub.DataWriterProtobuf< PROTOBUF_TYPE, DDS_TYPE >.getQos ( )

Definition at line 348 of file DataWriterProtobuf.java.

◆ getStatusCondition()

StatusCondition<org.omg.dds.pub.DataWriter<PROTOBUF_TYPE> > org.opensplice.dds.pub.DataWriterProtobuf< PROTOBUF_TYPE, DDS_TYPE >.getStatusCondition ( )

Definition at line 214 of file DataWriterProtobuf.java.

◆ getTopic()

Topic<PROTOBUF_TYPE> org.opensplice.dds.pub.DataWriterProtobuf< PROTOBUF_TYPE, DDS_TYPE >.getTopic ( )

Definition at line 225 of file DataWriterProtobuf.java.

◆ lookupInstance()

InstanceHandle org.opensplice.dds.pub.DataWriterProtobuf< PROTOBUF_TYPE, DDS_TYPE >.lookupInstance ( PROTOBUF_TYPE instanceData )

Definition at line 230 of file DataWriterProtobuf.java.

◆ registerInstance() [1/3]

InstanceHandle org.opensplice.dds.pub.DataWriterProtobuf< PROTOBUF_TYPE, DDS_TYPE >.registerInstance ( PROTOBUF_TYPE instanceData ) throws TimeoutException

Definition at line 236 of file DataWriterProtobuf.java.

◆ registerInstance() [2/3]

InstanceHandle org.opensplice.dds.pub.DataWriterProtobuf< PROTOBUF_TYPE, DDS_TYPE >.registerInstance	(	PROTOBUF_TYPE	instanceData,
		Time	sourceTimestamp
	)		throws TimeoutException

Definition at line 243 of file DataWriterProtobuf.java.

◆ registerInstance() [3/3]

InstanceHandle org.opensplice.dds.pub.DataWriterProtobuf< PROTOBUF_TYPE, DDS_TYPE >.registerInstance	(	PROTOBUF_TYPE	instanceData,
		long	sourceTimestamp,
		TimeUnit	unit
	)		throws TimeoutException

Definition at line 250 of file DataWriterProtobuf.java.

◆ setListener() [1/3]

void org.opensplice.dds.pub.DataWriterProtobuf< PROTOBUF_TYPE, DDS_TYPE >.setListener ( DataWriterListener< PROTOBUF_TYPE > listener )

Definition at line 371 of file DataWriterProtobuf.java.

◆ setListener() [2/3]

void org.opensplice.dds.pub.DataWriterProtobuf< PROTOBUF_TYPE, DDS_TYPE >.setListener	(	DataWriterListener< PROTOBUF_TYPE >	listener,
		Collection< Class<? extends Status >>	statuses
	)

Definition at line 376 of file DataWriterProtobuf.java.

◆ setListener() [3/3]

void org.opensplice.dds.pub.DataWriterProtobuf< PROTOBUF_TYPE, DDS_TYPE >.setListener	(	DataWriterListener< PROTOBUF_TYPE >	listener,
		Class<? extends Status >...	statuses
	)

Definition at line 383 of file DataWriterProtobuf.java.

◆ setQos()

void org.opensplice.dds.pub.DataWriterProtobuf< PROTOBUF_TYPE, DDS_TYPE >.setQos ( DataWriterQos qos )

Definition at line 390 of file DataWriterProtobuf.java.

◆ unregisterInstance() [1/4]

void org.opensplice.dds.pub.DataWriterProtobuf< PROTOBUF_TYPE, DDS_TYPE >.unregisterInstance ( InstanceHandle handle ) throws TimeoutException

Definition at line 258 of file DataWriterProtobuf.java.

◆ unregisterInstance() [2/4]

void org.opensplice.dds.pub.DataWriterProtobuf< PROTOBUF_TYPE, DDS_TYPE >.unregisterInstance	(	InstanceHandle	handle,
		PROTOBUF_TYPE	instanceData
	)		throws TimeoutException

Definition at line 265 of file DataWriterProtobuf.java.

◆ unregisterInstance() [3/4]

void org.opensplice.dds.pub.DataWriterProtobuf< PROTOBUF_TYPE, DDS_TYPE >.unregisterInstance	(	InstanceHandle	handle,
		PROTOBUF_TYPE	instanceData,
		Time	sourceTimestamp
	)		throws TimeoutException

Definition at line 272 of file DataWriterProtobuf.java.

◆ unregisterInstance() [4/4]

void org.opensplice.dds.pub.DataWriterProtobuf< PROTOBUF_TYPE, DDS_TYPE >.unregisterInstance	(	InstanceHandle	handle,
		PROTOBUF_TYPE	instanceData,
		long	sourceTimestamp,
		TimeUnit	unit
	)		throws TimeoutException

Definition at line 281 of file DataWriterProtobuf.java.

◆ waitForAcknowledgments() [1/2]

void org.opensplice.dds.pub.DataWriterProtobuf< PROTOBUF_TYPE, DDS_TYPE >.waitForAcknowledgments ( Duration maxWait ) throws TimeoutException

Definition at line 291 of file DataWriterProtobuf.java.

◆ waitForAcknowledgments() [2/2]

void org.opensplice.dds.pub.DataWriterProtobuf< PROTOBUF_TYPE, DDS_TYPE >.waitForAcknowledgments	(	long	maxWait,
		TimeUnit	unit
	)		throws TimeoutException

Definition at line 297 of file DataWriterProtobuf.java.

◆ write() [1/6]

void org.opensplice.dds.pub.DataWriterProtobuf< PROTOBUF_TYPE, DDS_TYPE >.write ( PROTOBUF_TYPE instanceData ) throws TimeoutException

Definition at line 303 of file DataWriterProtobuf.java.

◆ write() [2/6]

void org.opensplice.dds.pub.DataWriterProtobuf< PROTOBUF_TYPE, DDS_TYPE >.write	(	PROTOBUF_TYPE	instanceData,
		Time	sourceTimestamp
	)		throws TimeoutException

Definition at line 309 of file DataWriterProtobuf.java.

◆ write() [3/6]

void org.opensplice.dds.pub.DataWriterProtobuf< PROTOBUF_TYPE, DDS_TYPE >.write	(	PROTOBUF_TYPE	instanceData,
		InstanceHandle	handle
	)		throws TimeoutException

Definition at line 316 of file DataWriterProtobuf.java.

◆ write() [4/6]

void org.opensplice.dds.pub.DataWriterProtobuf< PROTOBUF_TYPE, DDS_TYPE >.write	(	PROTOBUF_TYPE	instanceData,
		long	sourceTimestamp,
		TimeUnit	unit
	)		throws TimeoutException

Definition at line 324 of file DataWriterProtobuf.java.

◆ write() [5/6]

void org.opensplice.dds.pub.DataWriterProtobuf< PROTOBUF_TYPE, DDS_TYPE >.write	(	PROTOBUF_TYPE	instanceData,
		InstanceHandle	handle,
		Time	sourceTimestamp
	)		throws TimeoutException

Definition at line 332 of file DataWriterProtobuf.java.

◆ write() [6/6]

void org.opensplice.dds.pub.DataWriterProtobuf< PROTOBUF_TYPE, DDS_TYPE >.write	(	PROTOBUF_TYPE	instanceData,
		InstanceHandle	handle,
		long	sourceTimestamp,
		TimeUnit	unit
	)		throws TimeoutException

Definition at line 340 of file DataWriterProtobuf.java.

◆ writeDispose() [1/6]

void org.opensplice.dds.pub.DataWriterProtobuf< PROTOBUF_TYPE, DDS_TYPE >.writeDispose ( PROTOBUF_TYPE instanceData ) throws TimeoutException

Definition at line 400 of file DataWriterProtobuf.java.

◆ writeDispose() [2/6]

void org.opensplice.dds.pub.DataWriterProtobuf< PROTOBUF_TYPE, DDS_TYPE >.writeDispose	(	PROTOBUF_TYPE	instanceData,
		Time	sourceTimestamp
	)		throws TimeoutException

Definition at line 407 of file DataWriterProtobuf.java.

◆ writeDispose() [3/6]

void org.opensplice.dds.pub.DataWriterProtobuf< PROTOBUF_TYPE, DDS_TYPE >.writeDispose	(	PROTOBUF_TYPE	instanceData,
		InstanceHandle	handle
	)		throws TimeoutException

Definition at line 414 of file DataWriterProtobuf.java.

◆ writeDispose() [4/6]

void org.opensplice.dds.pub.DataWriterProtobuf< PROTOBUF_TYPE, DDS_TYPE >.writeDispose	(	PROTOBUF_TYPE	instanceData,
		long	sourceTimestamp,
		TimeUnit	unit
	)		throws TimeoutException

Definition at line 421 of file DataWriterProtobuf.java.

◆ writeDispose() [5/6]

void org.opensplice.dds.pub.DataWriterProtobuf< PROTOBUF_TYPE, DDS_TYPE >.writeDispose	(	PROTOBUF_TYPE	instanceData,
		InstanceHandle	handle,
		Time	sourceTimestamp
	)		throws TimeoutException

Definition at line 429 of file DataWriterProtobuf.java.

◆ writeDispose() [6/6]

void org.opensplice.dds.pub.DataWriterProtobuf< PROTOBUF_TYPE, DDS_TYPE >.writeDispose	(	PROTOBUF_TYPE	instanceData,
		InstanceHandle	instanceHandle,
		long	sourceTimestamp,
		TimeUnit	unit
	)		throws TimeoutException

Definition at line 438 of file DataWriterProtobuf.java.

Member Data Documentation

◆ typeSupport

final TypeSupportProtobuf<PROTOBUF_TYPE, DDS_TYPE> org.opensplice.dds.pub.DataWriterProtobuf< PROTOBUF_TYPE, DDS_TYPE >.typeSupport