StreamRefSettings

public interface StreamRefSettings

Settings specific to SourceRef and SinkRef. More detailed documentation about each of the settings is available in reference.conf.

Method Summary

Modifier and Type

Method

Description

int

bufferCapacity()

Deprecated.
Use attribute 'StreamRefAttributes.BufferCapacity' to read the concrete setting value.

scala.concurrent.duration.FiniteDuration

demandRedeliveryInterval()

Deprecated.
Use attribute 'StreamRefAttributes.DemandRedeliveryInterval' to read the concrete setting value.

scala.concurrent.duration.FiniteDuration

finalTerminationSignalDeadline()

Deprecated.
Use attribute 'StreamRefAttributes.FinalTerminationSignalDeadline' to read the concrete setting value.

scala.concurrent.duration.FiniteDuration

subscriptionTimeout()

Deprecated.
Use attribute 'StreamRefAttributes.SubscriptionTimeout' to read the concrete setting value.

StreamRefSettings

withBufferCapacity(int value)

StreamRefSettings

withDemandRedeliveryInterval(scala.concurrent.duration.FiniteDuration value)

StreamRefSettings

withSubscriptionTimeout(scala.concurrent.duration.FiniteDuration value)

StreamRefSettings

withTerminationReceivedBeforeCompletionLeeway(scala.concurrent.duration.FiniteDuration value)

Method Details
- bufferCapacity
  
  int bufferCapacity()
  
  Deprecated.
  Use attribute 'StreamRefAttributes.BufferCapacity' to read the concrete setting value. Since Akka 2.6.0.
- demandRedeliveryInterval
  
  scala.concurrent.duration.FiniteDuration demandRedeliveryInterval()
  
  Deprecated.
  Use attribute 'StreamRefAttributes.DemandRedeliveryInterval' to read the concrete setting value. Since Akka 2.6.0.
- subscriptionTimeout
  
  scala.concurrent.duration.FiniteDuration subscriptionTimeout()
  
  Deprecated.
  Use attribute 'StreamRefAttributes.SubscriptionTimeout' to read the concrete setting value. Since Akka 2.6.0.
- finalTerminationSignalDeadline
  
  scala.concurrent.duration.FiniteDuration finalTerminationSignalDeadline()
  
  Deprecated.
  Use attribute 'StreamRefAttributes.FinalTerminationSignalDeadline' to read the concrete setting value. Since Akka 2.6.0.
- withBufferCapacity
  
  StreamRefSettings withBufferCapacity(int value)
- withDemandRedeliveryInterval
  
  StreamRefSettings withDemandRedeliveryInterval(scala.concurrent.duration.FiniteDuration value)
- withSubscriptionTimeout
  
  StreamRefSettings withSubscriptionTimeout(scala.concurrent.duration.FiniteDuration value)
- withTerminationReceivedBeforeCompletionLeeway
  
  StreamRefSettings withTerminationReceivedBeforeCompletionLeeway(scala.concurrent.duration.FiniteDuration value)