Even with auto-down configuration disabled, same issue had occurred
recently in a three node cluster.
2019-04-04 22:44:33,205 | ult-dispatcher-3 | Remoting
| Tried to associate with unreachable remote address
[akka.tcp://opendaylight-cluster-data@x.x.x.155:2550]. Address
failure count in Closed is reset to 0 immediately when there is one
> successful call.
>
> /Patrik
>
>
>>
>> On Thu, Oct 1, 2015 at 11:28 AM, Sandeep Khurana > > wrote:
>>
>>> Hello All
>>>
>>> I am evaluating Akka to use in our e
Hello All
I am evaluating Akka to use in our enterprise application. One of the
feature which we are looking for is to find out if we can allow circuit
breaker to remain closed when the number of failures are less than certain
threshold within a time window.
For example,
If in 30 minutes nu
I want to just send a http request.
something like this
val response: Future[HttpResponse] =
(IO(Http) ? HttpRequest(GET,
Uri("http://google.com";))).mapTo[HttpResponse]
--
>> Read the docs: http://akka.io/docs/
>> Check the FAQ:
>> http://doc.akka.io/docs/
publish it to your local repo
>
> this works, I am currently doing the same
>
> Am Montag, 13. Januar 2014 15:01:01 UTC+1 schrieb Sandeep Singh:
>>
>> Tried but same error
>> "org.reactivemongo" %% "reactivemongo" % "0.10.0" excludeAll(
&g
Tried but same error
"org.reactivemongo" %% "reactivemongo" % "0.10.0" excludeAll(
ExclusionRule(organization = "com.typesafe"))
On Monday, January 13, 2014 7:19:53 PM UTC+5:30, Sandeep Singh wrote:
>
> Yupp saw that but can't change my versi
; https://github.com/ReactiveMongo/ReactiveMongo/blob/master/project/ReactiveMongo.scala#L124
>
> Cheers,
> √
>
>
> On Mon, Jan 13, 2014 at 2:11 PM, Sandeep Singh
>
> > wrote:
>
>> I'm using sbt,
>> Here's my build.sbt
>>
>> na
nt" % "1.3-M2",
"org.reactivemongo" %% "reactivemongo" % "0.10.0"
)
On Monday, January 13, 2014 5:29:49 PM UTC+5:30, √ wrote:
>
> Akka will never throw an AbstractMethodError, something is wrong with your
> classpath.
>
> Cheers,
> √
>
&g
My whole actor code
class Getter(url: String, depth: Int, id: ActorRef) extends Actor {
implicit val executor = context.dispatcher.asInstanceOf[Executor with
ExecutionContext]
def client: WebClient = AsyncWebClient
client get url pipeTo self
def receive = {
case body: String =>
I wrote this code this is a recieve function of an actor,
def receive = {
case body: String =>
import reactivemongo.api.MongoDriver
import reactivemongo.api.collections.default._
import reactivemongo.api._
import reactivemongo.bson._
import scala.concurrent.
Done :)
thanks Patrik,
had to change the tell message from
*workerRouter.tell( ConsistentHashableEnvelope(word, word), aggregator)*
to
*workerRouter.tell( word, aggregator)*
On Friday, January 10, 2014 4:40:52 PM UTC+5:30, Patrik Nordwall wrote:
>
>
>
>
> On Fri, Jan 10, 2014 at 11:38 AM, >wrot
I have tried running in typesafe activator the sample's from akka repo,
akka-sample-cluster-scala but the problem is that i don't understand how to
use the router stategy other than one's mentioned and how they'll affect
the code ? currently they are using consistent-hashing-group
On Friday, J
I want to use the cluster aware group router, working in a round robin
fashion.
I've read the documentation but still confused how to implement this.
The router just sends messages to a routee's and collects output from them,
thats it. The routee's are on different nodes(dynamic addition).
Than
Read the doc done :)
On Wednesday, January 8, 2014 10:49:03 AM UTC+5:30, san...@techaddict.me
wrote:
>
> I'm building a text processing application of distributed nature, What i
> want to do is when new jobs come they should be routed to Worker Actors(on
> multiple machines). I want to use the
I'm building a text processing application of distributed nature, What i
want to do is when new jobs come they should be routed to Worker Actors(on
multiple machines). I want to use the Group Routing, and want to register a
new Actor when its up(Cluster MemberUp) as a routee in the router config
ok i'll take a look at 2.3 persistance, i was using 2.2.
On Friday, December 20, 2013 5:43:53 PM UTC+5:30, Patrik Nordwall wrote:
>
> Hi,
>
>
> On Thu, Dec 19, 2013 at 9:43 PM, >wrote:
>
>> As i've read in akka there is no single point of failure. How can we
>> handle this situation,
>> I've few
As i've read in akka there is no single point of failure. How can we handle
this situation,
I've few nodes, one of them is the master node that assigns tasks to other
ones, What can be done if master node fails (automatically choose another
node as master)? How can we recover from such an failur
Thanks Patrik, Problem solved :)
On Thursday, December 19, 2013 1:02:49 PM UTC+5:30, Patrik Nordwall wrote:
>
>
>
>
> On Wed, Dec 18, 2013 at 8:49 PM, >wrote:
>
>> Ignore My previous post,
>>
>> Got it runMain runs a specific class. I wanted to know how to use
>> akka.Main concept with sbt ?
>>
>
Ignore My previous post,
Got it runMain runs a specific class. I wanted to know how to use akka.Main
concept with sbt ?
On Thursday, December 19, 2013 12:14:33 AM UTC+5:30, Patrik Nordwall wrote:
>
> I'm not sure how the linkchecker was started, but in the end you need a
> "static main method"
Sorry sbt runMain classname gives error,
[error] Not a valid command: runMain
[error] Expected whitespace character
[error] runMain
Whats the syntax, i cant find docs about using akka.main with sbt.
On Thursday, December 19, 2013 12:14:33 AM UTC+5:30, Patrik Nordwall wrote:
>
> I'm not sure
I was taking the Principles of reactive programming on Coursera. There was
and example in week 7 a linkchecker. In this example they are running a
Object Directly with a main function in it using Scala IDE (not sure
though). How can i mimic the same behaviour using plain sbt. If not is a
minimi
I understand but its a general question, There is no main function in the
any of the objects but the objects are running in eclipse is this a feature
of Scala IDE, if yes how can we do it using just sbt ? Thanks in Advance
On Tuesday, December 17, 2013 11:15:05 PM UTC+5:30, Patrik Nordwall wrot
I was trying to run the example without eclipse using sbt test and run
commands,
The sbt test command passed all the 4 test but,
run command gives me,
Running info.rkuhn.linkchecker.WebClientTest
Thats it, the program execution pauses here.
Help.
--
>> Read the docs: http://akka.i
23 matches
Mail list logo
