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

21476 commits

This branch
This branch
All branches
Author SHA1 Message Date
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
Sebastian Harko
efb91ff8c8 Docs: Cluster Usage (#23479) 
* distributed data is on by default

* clarify paragraph

* add missing space

* make sentence shorter

* fix grammar

* akka cluster docs: add gradle, rename java / scala to maven / sbt
 2017-08-07 17:56:40 +09:00
Konrad `ktoso` Malawski
e516436be1
=slf show how one would use mdc and a marker in slf4j 2017-08-07 11:44:10 +09:00
Christopher Batey
83533e9c30 Fix docs typo (#23474) 2017-08-05 15:00:09 +09:00
Viktor Klang
4bf3238b3e ImmutableIntMap optimizations 2017-08-03 23:29:48 +02:00
Manu Zhang
5be1a527b1 Fix #23385, Update ExtendedActorMaterializer doc (#23431) 2017-08-02 10:53:14 +02:00
Sjoerd Mulder
2b1d964f14 =build Fixing sbt deprecation warning (#23454) 
warning: `<<=` operator is deprecated. Use `key := { x.value }`
See http://www.scala-sbt.org/0.13/docs/Migrating-from-sbt-012x.html
 2017-08-02 15:21:15 +09:00
Konrad `ktoso` Malawski
6be0c4c55f =act #23458 cross link Patterns java APIs (#23459) 2017-08-02 14:33:47 +09:00
Nafer Sanabria
dc038c69f3 Merge content of stream graphs.md (#23455) 2017-07-31 11:38:05 -07:00
Sebastian Harko
bdf8cd42e6 =doc Akka Persistence: sbt/Maven instead of Scala/Java (#23450) 
* distributed data is on by default

* clarify paragraph

* add missing space

* make sentence shorter

* fix grammar

* sbt instead of Scala and Maven instead of Java

* add gradle

* substitute scala akka versions

* fix TCK section

* fix version

* =doc clarify there is no language specific dependency
 2017-07-31 18:02:51 +09:00
Nafer Sanabria
2d42fedb9a =str update reference FlowMaterializer to ActorMaterializer (#23457) 2017-07-31 16:06:29 +09:00
Josep Prat
3b01e08904 Typed test kit improvements #23360 
* Call right overloaded super method in spawn and spawnAnonymous (avoiding infinite recursion)
* Add Effects for each type of Spawning
 2017-07-28 09:53:37 +02:00
Sebastian Harko
cc11ed40b5 Persistence: Reference.conf : remove refs to persistent view (#23451) 2017-07-28 09:15:36 +02:00
Martynas Mickevičius
423f6d0094 Update CONTRIBUTING.md regarding MiMa issue filters (#23448) 2017-07-27 14:38:26 +02:00
Martynas Mickevičius
bc0f2ee26d Load MiMa filters from file (#23083) 2017-07-27 12:33:14 +02:00
Sebastian Harko
227950e631 Docs: Persistence: Fix Layout Issue (#23446) 2017-07-27 01:52:52 -07:00
Jimin Hsieh
8e4e9c0e07 Fix broken link. (#23447) 2017-07-27 01:50:47 -07:00
Alexander Golubev
d004a32206 =str add Input/OutputStream mapMaterialized value warning in doc (#23424) 2017-07-27 01:48:34 -07:00
Sebastian Harko
3bad6da9a8 Docs: Persistence: Fix note about sharding and snapshots (#23444) 2017-07-27 10:20:47 +02:00
Ryan Brideau
cce775380d Cleaned up the comments and fixed typo (#23418) 2017-07-26 18:15:42 +02:00
Sebastian Harko
3b4ca5fbf7 Docs: Akka Persistence: Better intro for snapshots (#23430) 2017-07-26 17:02:37 +02:00
Johan Andrén
407131cb4e Stream supervision doc clarification #23376 2017-07-26 16:23:46 +02:00
Johannes Rudolph
8eabc685dc =act #23437 wake up SelectionHandler every 10 seconds to prune stale selection keys 2017-07-26 15:52:48 +02:00
Jan Ypma
7b7749cd7b Fix #23165: Update StreamConverters.fromInputStream docs to reflect reality 2017-07-26 12:08:17 +02:00