Package | Description |
---|---|
org.omg.dds.core |
The Core (Infrastructure) Module defines the abstract classes and the
interfaces that are refined by the other modules.
|
org.omg.dds.core.policy | |
org.omg.dds.domain |
The Domain Module contains the
DomainParticipant
class that acts as an entry-point of the Service and acts as a factory for
many of the classes. |
org.omg.dds.pub |
The Publication Module contains the
Publisher and
DataWriter interfaces as well as the
PublisherListener and
DataWriterListener interfaces, and more generally,
all that is needed on the publication side. |
org.omg.dds.sub |
The Subscription Module contains the
Subscriber ,
DataReader , ReadCondition ,
and QueryCondition interfaces, as well as the
SubscriberListener and
DataReaderListener interfaces, and more generally,
all that is needed on the subscription side. |
Modifier and Type | Method and Description |
---|---|
abstract Duration |
Duration.add(Duration duration) |
abstract Duration |
Duration.add(long duration,
TimeUnit unit) |
Duration |
ServiceEnvironment.ServiceProviderInterface.infiniteDuration() |
static Duration |
Duration.infiniteDuration(ServiceEnvironment env) |
Duration |
ServiceEnvironment.ServiceProviderInterface.newDuration(long duration,
TimeUnit unit)
Construct a
Duration of the given magnitude. |
static Duration |
Duration.newDuration(long duration,
TimeUnit unit,
ServiceEnvironment env)
Construct a time duration of the given magnitude.
|
abstract Duration |
Duration.subtract(Duration duration) |
abstract Duration |
Duration.subtract(long duration,
TimeUnit unit) |
Duration |
ServiceEnvironment.ServiceProviderInterface.zeroDuration() |
static Duration |
Duration.zeroDuration(ServiceEnvironment env) |
Modifier and Type | Method and Description |
---|---|
abstract void |
ModifiableTime.add(Duration duration)
Increment this time by the given amount.
|
abstract Duration |
Duration.add(Duration duration) |
abstract void |
ModifiableTime.subtract(Duration duration)
Decrement this time by the given amount.
|
abstract Duration |
Duration.subtract(Duration duration) |
abstract void |
WaitSet.waitForConditions(Collection<Condition> activeConditions,
Duration timeout)
This operation allows an application thread to wait for the occurrence
of certain conditions.
|
abstract void |
WaitSet.waitForConditions(Duration timeout)
This operation allows an application thread to wait for the occurrence
of certain conditions.
|
Modifier and Type | Method and Description |
---|---|
Duration |
ReaderDataLifecycle.getAutoPurgeDisposedSamplesDelay() |
Duration |
ReaderDataLifecycle.getAutoPurgeNoWriterSamplesDelay() |
Duration |
Lifespan.getDuration() |
Duration |
LatencyBudget.getDuration() |
Duration |
Liveliness.getLeaseDuration() |
Duration |
Reliability.getMaxBlockingTime() |
Duration |
TimeBasedFilter.getMinimumSeparation() |
Duration |
Deadline.getPeriod() |
Duration |
DurabilityService.getServiceCleanupDelay() |
Modifier and Type | Method and Description |
---|---|
ReaderDataLifecycle |
ReaderDataLifecycle.withAutoPurgeDisposedSamplesDelay(Duration autoPurgeDisposedSamplesDelay)
Copy this policy and override the value of the property.
|
ReaderDataLifecycle |
ReaderDataLifecycle.withAutoPurgeNoWriterSamplesDelay(Duration autoPurgeNoWriterSamplesDelay)
Copy this policy and override the value of the property.
|
Lifespan |
Lifespan.withDuration(Duration duration)
Copy this policy and override the value of the property.
|
LatencyBudget |
LatencyBudget.withDuration(Duration duration)
Copy this policy and override the value of the property.
|
Liveliness |
Liveliness.withLeaseDuration(Duration leaseDuration)
Copy this policy and override the value of the property.
|
Reliability |
Reliability.withMaxBlockingTime(Duration maxBlockingTime)
Copy this policy and override the value of the property.
|
TimeBasedFilter |
TimeBasedFilter.withMinimumSeparation(Duration minimumSeparation)
Copy this policy and override the value of the property.
|
Deadline |
Deadline.withPeriod(Duration period)
Copy this policy and override the value of the property.
|
DurabilityService |
DurabilityService.withServiceCleanupDelay(Duration serviceCleanupDelay)
Copy this policy and override the value of the property.
|
Modifier and Type | Method and Description |
---|---|
<TYPE> Topic<TYPE> |
DomainParticipant.findTopic(String topicName,
Duration timeout)
This operation gives access to an existing (or ready to exist) enabled
Topic, based on its name.
|
Modifier and Type | Method and Description |
---|---|
void |
Publisher.waitForAcknowledgments(Duration maxWait)
This operation blocks the calling thread until either all data
written by the reliable
DataWriter entities is acknowledged by
all matched reliable DataReader entities, or else the duration
specified elapses, whichever happens first. |
void |
DataWriter.waitForAcknowledgments(Duration maxWait)
This operation is intended to be used only if the DataWriter has
Reliability.getKind() set to
Reliability.Kind.RELIABLE . |
Modifier and Type | Method and Description |
---|---|
void |
DataReader.waitForHistoricalData(Duration maxWait)
This operation is intended only for DataReader entities for which
Durability.getKind() is not
Durability.Kind.VOLATILE . |
Copyright © 2014. All rights reserved.