[akka-user][deprecated] confuse about source.tick

2019-02-11 Thread 491537461q
object Test extends App { implicit val sys = ActorSystem("streamSys") implicit val ec = sys.dispatcher implicit val mat = ActorMaterializer( ActorMaterializerSettings(sys) .withInputBuffer(1,1) ) case class Tick() RunnableGraph.fromGraph(GraphDSL.create() { implicit b =>

[akka-user][deprecated] Akka Cluster starding not able to register to Coordinator

2019-02-11 Thread Bishnu Shankar Pandey
I am trying to create an Akka Sharding Cluster. I want to use proxy only mode on one of the nodes just to route the message to the shard regions. I am getting the following Warning: [WARN] [02/11/2019 17:04:17.819] [ClusterSystem-akka.actor.default-dispatcher-21] [akka.tcp://ClusterSystem@