As I replied above, it has been fixed in later versions of Akka - you have not stated what version you’re using. Please upgrade to the latest, they’re all binary backwards compatible so you can bump the Akka version.
— Konrad On 26 October 2016 at 21:31:29, Konrad Malawski ( [email protected]) wrote: Well that's exactly the thing we fixed. As you've found in the docs. We'll release a stable this week, please upgrade then. -- Konrad `ktoso` Malawski Akka <http://akka.io> @ Lightbend <http://lightbend.com> On 26 October 2016 at 13:29:52, murtuza chhil ([email protected]) wrote: Still looking for an answer to this, if anyone can point out whats wrong and how to get it done. I was looking at some HTTP docs and there was a fix in there and wonder if the problem is related http://doc.akka.io/docs/akka-http/current/java/http/migration-guide/migration-guide-2.4.x-3.0.x.html#akka-http-2-4-11-3-0-0 "The Java DSL for the following directives pathPrefixText, rawPathPrefixTest, rawPathPrefix, pathSuffix accidentally used the Scala function type instead of the java.util.function.Function" -chhil On Thursday, October 20, 2016 at 10:33:03 PM UTC+5:30, murtuza chhil wrote: > > Having trouble setting up withSupervisionStrategy for the materializer. > > I get a compile time error of > > Error:(30, 23) java: no suitable method found for > withSupervisionStrategy(akka.japi.function.Function<java.lang.Throwable,akka.actor.SupervisorStrategy.Directive>) > method > akka.stream.ActorMaterializerSettings.withSupervisionStrategy(scala.Function1<java.lang.Throwable,akka.stream.Supervision.Directive>) > is not applicable > (argument mismatch; > akka.japi.function.Function<java.lang.Throwable,akka.actor.SupervisorStrategy.Directive> > cannot be converted to > scala.Function1<java.lang.Throwable,akka.stream.Supervision.Directive>) > method > akka.stream.ActorMaterializerSettings.withSupervisionStrategy(akka.japi.function.Function<java.lang.Throwable,akka.stream.Supervision.Directive>) > is not applicable > (argument mismatch; > akka.japi.function.Function<java.lang.Throwable,akka.actor.SupervisorStrategy.Directive> > cannot be converted to > akka.japi.function.Function<java.lang.Throwable,akka.stream.Supervision.Directive>) > > It for some reason is confusing the method that would be used for scala > (expecting a function1). > How do I get this to compile using java? > > import akka.NotUsed;import akka.actor.ActorSystem;import > akka.actor.SupervisorStrategy;import akka.japi.function.Function;import > akka.stream.ActorAttributes;import akka.stream.ActorMaterializer;import > akka.stream.IOResult;import akka.stream.Supervision;import > akka.stream.javadsl.*;import akka.util.ByteString;import scala.Function1; > import java.io.File;import java.util.concurrent.CompletionStage; > /** > * Created by Murtuza on 10/19/2016. > */public class EventFilter { > > public static void main(String[] args) { > > State filteredState = new State("ok"); > ActorSystem system = ActorSystem.create("system"); > ActorMaterializer mat = ActorMaterializer.create(system); > Function<Throwable,SupervisorStrategy.Directive> decider = thr > ->SupervisorStrategy.resume(); > > mat.settings().withSupervisionStrategy(decider); > > } > > Below supervisionStrategy expects a Function1 unlike for the mat which > expects a japi function > > > Flow<String, Event, NotUsed> parse = Flow.of(String.class) > .map(x -> { > //System.out.println(LogStreamProcessor.parseLineEx(x).get()); > return LogStreamProcessor.parseLineEx(x).get(); > > }).withAttributes(ActorAttributes.supervisionStrategy(...)); > > So I am kinda confused on passing the strategy. > > Any help will be greatly appreciated. > > -chhil > > -- >>>>>>>>>> Read the docs: http://akka.io/docs/ >>>>>>>>>> Check the FAQ: http://doc.akka.io/docs/akka/current/additional/faq.html >>>>>>>>>> Search the archives: https://groups.google.com/group/akka-user --- You received this message because you are subscribed to the Google Groups "Akka User List" group. To unsubscribe from this group and stop receiving emails from it, send an email to [email protected]. To post to this group, send email to [email protected]. Visit this group at https://groups.google.com/group/akka-user. For more options, visit https://groups.google.com/d/optout. -- >>>>>>>>>> Read the docs: http://akka.io/docs/ >>>>>>>>>> Check the FAQ: >>>>>>>>>> http://doc.akka.io/docs/akka/current/additional/faq.html >>>>>>>>>> Search the archives: https://groups.google.com/group/akka-user --- You received this message because you are subscribed to the Google Groups "Akka User List" group. To unsubscribe from this group and stop receiving emails from it, send an email to [email protected]. To post to this group, send email to [email protected]. Visit this group at https://groups.google.com/group/akka-user. For more options, visit https://groups.google.com/d/optout.
