Package akka.stream
Interface StreamRefSettings
-
public interface StreamRefSettings
-
-
Method Summary
All Methods Instance Methods Abstract Methods Deprecated Methods 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 Detail
-
bufferCapacity
int bufferCapacity()
Deprecated.Use attribute 'StreamRefAttributes.BufferCapacity' to read the concrete setting value. Since 2.6.0.
-
demandRedeliveryInterval
scala.concurrent.duration.FiniteDuration demandRedeliveryInterval()
Deprecated.Use attribute 'StreamRefAttributes.DemandRedeliveryInterval' to read the concrete setting value. Since 2.6.0.
-
subscriptionTimeout
scala.concurrent.duration.FiniteDuration subscriptionTimeout()
Deprecated.Use attribute 'StreamRefAttributes.SubscriptionTimeout' to read the concrete setting value. Since 2.6.0.
-
finalTerminationSignalDeadline
scala.concurrent.duration.FiniteDuration finalTerminationSignalDeadline()
Deprecated.Use attribute 'StreamRefAttributes.FinalTerminationSignalDeadline' to read the concrete setting value. Since 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)
-
-