Inheritance diagram for org.opensplice.dds.pub.PublisherImpl:

Collaboration diagram for org.opensplice.dds.pub.PublisherImpl:

Public Member Functions
	PublisherImpl (OsplServiceEnvironment environment, DomainParticipantImpl parent, PublisherQos qos, PublisherListener listener, Collection< Class<? extends Status >> statuses)

void	beginCoherentChanges ()
	This operation requests that the application will begin a 'coherent set' of modifications using org.omg.dds.pub.DataWriter objects attached to the Publisher. More...

final void	close ()

abstract void	close ()
	Halt communication and dispose the resources held by this Entity. More...

void	closeContainedEntities ()
	This operation closes all the entities that were created by means of the "create" operations on the Publisher. More...

DataWriterQos	copyFromTopicQos (DataWriterQos dwQos, TopicQos tQos)
	This operation copies the policies in the org.omg.dds.topic.Topic QoS to the corresponding policies in the org.omg.dds.pub.DataWriter QoS (replacing values in the DataWriter QoS, if present). More...

void	destroyDataWriter (EntityImpl< DDS.DataWriter, ?, ?, ?, ?> dataWriter)

final void	enable ()

void	enable ()
	This operation enables the Entity. More...

void	endCoherentChanges ()
	This operation terminates the 'coherent set' initiated by the matching call to beginCoherentChanges(). More...

DataWriterQos	getDefaultDataWriterQos ()
	This operation retrieves the default value of the DataWriter QoS, that is, the QoS policies which will be used for newly created org.omg.dds.pub.DataWriter entities in the case where the QoS policies are defaulted in the createDataWriter(Topic) operation. More...

ServiceEnvironment	getEnvironment ()

final InstanceHandle	getInstanceHandle ()

InstanceHandle	getInstanceHandle ()

LISTENER	getListener ()
	This operation allows access to the existing Listener attached to the Entity. More...

final LISTENER	getListener ()

OLD	getOld ()

OLDPARENT	getOldParent ()

org.omg.dds.domain.DomainParticipant	getParent ()

String	getProperty (String key)
	Provides access to the current value for a given property. More...

PublisherQos	getQos ()

final Set< Class<? extends Status > >	getStatusChanges ()

Set< Class<? extends Status > >	getStatusChanges ()
	This operation retrieves the list of communication statuses in the Entity that are 'triggered. More...

StatusCondition< Publisher >	getStatusCondition ()

void	resumePublications ()
	This operation indicates to the Service that the application has completed the multiple changes initiated by the previous suspendPublications(). More...

final void	retain ()

void	retain ()
	Indicates that references to this object may go out of scope but that the application expects to look it up again later. More...

void	setDefaultDataWriterQos (DataWriterQos qos)
	This operation sets a default value of the DataWriter QoS policies, which will be used for newly created org.omg.dds.pub.DataWriter entities in the case where the QoS policies are defaulted in the createDataWriter(Topic) operation. More...

void	setListener (LISTENER listener)
	This operation installs a Listener on the Entity. More...

void	setListener (LISTENER listener, Collection< Class<? extends Status >> statuses)
	This operation installs a Listener on the Entity. More...

void	setListener (LISTENER listener, Class<? extends Status >... statuses)
	This operation installs a Listener on the Entity. More...

void	setListener (PublisherListener listener)

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

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

void	setProperty (String key, String value)
	This method sets the property specified by the key to the value given by the value. More...

void	setQos (PublisherQos qos)

void	setQos (QOS qos)
	This operation is used to set the QoS policies of the Entity. More...

void	suspendPublications ()
	This operation indicates to the Service that the application is about to make multiple modifications using DataWriter objects belonging to the Publisher. More...

void	waitForAcknowledgments (Duration maxWait) throws TimeoutException
	This operation blocks the calling thread until either all data written by the reliable org.omg.dds.pub.DataWriter entities is acknowledged by all matched reliable org.omg.dds.sub.DataReader entities, or else the duration specified elapses, whichever happens first. More...

void	waitForAcknowledgments (long maxWait, TimeUnit unit) throws TimeoutException
	This operation blocks the calling thread until either all data written by the reliable org.omg.dds.pub.DataWriter entities is acknowledged by all matched reliable org.omg.dds.sub.DataReader entities, or else the duration specified elapses, whichever happens first. More...

Static Public Member Functions
static boolean	printReferences ()

Protected Member Functions
void	destroy ()

void	setOld (OLD old)

Protected Attributes
final transient OsplServiceEnvironment	environment

LISTENERIMPL	listener

PARENT	parent

Detailed Description

Definition at line 55 of file PublisherImpl.java.

Constructor & Destructor Documentation

◆ PublisherImpl()

org.opensplice.dds.pub.PublisherImpl.PublisherImpl	(	OsplServiceEnvironment	environment,
		DomainParticipantImpl	parent,
		PublisherQos	qos,
		PublisherListener	listener,
		Collection< Class<? extends Status >>	statuses
	)

Definition at line 61 of file PublisherImpl.java.

Member Function Documentation

◆ beginCoherentChanges()

void org.opensplice.dds.pub.PublisherImpl.beginCoherentChanges ( )

This operation requests that the application will begin a 'coherent set' of modifications using org.omg.dds.pub.DataWriter objects attached to the Publisher.

The 'coherent set' will be completed by a matching call to endCoherentChanges().

A 'coherent set' is a set of modifications that must be propagated in such a way that they are interpreted at the receivers' side as a consistent set of modifications; that is, the receiver will only be able to access the data after all the modifications in the set are available at the receiver end.

A connectivity change may occur in the middle of a set of coherent changes; for example, the set of partitions used by the Publisher or one of its Subscribers may change, a late-joining DataReader may appear on the network, or a communication failure may occur. In the event that such a change prevents an entity from receiving the entire set of coherent changes, that entity must behave as if it had received none of the set.

These calls can be nested. In that case, the coherent set terminates only with the last call to endCoherentChanges().

The support for 'coherent changes' enables a publishing application to change the value of several data instances that could belong to the same or different topics and have those changes be seen 'atomically' by the readers. This is useful in cases where the values are interrelated. For example, if there are two data instances representing the 'altitude' and 'velocity vector' of the same aircraft and both are changed, it may be useful to communicate those values in a way the reader can see both together; otherwise, it may e.g., erroneously interpret that the aircraft is on a collision course.

Exceptions

org.omg.dds.core.PreconditionNotMetException	the Publisher is not able to handle coherent changes because its PresentationQos has not set coherentAccess to TRUE.
org.omg.dds.core.DDSException	An internal error has occurred.
org.omg.dds.core.AlreadyClosedException	The corresponding Publisher has been closed.

See also: endCoherentChanges()

Implements org.omg.dds.pub.Publisher.

Definition at line 300 of file PublisherImpl.java.

◆ close() [1/2]

final void org.opensplice.dds.core.EntityImpl< OLD extends DDS.Entity, OLDPARENT, QOS extends EntityQos<?, LISTENER extends EventListener, LISTENERIMPL extends Listener< LISTENER >.close ( )

inherited

Definition at line 139 of file EntityImpl.java.

◆ close() [2/2]

abstract void org.omg.dds.core.Entity< LISTENER extends EventListener, QOS extends EntityQos<?>.close ( )

abstractinherited

Halt communication and dispose the resources held by this Entity.

Closing an Entity implicitly closes all of its contained objects, if any. For example, closing a Publisher also closes all of its contained DataWriters.

An Entity cannot be closed if it has any unclosed dependent objects, not including contained objects. These include the following:

A org.omg.dds.topic.Topic cannot be closed if it is still in use by any org.omg.dds.topic.ContentFilteredTopics or org.omg.dds.topic.MultiTopics.
A Topic cannot be closed if any org.omg.dds.pub.DataWriters or org.omg.dds.sub.DataReader is still using it.
A DataReader cannot be closed if it has any outstanding loans as a result of a call to org.omg.dds.sub.DataReader#read(), org.omg.dds.sub.DataReader#take(), or one of the variants thereof.

The deletion of a org.omg.dds.pub.DataWriter will automatically unregister all instances. Depending on the settings of the org.omg.dds.core.policy.WriterDataLifecycle, the deletion of the DataWriter may also dispose all instances.

Exceptions

PreconditionNotMetException if close is called on an Entity with unclosed dependent object(s), not including contained objects.

See also: org.omg.dds.topic.TopicDescription::close()

◆ closeContainedEntities()

void org.opensplice.dds.pub.PublisherImpl.closeContainedEntities ( )

This operation closes all the entities that were created by means of the "create" operations on the Publisher.

That is, it closes all contained org.omg.dds.pub.DataWriter objects.

Exceptions

org.omg.dds.core.PreconditionNotMetException if the any of the contained entities is in a state where it cannot be deleted.

Implements org.omg.dds.pub.Publisher.

Definition at line 271 of file PublisherImpl.java.

◆ copyFromTopicQos()

DataWriterQos org.opensplice.dds.pub.PublisherImpl.copyFromTopicQos	(	DataWriterQos	dwQos,
		TopicQos	tQos
	)

This operation copies the policies in the org.omg.dds.topic.Topic QoS to the corresponding policies in the org.omg.dds.pub.DataWriter QoS (replacing values in the DataWriter QoS, if present).

This is a "convenience" operation most useful in combination with the operations getDefaultDataWriterQos() and org.omg.dds.topic.Topic#getQos(). The operation can be used to merge the DataWriter default QoS policies with the corresponding ones on the Topic. The resulting QoS can then be used to create a new DataWriter or set its QoS.

This operation does not check the resulting DatWriter QoS for consistency. This is because the 'merged' QoS may not be the final one, as the application can still modify some policies prior to applying the policies to the DataWriter.

Parameters

dwQos	The QoS whose policies are to be overridden. This object is not modified.
tQos	The QoS from which the policies are to be taken. This object is not modified.

Returns: A copy of dwQos with the applicable policies from tQos applied to it.

Exceptions

org.omg.dds.core.OutOfResourcesException	The Data Distribution Service ran out of resources to complete this operation.
org.omg.dds.core.DDSException	An internal error has occurred.
org.omg.dds.core.AlreadyClosedException	The corresponding Publisher has been closed.

Implements org.omg.dds.pub.Publisher.

Definition at line 358 of file PublisherImpl.java.

◆ destroy()

void org.opensplice.dds.pub.PublisherImpl.destroy ( )

protected

Definition at line 397 of file PublisherImpl.java.

◆ destroyDataWriter()

void org.opensplice.dds.pub.PublisherImpl.destroyDataWriter ( EntityImpl< DDS.DataWriter, ?, ?, ?, ?> dataWriter )

Definition at line 402 of file PublisherImpl.java.

◆ enable() [1/2]

final void org.opensplice.dds.core.EntityImpl< OLD extends DDS.Entity, OLDPARENT, QOS extends EntityQos<?, LISTENER extends EventListener, LISTENERIMPL extends Listener< LISTENER >.enable ( )

inherited

Definition at line 153 of file EntityImpl.java.

◆ enable() [2/2]

void org.omg.dds.core.Entity< LISTENER extends EventListener, QOS extends EntityQos<?>.enable ( )

inherited

This operation enables the Entity.

Entity objects can be created either enabled or disabled. This is controlled by the value of the org.omg.dds.core.policy.EntityFactory on the corresponding factory for the Entity.

The default setting of org.omg.dds.core.policy.EntityFactory is such that, by default, it is not necessary to explicitly call enable on newly created entities.

The enable operation is idempotent. Calling enable on an already enabled Entity has no effect.

If an Entity has not yet been enabled, the following kinds of operations may be invoked on it:

Operations to set or get an Entity's QoS policies (including default QoS policies) and listener
getStatusCondition()
'factory' operations and close()
getStatusChanges() and other get status operations (although the status of a disabled entity never changes)
'lookup' operations

Other operations may explicitly state that they may be called on disabled entities; those that do not will fail with org.omg.dds.core.NotEnabledException.

It is legal to delete an Entity that has not been enabled by calling close(). Entities created from a factory that is disabled are created disabled regardless of the setting of org.omg.dds.core.policy.EntityFactory.

Calling enable on an Entity whose factory is not enabled will fail with org.omg.dds.core.PreconditionNotMetException.

If org.omg.dds.core.policy.EntityFactory#isAutoEnableCreatedEntities() is true, the enable operation on the factory will automatically enable all entities created from the factory.

The Listeners associated with an entity are not called until the entity is enabled. org.omg.dds.core.Conditions associated with an entity that is not enabled are "inactive," that is, have a triggerValue == false.

In addition to the general description, the enable operation on a org.omg.dds.sub.Subscriber has special meaning in specific usecases. This applies only to Subscribers with PresentationQoS coherent-access set to true with access-scope set to group.

In this case the subscriber is always created in a disabled state, regardless of the factory's auto-enable created entities setting. While the subscriber remains disabled, DataReaders can be created that will participate in coherent transactions of the subscriber.

See org.omg.dds.sub.Subscriber#beginAccess() and org.omg.dds.sub.Subscriber#endAccess() for more information.

All DataReaders will also be created in a disabled state. Coherency with group access-scope requires data to be delivered as a transaction, atomically, to all eligible readers. Therefore data should not be delivered to any single DataReader immediately after it's created, as usual, but only after the application has finished creating all DataReaders for a given Subscriber. At this point, the application should enable the Subscriber which in turn enables all its DataReaders.

Note that for a DataWriter which has a corresponding Publisher with a PresentationQoS with coherent-access set to true and access-scope set to topic or group that the HistoryQoS of the DataWriter should be set to KEEP_ALL otherwise the enable operation will fail. See org.omg.dds.pub.Publisher#createDataWriter(Topic, DataWriterQos, DataWriterListener, Collection)

◆ endCoherentChanges()

void org.opensplice.dds.pub.PublisherImpl.endCoherentChanges ( )

This operation terminates the 'coherent set' initiated by the matching call to beginCoherentChanges().

Exceptions

org.omg.dds.core.PreconditionNotMetException	if there is no matching call to beginCoherentChanges().
org.omg.dds.core.DDSException	An internal error has occurred.
org.omg.dds.core.AlreadyClosedException	The corresponding Publisher has been closed.

See also: beginCoherentChanges()

Implements org.omg.dds.pub.Publisher.

Definition at line 307 of file PublisherImpl.java.

◆ getDefaultDataWriterQos()

DataWriterQos org.opensplice.dds.pub.PublisherImpl.getDefaultDataWriterQos ( )

This operation retrieves the default value of the DataWriter QoS, that is, the QoS policies which will be used for newly created org.omg.dds.pub.DataWriter entities in the case where the QoS policies are defaulted in the createDataWriter(Topic) operation.

The values retrieved will match the set of values specified on the last successful call to setDefaultDataWriterQos(DataWriterQos), or else, if the call was never made, the default values identified by the DDS specification.

Returns: A DataWriterQos

Exceptions

org.omg.dds.core.DDSException	An internal error has occurred.
org.omg.dds.core.AlreadyClosedException	The corresponding Publisher has been closed.
org.omg.dds.core.OutOfResourcesException	The Data Distribution Service ran out of resources to complete this operation.

See also: setDefaultDataWriterQos(DataWriterQos)

Implements org.omg.dds.pub.Publisher.

Definition at line 331 of file PublisherImpl.java.

◆ getEnvironment()

ServiceEnvironment org.opensplice.dds.core.EntityImpl< OLD extends DDS.Entity, OLDPARENT, QOS extends EntityQos<?, LISTENER extends EventListener, LISTENERIMPL extends Listener< LISTENER >.getEnvironment ( )

inherited

Definition at line 121 of file EntityImpl.java.

◆ getInstanceHandle() [1/2]

final InstanceHandle org.opensplice.dds.core.EntityImpl< OLD extends DDS.Entity, OLDPARENT, QOS extends EntityQos<?, LISTENER extends EventListener, LISTENERIMPL extends Listener< LISTENER >.getInstanceHandle ( )

inherited

Definition at line 166 of file EntityImpl.java.

◆ getInstanceHandle() [2/2]

InstanceHandle org.omg.dds.core.Entity< LISTENER extends EventListener, QOS extends EntityQos<?>.getInstanceHandle ( )

inherited

Returns: the org.omg.dds.core.InstanceHandle that represents the Entity.

◆ getListener() [1/2]

LISTENER org.omg.dds.core.Entity< LISTENER extends EventListener, QOS extends EntityQos<?>.getListener ( )

inherited

This operation allows access to the existing Listener attached to the Entity.

Returns: The attached listener if set, or null otherwise.

See also: #setListener(EventListener); #setListener(EventListener, Collection)

◆ getListener() [2/2]

final LISTENER org.opensplice.dds.core.EntityImpl< OLD extends DDS.Entity, OLDPARENT, QOS extends EntityQos<?, LISTENER extends EventListener, LISTENERIMPL extends Listener< LISTENER >.getListener ( )

inherited

Definition at line 174 of file EntityImpl.java.

◆ getOld()

OLD org.opensplice.dds.core.EntityImpl< OLD extends DDS.Entity, OLDPARENT, QOS extends EntityQos<?, LISTENER extends EventListener, LISTENERIMPL extends Listener< LISTENER >.getOld ( )

inherited

Definition at line 102 of file EntityImpl.java.

◆ getOldParent()

OLDPARENT org.opensplice.dds.core.EntityImpl< OLD extends DDS.Entity, OLDPARENT, QOS extends EntityQos<?, LISTENER extends EventListener, LISTENERIMPL extends Listener< LISTENER >.getOldParent ( )

inherited

Definition at line 116 of file EntityImpl.java.

◆ getParent()

org.omg.dds.domain.DomainParticipant org.opensplice.dds.pub.PublisherImpl.getParent ( )

Returns: the factory object that created this entity.

Implements org.omg.dds.pub.Publisher.

Definition at line 392 of file PublisherImpl.java.

◆ getProperty()

String org.opensplice.dds.core.EntityImpl< OLD extends DDS.Entity, OLDPARENT, QOS extends EntityQos<?, LISTENER extends EventListener, LISTENERIMPL extends Listener< LISTENER >.getProperty ( String key )

inherited

Provides access to the current value for a given property.

Parameters

key	The key of the property to obtain the value for.

Returns: The value for the specified property, or null if it has not been set.

Definition at line 189 of file EntityImpl.java.

◆ getQos()

PublisherQos org.opensplice.dds.pub.PublisherImpl.getQos ( )

Definition at line 138 of file PublisherImpl.java.

◆ getStatusChanges() [1/2]

final Set<Class<? extends Status> > org.opensplice.dds.core.EntityImpl< OLD extends DDS.Entity, OLDPARENT, QOS extends EntityQos<?, LISTENER extends EventListener, LISTENERIMPL extends Listener< LISTENER >.getStatusChanges ( )

inherited

Definition at line 160 of file EntityImpl.java.

◆ getStatusChanges() [2/2]

Set<Class<? extends Status> > org.omg.dds.core.Entity< LISTENER extends EventListener, QOS extends EntityQos<?>.getStatusChanges ( )

inherited

This operation retrieves the list of communication statuses in the Entity that are 'triggered.

' That is, the list of statuses whose value has changed since the last time the application read the status.

When the entity is first created or if the entity is not enabled, all communication statuses are in the "untriggered" state so the list returned will be empty.

The list of statuses returned refers to the statuses that are triggered on the Entity itself and does not include statuses that apply to contained entities.

Returns: a new Set containing the triggered statuses.

◆ getStatusCondition()

StatusCondition<Publisher> org.opensplice.dds.pub.PublisherImpl.getStatusCondition ( )

Implements org.omg.dds.pub.Publisher.

Definition at line 381 of file PublisherImpl.java.

◆ printReferences()

static boolean org.opensplice.dds.core.EntityImpl< OLD extends DDS.Entity, OLDPARENT, QOS extends EntityQos<?, LISTENER extends EventListener, LISTENERIMPL extends Listener< LISTENER >.printReferences ( )

staticinherited

Definition at line 66 of file EntityImpl.java.

◆ resumePublications()

void org.opensplice.dds.pub.PublisherImpl.resumePublications ( )

This operation indicates to the Service that the application has completed the multiple changes initiated by the previous suspendPublications().

This is a hint to the Service that can be used by a Service implementation to e.g., batch all the modifications made since the suspendPublications().

Exceptions

org.omg.dds.core.PreconditionNotMetException	if the call to this method does not match a previous call to suspendPublications().
org.omg.dds.core.OutOfResourcesException	if it is not possible for sufficient resources to be made available within the configured max blocking time.
org.omg.dds.core.DDSException	An internal error has occurred.
org.omg.dds.core.AlreadyClosedException	The corresponding Publisher has been closed.

See also: suspendPublications()

Implements org.omg.dds.pub.Publisher.

Definition at line 293 of file PublisherImpl.java.

◆ retain() [1/2]

final void org.opensplice.dds.core.EntityImpl< OLD extends DDS.Entity, OLDPARENT, QOS extends EntityQos<?, LISTENER extends EventListener, LISTENERIMPL extends Listener< LISTENER >.retain ( )

inherited

Definition at line 126 of file EntityImpl.java.

◆ retain() [2/2]

void org.omg.dds.core.Entity< LISTENER extends EventListener, QOS extends EntityQos<?>.retain ( )

inherited

Indicates that references to this object may go out of scope but that the application expects to look it up again later.

Therefore, the Service must consider this object to be still in use and may not close it automatically.

◆ setDefaultDataWriterQos()

void org.opensplice.dds.pub.PublisherImpl.setDefaultDataWriterQos ( DataWriterQos qos )

This operation sets a default value of the DataWriter QoS policies, which will be used for newly created org.omg.dds.pub.DataWriter entities in the case where the QoS policies are defaulted in the createDataWriter(Topic) operation.

Parameters

qos	The new default DataWriterQos

Exceptions

org.omg.dds.core.InconsistentPolicyException	if the resulting policies are not self consistent; if they are not, the operation will have no effect.
org.omg.dds.core.DDSException	An internal error has occurred.
org.omg.dds.core.AlreadyClosedException	The corresponding Publisher has been closed.
org.omg.dds.core.OutOfResourcesException	The Data Distribution Service ran out of resources to complete this operation.

See also: getDefaultDataWriterQos()

Implements org.omg.dds.pub.Publisher.

Definition at line 341 of file PublisherImpl.java.

◆ setListener() [1/6]

void org.omg.dds.core.Entity< LISTENER extends EventListener, QOS extends EntityQos<?>.setListener ( LISTENER listener )

inherited

This operation installs a Listener on the Entity.

The listener will only be invoked on all communication statuses pertaining to the concrete type of this entity.

It is permitted to use null as the value of the listener. The null listener behaves as a Listener whose operations perform no action.

Only one listener can be attached to each Entity. If a listener was already set, the operation will replace it with the new one. Consequently if the value null is passed for the listener parameter, any existing listener will be removed.

Parameters

listener the listener to attach.

See also: getListener(); #setListener(EventListener, Collection)

◆ setListener() [2/6]

void org.omg.dds.core.Entity< LISTENER extends EventListener, QOS extends EntityQos<?>.setListener	(	LISTENER	listener,
		Collection< Class<? extends Status >>	statuses
	)

inherited

This operation installs a Listener on the Entity.

The listener will only be invoked on the changes of communication status indicated by the specified mask.

It is permitted to use null as the value of the listener. The null listener behaves as a Listener whose operations perform no action.

Only one listener can be attached to each Entity. If a listener was already set, the operation will replace it with the new one. Consequently if the value null is passed for the listener parameter, any existing listener will be removed.

See also: getListener(); #setListener(EventListener)

◆ setListener() [3/6]

void org.omg.dds.core.Entity< LISTENER extends EventListener, QOS extends EntityQos<?>.setListener	(	LISTENER	listener,
		Class<? extends Status >...	statuses
	)

inherited

This operation installs a Listener on the Entity.

The listener will only be invoked on the changes of communication status indicated by the specified mask.

It is permitted to use null as the value of the listener. The null listener behaves as a Listener whose operations perform no action.

Only one listener can be attached to each Entity. If a listener was already set, the operation will replace it with the new one. Consequently if the value null is passed for the listener parameter, any existing listener will be removed.

See also: getListener(); #setListener(EventListener)

◆ setListener() [4/6]

void org.opensplice.dds.pub.PublisherImpl.setListener ( PublisherListener listener )

Definition at line 119 of file PublisherImpl.java.

◆ setListener() [5/6]

void org.opensplice.dds.pub.PublisherImpl.setListener	(	PublisherListener	listener,
		Collection< Class<? extends Status >>	statuses
	)

Definition at line 124 of file PublisherImpl.java.

◆ setListener() [6/6]

void org.opensplice.dds.pub.PublisherImpl.setListener	(	PublisherListener	listener,
		Class<? extends Status >...	statuses
	)

Definition at line 131 of file PublisherImpl.java.

◆ setOld()

void org.opensplice.dds.core.EntityImpl< OLD extends DDS.Entity, OLDPARENT, QOS extends EntityQos<?, LISTENER extends EventListener, LISTENERIMPL extends Listener< LISTENER >.setOld ( OLD old )

protectedinherited

Definition at line 112 of file EntityImpl.java.

◆ setProperty()

void org.opensplice.dds.core.EntityImpl< OLD extends DDS.Entity, OLDPARENT, QOS extends EntityQos<?, LISTENER extends EventListener, LISTENERIMPL extends Listener< LISTENER >.setProperty	(	String	key,
		String	value
	)

inherited

This method sets the property specified by the key to the value given by the value.

Currently, this method is only supported on a org.omg.dds.sub.DataReader and that supports the following properties:

parallelReadThreadCount - By default, the demarshalling of data into Java objects by a single read or take operation happens only in the calling thread. The parallelReadThreadCount property can be used to control the number of parallel threads to be used for this demarshalling. When reading multiple of samples takes a significant amount of time, increasing the number of threads on a multi-core machine can provide a significant benefit. The value is interpreted as the number of parallel threads to use (i.e., the value is a string representing a natural integer in decimal notation, so for example the string '4' will cause 4 threads to be used). The value '0' is allowed and selects the default behavior. If the call was successful, successive read/take operations on that org.omg.dds.sub.DataReader will use the specified number of threads for the demarshalling step of the respective operations until the value of this property is changed again.

CDRCopy - The default demarshalling technique constructs the Java object directly from the shared memory, but for some types, it is more efficient to marshal the value in shared memory into CDR representation, and then demarshal the CDR representation from Java. The value is interpreted as a boolean (i.e., value must be either 'true' or 'false'), with 'false' selecting the default technique and 'true' selecting the alternative, CDR-based technique. The CDR-based technique requires JacORB to be configured as the default ORB in the JVM, and furthermore requires that the JacORB IDL preprocessor has been used to generate a Helper class for the topic type of this org.omg.dds.sub.DataReader and that this helper class can be found in the class path. The ORB initialization and Helper class lookup is all done at run-time to avoid introducing a compile-time dependency, but this means that attempting to set the CDRCopy property to 'true' can fail in complicated ways because of these dependencies. When set to true, the CDR-based technique will be used for successive read/take operations on the data reader, until the property is set to false again.

Parameters

key	The key of the property
value	The value to assign to the property.

Definition at line 182 of file EntityImpl.java.

◆ setQos() [1/2]

void org.opensplice.dds.pub.PublisherImpl.setQos ( PublisherQos qos )

Definition at line 148 of file PublisherImpl.java.

◆ setQos() [2/2]

void org.omg.dds.core.Entity< LISTENER extends EventListener, QOS extends EntityQos<?>.setQos ( QOS qos )

inherited

This operation is used to set the QoS policies of the Entity.

This operation must be provided by each of the derived Entity classes (org.omg.dds.domain.DomainParticipant, org.omg.dds.topic.Topic, org.omg.dds.pub.Publisher, org.omg.dds.pub.DataWriter, org.omg.dds.sub.Subscriber, org.omg.dds.sub.DataReader) so that the policies that are meaningful to each Entity can be set.

The set of policies specified as the parameter are applied on top of the existing QoS, replacing the values of any policies previously set.

Certain policies are "immutable"; they can only be set at Entity creation time, or before the entity is made enabled. If setQos is invoked after the Entity is enabled and it attempts to change the value of an "immutable" policy, the operation will fail with org.omg.dds.core.ImmutablePolicyException.

Certain values of QoS policies can be incompatible with the settings of the other policies. The setQos operation will also fail if it specifies a set of values that once combined with the existing values would result in an inconsistent set of policies. In this case, it shall fail with org.omg.dds.core.InconsistentPolicyException.

If the application supplies a non-default value for a QoS policy that is not supported by the implementation of the service, the setQos operation will fail with UnsupportedOperationException.

The existing set of policies are only changed if the setQos operation succeeds. In all other cases, none of the policies is modified.

Exceptions

ImmutablePolicyException	if an immutable policy changes its value.
InconsistentPolicyException	if a combination of policies is inconsistent with one another.
UnsupportedOperationException	if an unsupported policy has a non-default value.

See also: getQos()

◆ suspendPublications()

void org.opensplice.dds.pub.PublisherImpl.suspendPublications ( )

This operation indicates to the Service that the application is about to make multiple modifications using DataWriter objects belonging to the Publisher.

It is a hint to the Service so it can optimize its performance by e.g., holding the dissemination of the modifications and then batching them.

It is not required that the Service use this hint in any way.

The use of this operation must be matched by a corresponding call to resumePublications() indicating that the set of modifications has completed. If the Publisher is deleted before resumePublications() is called, any suspended updates yet to be published will be discarded.

Exceptions

org.omg.dds.core.OutOfResourcesException	if it is not possible for sufficient resources to be made available within the configured max blocking time.
org.omg.dds.core.DDSException	An internal error has occurred.
org.omg.dds.core.AlreadyClosedException	The corresponding Publisher has been closed.

See also: resumePublications()

Implements org.omg.dds.pub.Publisher.

Definition at line 285 of file PublisherImpl.java.

◆ waitForAcknowledgments() [1/2]

void org.opensplice.dds.pub.PublisherImpl.waitForAcknowledgments ( Duration maxWait ) throws TimeoutException

This operation blocks the calling thread until either all data written by the reliable org.omg.dds.pub.DataWriter entities is acknowledged by all matched reliable org.omg.dds.sub.DataReader entities, or else the duration specified elapses, whichever happens first.

Be aware that in case the operation succeeds, the data has only been acknowledged by the local infrastructure: it does not mean all remote subscriptions have already received the data. However, delivering the data to remote nodes is then the sole responsibility of the networking service: even when the publishing application would terminate, all data that has not yet been received may be considered 'on-route' and will therefore eventually arrive (unless the networking service itself will crash). In contrast, if a DataWriter would still have data in its local history buffer when it terminates, this data is considered 'lost'.

Parameters

maxWait The maximum duration to block for the waitForAcknowledgments, after which the application thread is unblocked. The operation Duration.infiniteDuration(env) can be used when the maximum waiting time does not need to be bounded.

Exceptions

TimeoutException	if maxWait elapsed before all the data was acknowledged.
org.omg.dds.core.DDSException	An internal error has occurred.
org.omg.dds.core.OutOfResourcesException	The Data Distribution Service ran out of resources to complete this operation.
org.omg.dds.core.AlreadyClosedException	The corresponding Publisher has been closed.

Implements org.omg.dds.pub.Publisher.

Definition at line 314 of file PublisherImpl.java.

◆ waitForAcknowledgments() [2/2]

void org.opensplice.dds.pub.PublisherImpl.waitForAcknowledgments	(	long	maxWait,
		TimeUnit	unit
	)		throws TimeoutException

This operation blocks the calling thread until either all data written by the reliable org.omg.dds.pub.DataWriter entities is acknowledged by all matched reliable org.omg.dds.sub.DataReader entities, or else the duration specified elapses, whichever happens first.

Be aware that in case the operation succeeds, the data has only been acknowledged by the local infrastructure: it does not mean all remote subscriptions have already received the data. However, delivering the data to remote nodes is then the sole responsibility of the networking service: even when the publishing application would terminate, all data that has not yet been received may be considered 'on-route' and will therefore eventually arrive (unless the networking service itself will crash). In contrast, if a DataWriter would still have data in its local history buffer when it terminates, this data is considered 'lost'.

Parameters

maxWait	The maximum duration to block for the waitForAcknowledgments, after which the application thread is unblocked defined in a long.
unit	The TimeUnit which the maxWait describes (i.e. TimeUnit.SECONDS or TimeUnit.MILLISECONDS)

Exceptions

TimeoutException	if maxWait elapsed before all the data was acknowledged.
org.omg.dds.core.DDSException	An internal error has occurred.
org.omg.dds.core.OutOfResourcesException	The Data Distribution Service ran out of resources to complete this operation.
org.omg.dds.core.AlreadyClosedException	The corresponding Publisher has been closed.

Implements org.omg.dds.pub.Publisher.

Definition at line 324 of file PublisherImpl.java.

Member Data Documentation

◆ environment

final transient OsplServiceEnvironment org.opensplice.dds.core.EntityImpl< OLD extends DDS.Entity, OLDPARENT, QOS extends EntityQos<?, LISTENER extends EventListener, LISTENERIMPL extends Listener< LISTENER >.environment

protectedinherited

Definition at line 36 of file EntityImpl.java.

◆ listener

LISTENERIMPL org.opensplice.dds.core.EntityImpl< OLD extends DDS.Entity, OLDPARENT, QOS extends EntityQos<?, LISTENER extends EventListener, LISTENERIMPL extends Listener< LISTENER >.listener

protectedinherited

Definition at line 39 of file EntityImpl.java.

◆ parent

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 >.parent

protectedinherited

Definition at line 40 of file DomainEntityImpl.java.

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

java5/common/java/code/org/opensplice/dds/pub/PublisherImpl.java

Public Member Functions

Static Public Member Functions

Protected Member Functions

Protected Attributes

Detailed Description

Constructor & Destructor Documentation

◆ PublisherImpl()

Member Function Documentation

◆ beginCoherentChanges()

◆ close() [1/2]

◆ close() [2/2]

◆ closeContainedEntities()

◆ copyFromTopicQos()

◆ destroy()

◆ destroyDataWriter()

◆ enable() [1/2]

◆ enable() [2/2]

◆ endCoherentChanges()

◆ getDefaultDataWriterQos()

◆ getEnvironment()

◆ getInstanceHandle() [1/2]

◆ getInstanceHandle() [2/2]

◆ getListener() [1/2]

◆ getListener() [2/2]

◆ getOld()

◆ getOldParent()

◆ getParent()

◆ getProperty()

◆ getQos()

◆ getStatusChanges() [1/2]

◆ getStatusChanges() [2/2]

◆ getStatusCondition()

◆ printReferences()

◆ resumePublications()

◆ retain() [1/2]

◆ retain() [2/2]

◆ setDefaultDataWriterQos()

◆ setListener() [1/6]

◆ setListener() [2/6]

◆ setListener() [3/6]

◆ setListener() [4/6]

◆ setListener() [5/6]

◆ setListener() [6/6]

◆ setOld()

◆ setProperty()

◆ setQos() [1/2]

◆ setQos() [2/2]

◆ suspendPublications()

◆ waitForAcknowledgments() [1/2]

◆ waitForAcknowledgments() [2/2]

Member Data Documentation

◆ environment

◆ listener

◆ parent