format the code
This commit is contained in:
parent
4e20bcf403
commit
c05bd51b68
8 changed files with 15 additions and 15 deletions
|
|
@ -12,7 +12,7 @@ import org.apache.camel.impl.DefaultCamelContext
|
||||||
/**
|
/**
|
||||||
* Subclass this abstract class to create an MDB-style untyped consumer actor. This
|
* Subclass this abstract class to create an MDB-style untyped consumer actor. This
|
||||||
* class is meant to be used from Java.
|
* class is meant to be used from Java.
|
||||||
*
|
*
|
||||||
* @deprecated Akka Camel is deprecated since 2.5.0 in favour of 'Alpakka', the Akka Streams based collection of integrations to various endpoints (including Camel).
|
* @deprecated Akka Camel is deprecated since 2.5.0 in favour of 'Alpakka', the Akka Streams based collection of integrations to various endpoints (including Camel).
|
||||||
*/
|
*/
|
||||||
@Deprecated
|
@Deprecated
|
||||||
|
|
|
||||||
|
|
@ -11,7 +11,7 @@ import org.apache.camel.impl.DefaultCamelContext
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Subclass this abstract class to create an untyped producer actor. This class is meant to be used from Java.
|
* Subclass this abstract class to create an untyped producer actor. This class is meant to be used from Java.
|
||||||
*
|
*
|
||||||
* @deprecated Akka Camel is deprecated since 2.5.0 in favour of 'Alpakka', the Akka Streams based collection of integrations to various endpoints (including Camel).
|
* @deprecated Akka Camel is deprecated since 2.5.0 in favour of 'Alpakka', the Akka Streams based collection of integrations to various endpoints (including Camel).
|
||||||
*/
|
*/
|
||||||
@Deprecated
|
@Deprecated
|
||||||
|
|
|
||||||
|
|
@ -121,7 +121,7 @@ object ActorPublisherMessage {
|
||||||
*
|
*
|
||||||
* If the actor is stopped the stream will be completed, unless it was not already terminated with
|
* If the actor is stopped the stream will be completed, unless it was not already terminated with
|
||||||
* failure, completed or canceled.
|
* failure, completed or canceled.
|
||||||
*
|
*
|
||||||
* @deprecated Use `akka.stream.stage.GraphStage` instead, it allows for all operations an Actor would and is more type-safe as well as guaranteed to be ReactiveStreams compliant.
|
* @deprecated Use `akka.stream.stage.GraphStage` instead, it allows for all operations an Actor would and is more type-safe as well as guaranteed to be ReactiveStreams compliant.
|
||||||
*/
|
*/
|
||||||
@deprecated("Use `akka.stream.stage.GraphStage` instead, it allows for all operations an Actor would and is more type-safe as well as guaranteed to be ReactiveStreams compliant.", since = "2.5.0")
|
@deprecated("Use `akka.stream.stage.GraphStage` instead, it allows for all operations an Actor would and is more type-safe as well as guaranteed to be ReactiveStreams compliant.", since = "2.5.0")
|
||||||
|
|
@ -472,7 +472,7 @@ object AbstractActorPublisher {
|
||||||
/**
|
/**
|
||||||
* Java API compatible with lambda expressions
|
* Java API compatible with lambda expressions
|
||||||
* @see [[akka.stream.actor.ActorPublisher]]
|
* @see [[akka.stream.actor.ActorPublisher]]
|
||||||
*
|
*
|
||||||
* @deprecated Use `akka.stream.stage.GraphStage` instead, it allows for all operations an Actor would and is more type-safe as well as guaranteed to be ReactiveStreams compliant.
|
* @deprecated Use `akka.stream.stage.GraphStage` instead, it allows for all operations an Actor would and is more type-safe as well as guaranteed to be ReactiveStreams compliant.
|
||||||
*/
|
*/
|
||||||
@deprecated("Use `akka.stream.stage.GraphStage` instead, it allows for all operations an Actor would and is more type-safe as well as guaranteed to be ReactiveStreams compliant.", since = "2.5.0")
|
@deprecated("Use `akka.stream.stage.GraphStage` instead, it allows for all operations an Actor would and is more type-safe as well as guaranteed to be ReactiveStreams compliant.", since = "2.5.0")
|
||||||
|
|
@ -482,7 +482,7 @@ abstract class AbstractActorPublisher[T] extends AbstractActor with ActorPublish
|
||||||
* Java API compatible with lambda expressions.
|
* Java API compatible with lambda expressions.
|
||||||
* This class adds a Stash to {@link AbstractActorPublisher}.
|
* This class adds a Stash to {@link AbstractActorPublisher}.
|
||||||
* @see [[akka.stream.actor.ActorPublisher]] and [[akka.stream.actor.AbstractActorWithStash]]
|
* @see [[akka.stream.actor.ActorPublisher]] and [[akka.stream.actor.AbstractActorWithStash]]
|
||||||
*
|
*
|
||||||
* @deprecated Use `akka.stream.stage.GraphStage` instead, it allows for all operations an Actor would and is more type-safe as well as guaranteed to be ReactiveStreams compliant.
|
* @deprecated Use `akka.stream.stage.GraphStage` instead, it allows for all operations an Actor would and is more type-safe as well as guaranteed to be ReactiveStreams compliant.
|
||||||
*/
|
*/
|
||||||
@deprecated("Use `akka.stream.stage.GraphStage` instead, it allows for all operations an Actor would and is more type-safe as well as guaranteed to be ReactiveStreams compliant.", since = "2.5.0")
|
@deprecated("Use `akka.stream.stage.GraphStage` instead, it allows for all operations an Actor would and is more type-safe as well as guaranteed to be ReactiveStreams compliant.", since = "2.5.0")
|
||||||
|
|
@ -492,7 +492,7 @@ abstract class AbstractActorPublisherWithStash[T] extends AbstractActor with Act
|
||||||
* Java API compatible with lambda expressions.
|
* Java API compatible with lambda expressions.
|
||||||
* This class adds an unbounded Stash to {@link AbstractActorPublisher}.
|
* This class adds an unbounded Stash to {@link AbstractActorPublisher}.
|
||||||
* @see [[akka.stream.actor.ActorPublisher]] and [[akka.stream.actor.AbstractActorWithUnboundedStash]]
|
* @see [[akka.stream.actor.ActorPublisher]] and [[akka.stream.actor.AbstractActorWithUnboundedStash]]
|
||||||
*
|
*
|
||||||
* @deprecated Use `akka.stream.stage.GraphStage` instead, it allows for all operations an Actor would and is more type-safe as well as guaranteed to be ReactiveStreams compliant.
|
* @deprecated Use `akka.stream.stage.GraphStage` instead, it allows for all operations an Actor would and is more type-safe as well as guaranteed to be ReactiveStreams compliant.
|
||||||
*/
|
*/
|
||||||
@deprecated("Use `akka.stream.stage.GraphStage` instead, it allows for all operations an Actor would and is more type-safe as well as guaranteed to be ReactiveStreams compliant.", since = "2.5.0")
|
@deprecated("Use `akka.stream.stage.GraphStage` instead, it allows for all operations an Actor would and is more type-safe as well as guaranteed to be ReactiveStreams compliant.", since = "2.5.0")
|
||||||
|
|
@ -502,7 +502,7 @@ abstract class AbstractActorPublisherWithUnboundedStash[T] extends AbstractActor
|
||||||
* Java API compatible with lambda expressions.
|
* Java API compatible with lambda expressions.
|
||||||
* This class adds an unrestricted Stash to {@link AbstractActorPublisher}.
|
* This class adds an unrestricted Stash to {@link AbstractActorPublisher}.
|
||||||
* @see [[akka.stream.actor.ActorPublisher]] and [[akka.stream.actor.AbstractActorWithUnrestrictedStash]]
|
* @see [[akka.stream.actor.ActorPublisher]] and [[akka.stream.actor.AbstractActorWithUnrestrictedStash]]
|
||||||
*
|
*
|
||||||
* @deprecated Use `akka.stream.stage.GraphStage` instead, it allows for all operations an Actor would and is more type-safe as well as guaranteed to be ReactiveStreams compliant.
|
* @deprecated Use `akka.stream.stage.GraphStage` instead, it allows for all operations an Actor would and is more type-safe as well as guaranteed to be ReactiveStreams compliant.
|
||||||
*/
|
*/
|
||||||
@deprecated("Use `akka.stream.stage.GraphStage` instead, it allows for all operations an Actor would and is more type-safe as well as guaranteed to be ReactiveStreams compliant.", since = "2.5.0")
|
@deprecated("Use `akka.stream.stage.GraphStage` instead, it allows for all operations an Actor would and is more type-safe as well as guaranteed to be ReactiveStreams compliant.", since = "2.5.0")
|
||||||
|
|
|
||||||
|
|
@ -158,7 +158,7 @@ abstract class MaxInFlightRequestStrategy(max: Int) extends RequestStrategy {
|
||||||
* together with [[ZeroRequestStrategy]] or some other strategy. In that case
|
* together with [[ZeroRequestStrategy]] or some other strategy. In that case
|
||||||
* you must also call [[#request]] when the actor is started or when it is ready, otherwise
|
* you must also call [[#request]] when the actor is started or when it is ready, otherwise
|
||||||
* it will not receive any elements.
|
* it will not receive any elements.
|
||||||
*
|
*
|
||||||
* @deprecated Use `akka.stream.stage.GraphStage` instead, it allows for all operations an Actor would and is more type-safe as well as guaranteed to be ReactiveStreams compliant.
|
* @deprecated Use `akka.stream.stage.GraphStage` instead, it allows for all operations an Actor would and is more type-safe as well as guaranteed to be ReactiveStreams compliant.
|
||||||
*/
|
*/
|
||||||
@deprecated("Use `akka.stream.stage.GraphStage` instead, it allows for all operations an Actor would and is more type-safe as well as guaranteed to be ReactiveStreams compliant.", since = "2.5.0")
|
@deprecated("Use `akka.stream.stage.GraphStage` instead, it allows for all operations an Actor would and is more type-safe as well as guaranteed to be ReactiveStreams compliant.", since = "2.5.0")
|
||||||
|
|
@ -350,7 +350,7 @@ object UntypedActorSubscriber {
|
||||||
/**
|
/**
|
||||||
* Java API
|
* Java API
|
||||||
* @see [[akka.stream.actor.ActorSubscriber]]
|
* @see [[akka.stream.actor.ActorSubscriber]]
|
||||||
*
|
*
|
||||||
* @deprecated Use `akka.stream.stage.GraphStage` instead, it allows for all operations an Actor would and is more type-safe as well as guaranteed to be ReactiveStreams compliant.
|
* @deprecated Use `akka.stream.stage.GraphStage` instead, it allows for all operations an Actor would and is more type-safe as well as guaranteed to be ReactiveStreams compliant.
|
||||||
*/
|
*/
|
||||||
@deprecated("Use `akka.stream.stage.GraphStage` instead, it allows for all operations an Actor would and is more type-safe as well as guaranteed to be ReactiveStreams compliant.", since = "2.5.0")
|
@deprecated("Use `akka.stream.stage.GraphStage` instead, it allows for all operations an Actor would and is more type-safe as well as guaranteed to be ReactiveStreams compliant.", since = "2.5.0")
|
||||||
|
|
@ -358,7 +358,7 @@ abstract class UntypedActorSubscriber extends UntypedActor with ActorSubscriber
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Java API compatible with lambda expressions
|
* Java API compatible with lambda expressions
|
||||||
*
|
*
|
||||||
* @deprecated Use `akka.stream.stage.GraphStage` instead, it allows for all operations an Actor would and is more type-safe as well as guaranteed to be ReactiveStreams compliant.
|
* @deprecated Use `akka.stream.stage.GraphStage` instead, it allows for all operations an Actor would and is more type-safe as well as guaranteed to be ReactiveStreams compliant.
|
||||||
*/
|
*/
|
||||||
@deprecated("Use `akka.stream.stage.GraphStage` instead, it allows for all operations an Actor would and is more type-safe as well as guaranteed to be ReactiveStreams compliant.", since = "2.5.0")
|
@deprecated("Use `akka.stream.stage.GraphStage` instead, it allows for all operations an Actor would and is more type-safe as well as guaranteed to be ReactiveStreams compliant.", since = "2.5.0")
|
||||||
|
|
@ -374,7 +374,7 @@ object AbstractActorSubscriber {
|
||||||
/**
|
/**
|
||||||
* Java API compatible with lambda expressions
|
* Java API compatible with lambda expressions
|
||||||
* @see [[akka.stream.actor.ActorSubscriber]]
|
* @see [[akka.stream.actor.ActorSubscriber]]
|
||||||
*
|
*
|
||||||
* @deprecated Use `akka.stream.stage.GraphStage` instead, it allows for all operations an Actor would and is more type-safe as well as guaranteed to be ReactiveStreams compliant.
|
* @deprecated Use `akka.stream.stage.GraphStage` instead, it allows for all operations an Actor would and is more type-safe as well as guaranteed to be ReactiveStreams compliant.
|
||||||
*/
|
*/
|
||||||
@deprecated("Use `akka.stream.stage.GraphStage` instead, it allows for all operations an Actor would and is more type-safe as well as guaranteed to be ReactiveStreams compliant.", since = "2.5.0")
|
@deprecated("Use `akka.stream.stage.GraphStage` instead, it allows for all operations an Actor would and is more type-safe as well as guaranteed to be ReactiveStreams compliant.", since = "2.5.0")
|
||||||
|
|
|
||||||
|
|
@ -213,7 +213,7 @@ object Sink {
|
||||||
* Creates a `Sink` that is materialized to an [[akka.actor.ActorRef]] which points to an Actor
|
* Creates a `Sink` that is materialized to an [[akka.actor.ActorRef]] which points to an Actor
|
||||||
* created according to the passed in [[akka.actor.Props]]. Actor created by the `props` should
|
* created according to the passed in [[akka.actor.Props]]. Actor created by the `props` should
|
||||||
* be [[akka.stream.actor.ActorSubscriber]].
|
* be [[akka.stream.actor.ActorSubscriber]].
|
||||||
*
|
*
|
||||||
* @deprecated Use `akka.stream.stage.GraphStage` and `fromGraph` instead, it allows for all operations an Actor would and is more type-safe as well as guaranteed to be ReactiveStreams compliant.
|
* @deprecated Use `akka.stream.stage.GraphStage` and `fromGraph` instead, it allows for all operations an Actor would and is more type-safe as well as guaranteed to be ReactiveStreams compliant.
|
||||||
*/
|
*/
|
||||||
@deprecated("Use `akka.stream.stage.GraphStage` and `fromGraph` instead, it allows for all operations an Actor would and is more type-safe as well as guaranteed to be ReactiveStreams compliant.", since = "2.5.0")
|
@deprecated("Use `akka.stream.stage.GraphStage` and `fromGraph` instead, it allows for all operations an Actor would and is more type-safe as well as guaranteed to be ReactiveStreams compliant.", since = "2.5.0")
|
||||||
|
|
|
||||||
|
|
@ -238,7 +238,7 @@ object Source {
|
||||||
* Creates a `Source` that is materialized to an [[akka.actor.ActorRef]] which points to an Actor
|
* Creates a `Source` that is materialized to an [[akka.actor.ActorRef]] which points to an Actor
|
||||||
* created according to the passed in [[akka.actor.Props]]. Actor created by the `props` should
|
* created according to the passed in [[akka.actor.Props]]. Actor created by the `props` should
|
||||||
* be [[akka.stream.actor.ActorPublisher]].
|
* be [[akka.stream.actor.ActorPublisher]].
|
||||||
*
|
*
|
||||||
* @deprecated Use `akka.stream.stage.GraphStage` and `fromGraph` instead, it allows for all operations an Actor would and is more type-safe as well as guaranteed to be ReactiveStreams compliant.
|
* @deprecated Use `akka.stream.stage.GraphStage` and `fromGraph` instead, it allows for all operations an Actor would and is more type-safe as well as guaranteed to be ReactiveStreams compliant.
|
||||||
*/
|
*/
|
||||||
@deprecated("Use `akka.stream.stage.GraphStage` and `fromGraph` instead, it allows for all operations an Actor would and is more type-safe as well as guaranteed to be ReactiveStreams compliant.", since = "2.5.0")
|
@deprecated("Use `akka.stream.stage.GraphStage` and `fromGraph` instead, it allows for all operations an Actor would and is more type-safe as well as guaranteed to be ReactiveStreams compliant.", since = "2.5.0")
|
||||||
|
|
|
||||||
|
|
@ -350,7 +350,7 @@ object Sink {
|
||||||
* Creates a `Sink` that is materialized to an [[akka.actor.ActorRef]] which points to an Actor
|
* Creates a `Sink` that is materialized to an [[akka.actor.ActorRef]] which points to an Actor
|
||||||
* created according to the passed in [[akka.actor.Props]]. Actor created by the `props` must
|
* created according to the passed in [[akka.actor.Props]]. Actor created by the `props` must
|
||||||
* be [[akka.stream.actor.ActorSubscriber]].
|
* be [[akka.stream.actor.ActorSubscriber]].
|
||||||
*
|
*
|
||||||
* @deprecated Use `akka.stream.stage.GraphStage` and `fromGraph` instead, it allows for all operations an Actor would and is more type-safe as well as guaranteed to be ReactiveStreams compliant.
|
* @deprecated Use `akka.stream.stage.GraphStage` and `fromGraph` instead, it allows for all operations an Actor would and is more type-safe as well as guaranteed to be ReactiveStreams compliant.
|
||||||
*/
|
*/
|
||||||
@deprecated("Use `akka.stream.stage.GraphStage` and `fromGraph` instead, it allows for all operations an Actor would and is more type-safe as well as guaranteed to be ReactiveStreams compliant.", since = "2.5.0")
|
@deprecated("Use `akka.stream.stage.GraphStage` and `fromGraph` instead, it allows for all operations an Actor would and is more type-safe as well as guaranteed to be ReactiveStreams compliant.", since = "2.5.0")
|
||||||
|
|
|
||||||
|
|
@ -373,7 +373,7 @@ object Source {
|
||||||
* Creates a `Source` that is materialized to an [[akka.actor.ActorRef]] which points to an Actor
|
* Creates a `Source` that is materialized to an [[akka.actor.ActorRef]] which points to an Actor
|
||||||
* created according to the passed in [[akka.actor.Props]]. Actor created by the `props` must
|
* created according to the passed in [[akka.actor.Props]]. Actor created by the `props` must
|
||||||
* be [[akka.stream.actor.ActorPublisher]].
|
* be [[akka.stream.actor.ActorPublisher]].
|
||||||
*
|
*
|
||||||
* @deprecated Use `akka.stream.stage.GraphStage` and `fromGraph` instead, it allows for all operations an Actor would and is more type-safe as well as guaranteed to be ReactiveStreams compliant.
|
* @deprecated Use `akka.stream.stage.GraphStage` and `fromGraph` instead, it allows for all operations an Actor would and is more type-safe as well as guaranteed to be ReactiveStreams compliant.
|
||||||
*/
|
*/
|
||||||
@deprecated("Use `akka.stream.stage.GraphStage` and `fromGraph` instead, it allows for all operations an Actor would and is more type-safe as well as guaranteed to be ReactiveStreams compliant.", since = "2.5.0")
|
@deprecated("Use `akka.stream.stage.GraphStage` and `fromGraph` instead, it allows for all operations an Actor would and is more type-safe as well as guaranteed to be ReactiveStreams compliant.", since = "2.5.0")
|
||||||
|
|
|
||||||
Loading…
Add table
Add a link
Reference in a new issue