raboof/pekko
1
0
Fork 0
Code Issues Pull requests Projects Releases 6 Packages Wiki Activity Actions 10
21263 commits 1 branch 31 tags 268 MiB
Commit graph

21263 commits

This branch
This branch
All branches
Author SHA1 Message Date
Patrik Nordwall
da7fb98d86 Merge pull request #23522 from akka/wip-23485-throttle-send-patriknw 
clarify sender of throttle example, #23485
 2017-08-22 18:12:11 +02:00
Patrik Nordwall
3637340e11 clarify sender of throttle example, #23485 
* and use noSender in ActorRefSinkActor
 2017-08-22 16:04:01 +02:00
Patrik Nordwall
72b32547ba Merge pull request #23519 from akka/wip-23323-FlightRecorder-patriknw 
fix duplicated FlightRecorder event 91, #23323
 2017-08-22 15:54:14 +02:00
Patrik Nordwall
2b803562f0 avoid unique actor name issue in EndToEndEventAdapterSpec, #23483 (#23520) 
* the name of the actor is of no importance
 2017-08-22 14:09:45 +02:00
Alexander Golubev
1ba5b27158 =str add latch to ManualProbe to popagate events only when subscription is done (#23365) 2017-08-21 11:26:29 +02:00
SirMullich
769f9c09cf Update tutorial_5.md (#23550) 
`repliesSoFar` is implied here, not `answersSoFar` which is never used in tutorial
 2017-08-21 10:48:53 +02:00
Konrad `ktoso` Malawski
d07df2b917 =clt #23215 fail with nicer message if PubSubMediator gets null message (#23216) 
* =clt #23215 fail with nicer message if PubSubMediator gets null message

* Update DistributedPubSubMediator.scala
 2017-08-20 19:02:15 +02:00
Christopher Batey
bb106aa27e Fix docs typo (#23548) 2017-08-19 16:15:34 +02:00
Sebastian Harko
6f64ff5cba Docs: Persistence - add configuration example for eager init. of plugins (#23545) 2017-08-18 06:58:09 -07:00
Patrik Nordwall
54fcfaa882 Merge pull request #23515 from jlprat/fix-docs-tab-snippets 
=doc Fix wrong scala/java snippet directives #23513
 2017-08-18 14:40:47 +02:00
Patrik Nordwall
9c0039eacc Merge pull request #23521 from lucianenache/update-codahale-metrics-dependencies 
Updated codahale metrics dependencies to 3.2.4 #17515
 2017-08-18 14:31:01 +02:00
Patrik Nordwall
cdd2f75c31 Merge pull request #23534 from SirMullich/patch-1 
Update tutorial.md
 2017-08-18 14:29:24 +02:00
Patrik Nordwall
2f712cceeb Merge pull request #23523 from jlprat/fix-broken-link-actor-docs 
=doc Transform broken link to ActorNotFound to inline code #23517
 2017-08-18 14:27:27 +02:00
Arnout Engelen
2623820450 Update configuration to exclude akka-bench-jmh from whitesource (#23542) 
* Update configuration to exclude akka-bench-jmh from whitesource

Because we don't distribute that project

* Whitesource 'product' is always 'Lightbend Reactive Platform' again

* Ignore all unpublished subprojects from whitesource
 2017-08-18 13:49:40 +02:00
Andrea Peruffo
c2ff4f74fc removing ThreadLocalRandom import (#23540) 2017-08-17 21:32:40 +09:00
Arnout Engelen
3a3f13447a Add alsoTo to stages (#23537) 2017-08-17 19:09:18 +09:00
Atiq Sayyed
55f7bf43a2 Merged the document from java/stream/index and scala/strea/index (#23539) 2017-08-17 00:57:48 -07:00
Richard Imaoka
7eeb9b5210 Merge paradox/scala/camel.md and java/camel.md (#23456) 2017-08-16 07:49:10 -07:00
Arnout Engelen
4f0ff3ac13 Document rolling upgrades of clusters using ddata (#23372) 2017-08-16 04:54:10 -07:00
SirMullich
e2c3af14ac Update tutorial.md 
typo "temperaturs", fixed to "temperatures"
 2017-08-16 17:11:56 +06:00
Josep Prat
5ec1447de0 =doc Transform broken link to ActorNotFound to inline code #23517 
Refs: #23517
Broken link by mistake, should just be the class name surrounded by backticks
 2017-08-15 07:56:55 +02:00
Lucian Enache
6f3d83fd9a Updated codahale metrics dependencies to 3.2.4 #17515 2017-08-14 15:45:23 +02:00
Patrik Nordwall
3adcd6884a fix duplicated FlightRecorder event 91, #23323 
* I don't think the FlightRecorder is in much use yet so don't care about compatibility
  of reading old logs
 2017-08-14 11:51:05 +02:00
Josep Prat
5216c8b403 =doc Fix wrong scala/java snippet directives #23513 
Issue: #23513
Fix inline snippet in stream-io
Fix wrong rendering on other pages
 2017-08-11 19:23:11 +02:00
Patrik Nordwall
c1f247212f Merge pull request #23505 from akka/wip-dependencies-patriknw 
Upgrade camel-core dependency to 2.17.7
 2017-08-10 14:10:31 +02:00
Patrik Nordwall
7a6f4fbc3e Merge pull request #23476 from ktoso/wip-mdc-and-marker 
=slf show how one would use mdc and a marker in slf4j
 2017-08-10 10:07:40 +02:00
Patrik Nordwall
302c922a5b Merge pull request #23497 from akka/wip-rs-1.0.1 
Update to Reactive Streams 1.0.1
 2017-08-10 10:04:21 +02:00
Patrik Nordwall
9abe5ae092 Merge pull request #23473 from akka/wip-immutableintmap-√ 
Extensibility, performance, and documentation improvements to AffinityPool
 2017-08-10 08:36:17 +02:00
Patrik Nordwall
bf1167fe3b fix link labels in migration guide (#23491) 2017-08-10 13:44:29 +09:00
Viktor Klang
6f5a89d3d5 Modularizes the queue-selector in AffinityPool 2017-08-10 00:01:50 +02:00
Patrik Nordwall
38bc0e2b4a Merge pull request #23102 from akka/wip-21880-PartitionHub-patriknw 
Add PartitonHub, #21880
 2017-08-09 18:52:52 +02:00
Patrik Nordwall
b5c11f189f Better use of Artery lanes for ActorSelection, #23150 
* Looked into the alternativies described in the ticket, but
  they were complicated so ended up with simply including the
  uid of the sending system in the hash for selecting inbound
  lane. That should be good enough, until we have any real demand
  for something else.
* This means that different lanes can be used ActorSelection messages
  from different sending systems, i.e. good in a cluster, but same lane
  will be used for all messages originating from the same system.
* Added possibility to run the benchmarks with ActorSelection
* Added ActorSelection to the send consistency test
 2017-08-09 17:35:43 +02:00
Konrad `ktoso` Malawski
e3ec5563ac Update to Reactive Streams 1.0.1 2017-08-10 00:05:10 +09:00
Nicolas Vollmar
1c43059da9 Replay all events if snapshot is unhandled #23469 2017-08-09 17:03:27 +02:00
Patrik Nordwall
945ade245e Add PartitonHub, #21880 
* FixedSizePartitionHub in Artery
* expose consumer queue size
 2017-08-09 17:00:35 +02:00
Patrik Nordwall
3ba093d27e Merge pull request #23417 from francisdb/issue23416 
fix #23416 instantiate exceptions at right time
 2017-08-09 16:35:08 +02:00
Konrad `ktoso` Malawski
8cbc3b5570 +doc more details on akka.actor.Status support in ask (#23463) 2017-08-09 16:13:43 +02:00
Sébastien Lorion
a95a94acff Replace ClusterRouterGroup/Pool "use-role" with "use-role-set" #23496 2017-08-09 16:06:18 +02:00
kellen
5477a6f92d Correct location of implicits in comment #23492 2017-08-09 14:54:13 +02:00
Patrik Nordwall
87750496f8 disclaimer about security vs binary compatibility 2017-08-09 14:24:48 +02:00
Patrik Nordwall
f8fd3c6488 security announcement CVE-2017-5643 2017-08-09 13:54:32 +02:00
Thomas Szymanski
e079fe3991 Upgrade camel-core dependency to 2.17.7 
Upgrade camel-core dependency to a version that fixes CVE-2017-5643.
The 2.17 branch is also currently a supported version of Camel, which
2.13 is not.
 2017-08-09 12:14:44 +02:00
Johan Andrén
48144467aa =typ toTyped always returning the same adapter #23405 (#23441) 2017-08-09 14:13:57 +09:00
Patrik Nordwall
ad90e459f9 Merge pull request #23490 from akka/wip-17314-RemoteRestartedQuarantinedSpec-patriknw 
harden RemoteRestartedQuarantinedSpec, #17314
 2017-08-08 16:30:47 +02:00
Patrik Nordwall
537d2c96fe harden RemoteRestartedQuarantinedSpec, #17314 
* Seems like the initial message may be dropped in this case,
  we are at-most once after all. See detailed logs in issue.
 2017-08-08 14:31:33 +02:00
Gilad Hoch
0bcf32fccb =str #23398 groupedWeightedWithin zero cost bugfix (#23399) 
* added a failing test to demonstrate a bug in groupedWeightedWithin with zero cost function

* fixed the bug by adding a flag indicating if there are elements in buffer, and using it instead of totalWeight in case onTimer is called
 2017-08-08 13:30:32 +02:00
Jimin Hsieh
f623d10522 Rename addr to address in non-public API #21874 2017-08-08 13:18:56 +02:00
Nafer Sanabria
ad1ffeda2b throw java.io.NotSerializableException during deserialization (#22821) 
* throw java.io.NotSerializableException during deserialization

* formatting fix

* add annotation to all fromBinary methods

* remove annotation

* add annotation to remaining methods in Serialization.scala
 2017-08-08 13:15:18 +02:00
Patrik Nordwall
e4b8256009 Merge pull request #23387 from Hawstein/fix-max-park-nanos 
fix comments for maxParkNanos and spinning
 2017-08-08 13:12:30 +02:00
Sebastian Harko
74ddb49969 =doc fix issue with Graceful Stop (#23478) 
* distributed data is on by default

* clarify paragraph

* add missing space

* make sentence shorter

* fix grammar

* fix issue with graceful stop
 2017-08-07 17:57:43 +09:00