Inheritance diagram for org.opensplice.dds.sub.SubscriberImpl:

Collaboration diagram for org.opensplice.dds.sub.SubscriberImpl:

Public Member Functions
	SubscriberImpl (OsplServiceEnvironment environment, DomainParticipantImpl parent, SubscriberQos qos, SubscriberListener listener, Collection< Class<? extends Status >> statuses)

	SubscriberImpl (OsplServiceEnvironment environment, DomainParticipantImpl parent, DDS.Subscriber oldSubscriber)

void	beginAccess ()
	This operation indicates that the application is about to access the data samples in any of the org.omg.dds.sub.DataReader objects attached to the Subscriber. 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 Subscriber. More...

DataReaderQos	copyFromTopicQos (DataReaderQos drQos, TopicQos tQos)
	This operation copies the policies in the org.omg.dds.topic.TopicQos to the corresponding policies in the org.omg.dds.sub.DataReaderQos (replacing values in the latter, if present). More...

DataState	createDataState ()
	Create and return a new modifiable DataState object. More...

void	destroyDataReader (AbstractDataReader<?> dataReader)

final void	enable ()

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

void	endAccess ()
	Indicates that the application has finished accessing the data samples in org.omg.dds.sub.DataReader objects managed by the Subscriber. More...

Collection< DataReader<?> >	getDataReaders (Collection< DataReader<?>> readers)

Collection< DataReader<?> >	getDataReaders ()
	This operation is equivalent to calling getDataReaders(DataState) with any sample state ( Subscriber.DataState#withAnySampleState()), any view state ( Subscriber.DataState#withAnyViewState()), and any instance state (Subscriber.DataState#withAnyInstanceState()). More...

Collection< DataReader<?> >	getDataReaders (DataState dataState)
	This operation allows the application to access the org.omg.dds.sub.DataReader objects that contain samples with the specified sample states, view states, and instance states. More...

DataReaderQos	getDefaultDataReaderQos ()
	This operation retrieves the default value of the DataReader QoS, that is, the QoS policies which will be used for newly created org.omg.dds.sub.DataReader entities in the case where the QoS policies are defaulted in the createDataReader(TopicDescription) 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...

SubscriberQos	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< Subscriber >	getStatusCondition ()

boolean	isBuiltin ()

void	notifyDataReaders ()
	This operation invokes the operation org.omg.dds.sub.DataReaderListener#onDataAvailable(org.omg.dds.core.event.DataAvailableEvent) on the DataReaderListener objects attached to contained DataReader entities with a org.omg.dds.core.event.DataAvailableEvent that is considered changed. 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	setDefaultDataReaderQos (DataReaderQos qos)
	This operation sets a default value of the DataReader QoS policies, which will be used for newly created org.omg.dds.sub.DataReader entities in the case where the QoS policies are defaulted in the createDataReader(TopicDescription) 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 (SubscriberListener listener)

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

void	setListener (SubscriberListener 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 (QOS qos)
	This operation is used to set the QoS policies of the Entity. More...

void	setQos (SubscriberQos qos)

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 54 of file SubscriberImpl.java.

Constructor & Destructor Documentation

◆ SubscriberImpl() [1/2]

org.opensplice.dds.sub.SubscriberImpl.SubscriberImpl	(	OsplServiceEnvironment	environment,
		DomainParticipantImpl	parent,
		SubscriberQos	qos,
		SubscriberListener	listener,
		Collection< Class<? extends Status >>	statuses
	)

Definition at line 61 of file SubscriberImpl.java.

◆ SubscriberImpl() [2/2]

org.opensplice.dds.sub.SubscriberImpl.SubscriberImpl	(	OsplServiceEnvironment	environment,
		DomainParticipantImpl	parent,
		DDS.Subscriber	oldSubscriber
	)

Definition at line 102 of file SubscriberImpl.java.

Member Function Documentation

◆ beginAccess()

void org.opensplice.dds.sub.SubscriberImpl.beginAccess ( )

This operation indicates that the application is about to access the data samples in any of the org.omg.dds.sub.DataReader objects attached to the Subscriber.

The application is required to use this operation only if the org.omg.dds.core.policy.Presentation of the Subscriber has org.omg.dds.core.policy.Presentation#getAccessScope() equal to org.omg.dds.core.policy.Presentation.AccessScopeKind#GROUP.

In the aforementioned case, the operation must be called prior to calling any of the sample-accessing operations, namely: getDataReaders(), org.omg.dds.sub.DataReader#read(), org.omg.dds.sub.DataReader#take(), or their overloads. Otherwise the sample-accessing operations will fail with org.omg.dds.core.PreconditionNotMetException. Once the application has finished accessing the data samples it must call endAccess().

It is not required for the application to call beginAccess()/ endAccess() if the org.omg.dds.core.policy.Presentation has the access scope set to something other than 'GROUP'. Calling these methods in this case is not considered an error and has no effect.

The calls to beginAccess()/endAccess() may be nested. In that case, the application must call endAccess() as many times as it called beginAccess.

Note that a coherent subscriber should first be enabled, otherwise this operation throws a DDSException. See org.omg.dds.core.Entity#enable() for more information on coherent access.

Exceptions

org.omg.dds.core.DDSException	An internal error has occurred.
org.omg.dds.core.AlreadyClosedException	The corresponding Subscriber has been closed.
org.omg.dds.core.PreconditionNotMetException	When the PresentationQos has not set AccessScope to GROUP

See also: endAccess(); org.omg.dds.core.policy.Presentation

Implements org.omg.dds.sub.Subscriber.

Definition at line 437 of file SubscriberImpl.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.sub.SubscriberImpl.closeContainedEntities ( )

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

That is, it closes all contained org.omg.dds.sub.DataReader objects. This pattern is applied recursively. In this manner the operation on the Subscriber will end up closing all the entities recursively contained in the Subscriber, that is also the org.omg.dds.sub.QueryCondition and org.omg.dds.sub.ReadCondition objects belonging to the contained DataReaders.

Exceptions

org.omg.dds.core.PreconditionNotMetException if any of the contained entities is in a state where it cannot be closed. This will occur, for example, if a contained DataReader cannot be closed because the application has called a org.omg.dds.sub.DataReader#read() or org.omg.dds.sub.DataReader#take() operation and has not called the corresponding Sample.Iterator#close() operation to return the loaned samples.

Implements org.omg.dds.sub.Subscriber.

Definition at line 349 of file SubscriberImpl.java.

◆ copyFromTopicQos()

DataReaderQos org.opensplice.dds.sub.SubscriberImpl.copyFromTopicQos	(	DataReaderQos	drQos,
		TopicQos	tQos
	)

This operation copies the policies in the org.omg.dds.topic.TopicQos to the corresponding policies in the org.omg.dds.sub.DataReaderQos (replacing values in the latter, if present).

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

This operation does not check the resulting 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 DataReader.

Parameters

drQos	The QoS, the policies of which will be overridden. This object is not modified.
tQos	The source for the new policies to be copied. This object is not modified.

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

Exceptions

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

Implements org.omg.dds.sub.Subscriber.

Definition at line 476 of file SubscriberImpl.java.

◆ createDataState()

DataState org.opensplice.dds.sub.SubscriberImpl.createDataState ( )

Create and return a new modifiable DataState object.

This object will be initialized with no sample states, no instance states, and no view states.

This method shall never return null.

Returns: a new DataState object.

Implements org.omg.dds.sub.Subscriber.

Definition at line 515 of file SubscriberImpl.java.

◆ destroy()

void org.opensplice.dds.sub.SubscriberImpl.destroy ( )

protected

Definition at line 520 of file SubscriberImpl.java.

◆ destroyDataReader()

void org.opensplice.dds.sub.SubscriberImpl.destroyDataReader ( AbstractDataReader<?> dataReader )

Definition at line 525 of file SubscriberImpl.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)

◆ endAccess()

void org.opensplice.dds.sub.SubscriberImpl.endAccess ( )

Indicates that the application has finished accessing the data samples in org.omg.dds.sub.DataReader objects managed by the Subscriber.

This operation must be used to 'close' a corresponding beginAccess().

After calling endAccess the application should no longer access any of the Sample (including corresponding data) elements returned from the sample-accessing operations.

See org.omg.dds.core.Entity#enable() for more information on coherent access.

Exceptions

org.omg.dds.core.PreconditionNotMetException	if this call does not close a previous call to beginAccess().
org.omg.dds.core.DDSException	An internal error has occurred.
org.omg.dds.core.AlreadyClosedException	The corresponding Subscriber has been closed.

See also: beginAccess()

Implements org.omg.dds.sub.Subscriber.

Definition at line 444 of file SubscriberImpl.java.

◆ getDataReaders() [1/3]

Collection<DataReader<?> > org.opensplice.dds.sub.SubscriberImpl.getDataReaders ( Collection< DataReader<?>> readers )

Definition at line 362 of file SubscriberImpl.java.

◆ getDataReaders() [2/3]

Collection<DataReader<?> > org.opensplice.dds.sub.SubscriberImpl.getDataReaders ( )

This operation is equivalent to calling getDataReaders(DataState) with any sample state ( Subscriber.DataState#withAnySampleState()), any view state ( Subscriber.DataState#withAnyViewState()), and any instance state (Subscriber.DataState#withAnyInstanceState()).

Returns: A collection of DataReaders that belong to this Subscriber.

Exceptions

org.omg.dds.core.PreconditionNotMetException	if the Subscriber has org.omg.dds.core.policy.Presentation#getAccessScope() set to org.omg.dds.core.policy.Presentation.AccessScopeKind#GROUP and this operation is not invoked inside a beginAccess()/endAccess() block.
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 Subscriber has been closed.

See also: getDataReaders(DataState); beginAccess(); endAccess(); org.omg.dds.core.policy.Presentation

Implements org.omg.dds.sub.Subscriber.

Definition at line 381 of file SubscriberImpl.java.

◆ getDataReaders() [3/3]

Collection<DataReader<?> > org.opensplice.dds.sub.SubscriberImpl.getDataReaders ( DataState dataState )

This operation allows the application to access the org.omg.dds.sub.DataReader objects that contain samples with the specified sample states, view states, and instance states.

If the org.omg.dds.core.policy.Presentation of the Subscriber has org.omg.dds.core.policy.Presentation#getAccessScope() set to org.omg.dds.core.policy.Presentation.AccessScopeKind#GROUP, this operation should only be invoked inside a beginAccess()/ endAccess() block. Otherwise it will fail with org.omg.dds.core.PreconditionNotMetException.

Depending on the setting of the org.omg.dds.core.policy.Presentation, the returned collection of DataReader objects may be a 'set' containing each DataReader at most once in no specified order, or a 'list' containing each DataReader one or more times in a specific order. (This refers to the semantics of the collection; the concrete type of the collection may or may not implement Set or java.util.List).

If org.omg.dds.core.policy.Presentation#getAccessScope() is org.omg.dds.core.policy.Presentation.AccessScopeKind#INSTANCE or org.omg.dds.core.policy.Presentation.AccessScopeKind#TOPIC, the returned collection is a 'set'.
If org.omg.dds.core.policy.Presentation#getAccessScope() is org.omg.dds.core.policy.Presentation.AccessScopeKind#GROUP and org.omg.dds.core.policy.Presentation#isOrderedAccess() is true, then the returned collection is a 'list'.

This difference is due to the fact that, in the second situation it is required to access samples belonging to different DataReader objects in a particular order. In this case, the application should process each DataReader in the same order it appears in the 'list' and read or take exactly one sample from each DataReader.

Parameters

dataState a DataReader will only be placed into the readers collection if it has data available with one of these sample states, view states, and instance states.

Returns: A collection of DataReaders that contain samples with the specified sample states.

Exceptions

org.omg.dds.core.PreconditionNotMetException	if the Subscriber has org.omg.dds.core.policy.Presentation#getAccessScope() set to org.omg.dds.core.policy.Presentation.AccessScopeKind#GROUP and this operation is not invoked inside a beginAccess()/endAccess() block.
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 Subscriber has been closed.

See also: getDataReaders(); beginAccess(); endAccess(); org.omg.dds.core.policy.Presentation

Implements org.omg.dds.sub.Subscriber.

Definition at line 399 of file SubscriberImpl.java.

◆ getDefaultDataReaderQos()

DataReaderQos org.opensplice.dds.sub.SubscriberImpl.getDefaultDataReaderQos ( )

This operation retrieves the default value of the DataReader QoS, that is, the QoS policies which will be used for newly created org.omg.dds.sub.DataReader entities in the case where the QoS policies are defaulted in the createDataReader(TopicDescription) operation.

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

Returns: the default DataReaderQos

Exceptions

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

See also: setDefaultDataReaderQos(DataReaderQos)

Implements org.omg.dds.sub.Subscriber.

Definition at line 451 of file SubscriberImpl.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.sub.SubscriberImpl.getParent ( )

Returns: the factory object that created this entity.

Implements org.omg.dds.sub.Subscriber.

Definition at line 510 of file SubscriberImpl.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()

SubscriberQos org.opensplice.dds.sub.SubscriberImpl.getQos ( )

Definition at line 157 of file SubscriberImpl.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<Subscriber> org.opensplice.dds.sub.SubscriberImpl.getStatusCondition ( )

Implements org.omg.dds.sub.Subscriber.

Definition at line 499 of file SubscriberImpl.java.

◆ isBuiltin()

boolean org.opensplice.dds.sub.SubscriberImpl.isBuiltin ( )

Definition at line 116 of file SubscriberImpl.java.

◆ notifyDataReaders()

void org.opensplice.dds.sub.SubscriberImpl.notifyDataReaders ( )

This operation invokes the operation org.omg.dds.sub.DataReaderListener#onDataAvailable(org.omg.dds.core.event.DataAvailableEvent) on the DataReaderListener objects attached to contained DataReader entities with a org.omg.dds.core.event.DataAvailableEvent that is considered changed.

This operation is typically invoked from org.omg.dds.sub.SubscriberListener#onDataOnReaders(org.omg.dds.core.event.DataOnReadersEvent). That way the SubscriberListener can delegate to the DataReaderListener objects the handling of the data.

Implements org.omg.dds.sub.Subscriber.

Definition at line 429 of file SubscriberImpl.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.

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

◆ setDefaultDataReaderQos()

void org.opensplice.dds.sub.SubscriberImpl.setDefaultDataReaderQos ( DataReaderQos qos )

This operation sets a default value of the DataReader QoS policies, which will be used for newly created org.omg.dds.sub.DataReader entities in the case where the QoS policies are defaulted in the createDataReader(TopicDescription) operation.

Parameters

qos	The new default DataReaderQos

Exceptions

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

See also: getDefaultDataReaderQos()

Implements org.omg.dds.sub.Subscriber.

Definition at line 460 of file SubscriberImpl.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.sub.SubscriberImpl.setListener ( SubscriberListener listener )

Definition at line 138 of file SubscriberImpl.java.

◆ setListener() [5/6]

void org.opensplice.dds.sub.SubscriberImpl.setListener	(	SubscriberListener	listener,
		Collection< Class<? extends Status >>	statuses
	)

Definition at line 143 of file SubscriberImpl.java.

◆ setListener() [6/6]

void org.opensplice.dds.sub.SubscriberImpl.setListener	(	SubscriberListener	listener,
		Class<? extends Status >...	statuses
	)

Definition at line 150 of file SubscriberImpl.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.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()

◆ setQos() [2/2]

void org.opensplice.dds.sub.SubscriberImpl.setQos ( SubscriberQos qos )

Definition at line 167 of file SubscriberImpl.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/sub/SubscriberImpl.java

Public Member Functions

Static Public Member Functions

Protected Member Functions

Protected Attributes

Detailed Description

Constructor & Destructor Documentation

◆ SubscriberImpl() [1/2]

◆ SubscriberImpl() [2/2]

Member Function Documentation

◆ beginAccess()

◆ close() [1/2]

◆ close() [2/2]

◆ closeContainedEntities()

◆ copyFromTopicQos()

◆ createDataState()

◆ destroy()

◆ destroyDataReader()

◆ enable() [1/2]

◆ enable() [2/2]

◆ endAccess()

◆ getDataReaders() [1/3]

◆ getDataReaders() [2/3]

◆ getDataReaders() [3/3]

◆ getDefaultDataReaderQos()

◆ 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()

◆ isBuiltin()

◆ notifyDataReaders()

◆ printReferences()

◆ retain() [1/2]

◆ retain() [2/2]

◆ setDefaultDataReaderQos()

◆ 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]

Member Data Documentation

◆ environment

◆ listener

◆ parent