Package akka.stream
Interface StreamRefSettings
-
public interface StreamRefSettings
-
-
Method Summary
All Methods Instance Methods Abstract Methods Deprecated Methods Modifier and Type Method Description intbufferCapacity()Deprecated.Use attribute 'StreamRefAttributes.BufferCapacity' to read the concrete setting value.scala.concurrent.duration.FiniteDurationdemandRedeliveryInterval()Deprecated.Use attribute 'StreamRefAttributes.DemandRedeliveryInterval' to read the concrete setting value.scala.concurrent.duration.FiniteDurationfinalTerminationSignalDeadline()Deprecated.Use attribute 'StreamRefAttributes.FinalTerminationSignalDeadline' to read the concrete setting value.scala.concurrent.duration.FiniteDurationsubscriptionTimeout()Deprecated.Use attribute 'StreamRefAttributes.SubscriptionTimeout' to read the concrete setting value.StreamRefSettingswithBufferCapacity(int value)StreamRefSettingswithDemandRedeliveryInterval(scala.concurrent.duration.FiniteDuration value)StreamRefSettingswithSubscriptionTimeout(scala.concurrent.duration.FiniteDuration value)StreamRefSettingswithTerminationReceivedBeforeCompletionLeeway(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)
-
-