Commit graph

21741 commits

Author SHA1 Message Date
Arnout Engelen
ab624c08c0 Update LevelDB (#23907)
The latest version can work with jdk9, previous versions
touched jdk.internal.ref.Cleaner which is no longer allowed
on jdk9.
2018-01-11 17:35:35 +01:00
Martynas Mickevičius
a3ae494325 #24104 Give a bit of time for consumers to register 2018-01-11 20:02:05 +09:00
Denys Zadorozhnyi
f1de21950d Adds stacktrace to the logged warning in onPersistRejected() (#24263)
Fixes #24133: Switch to log.error from log.warning and add a stacktrace in onPersistRejected()
2018-01-11 11:52:38 +01:00
Johan Andrén
7ce494b262 A bit more text about the clustered receptionist 2018-01-11 18:17:15 +09:00
Johan Andrén
f7b4a08308 Review updates and making the Receptionist API work from Java plus workaround for guardian start race 2018-01-11 18:17:15 +09:00
Johan Andrén
3a9facfe32 Review updates and making the Receptionist API work from Java 2018-01-11 18:17:15 +09:00
Christopher Batey
45c7303d3f Cluster typed examples in scala and java 2018-01-11 18:17:15 +09:00
Christopher Batey
f17dc5c7f7 Receptionist docs and examples 2018-01-11 18:17:15 +09:00
Konrad `ktoso` Malawski
cf455f3c11 Fix MiMa for Untangle settings from attributes in materializer #24063 2018-01-11 14:14:38 +09:00
Johan Andrén
4dde0742d0 Untangle settings from attributes in materializer #24063
Instead of renaming - deprecating and documenting

Renaming defaultInitialAttributes to defaultAttributes and adding docs

Tests passing

More work on using attributes for the attribute settings in ActorMaterializerSettings

Mark some attributes as mandatory and provide a smoother access w/o allocation for those

Another warning notice

MiMa filters

Part of the review adressed

Incorrect rebase fixed + formatting

Review feedback adressed

Formatting ...
2018-01-11 14:14:38 +09:00
Patrik Nordwall
4402c73a53
Merge pull request #24281 from akka/raboof-patch-1
Update sbt-paradox-akka
2018-01-10 17:01:05 +01:00
Arnout Engelen
f441d2e82a
Update sbt-paradox-akka
To the version with the fiddle encoding fix (and more)
2018-01-10 16:26:32 +01:00
Patrik Nordwall
ca945e2746
Merge pull request #24278 from akka/wip-24277-ClusterClientSpec-patriknw
harden ClusterClientSpec, #24277
2018-01-10 12:21:01 +01:00
Konrad `ktoso` Malawski
59a48c728b
+rem #24265 protobuf serializer for Address and UniqueAddress in akka… (#24267)
* +rem #24265 protobuf serializer for Address and UniqueAddress in akka-remote

* remove the duplication, by using previously existing type

* fixed doc link

* make it easier to enable the additional no-java-serialization bindings

* fixed akka-actor failure due to changes

* cleanup

* Update reference.conf

* Update serialization.md

* Update reference.conf
2018-01-10 19:28:51 +09:00
Patrik Nordwall
115f9b2a33 harden ClusterClientSpec, #24277 2018-01-10 10:48:55 +01:00
Konrad `ktoso` Malawski
eba7473199
=doc,per Include link to nice article about Events as First-Class Citizens (#24262)
* =doc,per Include link to nice article about Events as First-Class Citizens

* Move link up
2018-01-10 11:12:56 +09:00
Arnout Engelen
1f898ea491 Fix Java logging code example (#24275) 2018-01-10 11:09:54 +09:00
Patrik Nordwall
a1b61f15cb
Merge pull request #24209 from akka/wip-24191-sharding-opt2-patriknw
Reply to GetShardHome requests after rebalance, #24191
2018-01-09 20:53:30 +01:00
Patrik Nordwall
d30464c452 Reply to GetShardHome requests after rebalance, #24191
* Some GetShardHome requests were ignored (by design) during
  rebalance and they would be retried later.
* This optimization keeps tracks of such requests and reply
  to them immediately after rebalance has been completed and
  thereby the buffered messages in the region don't have to
  wait for next retry tick.
* use regionTerminationInProgress also during the update since
  all GetShardHome requests are not stashed
2018-01-09 20:12:45 +01:00
Johan Andrén
fc2413f29b
Version checking utility #24030 2018-01-09 20:11:14 +01:00
Patrik Nordwall
0eedd714e8 reply to known shard locations immediately when waitingForUpdate, #24064 2018-01-09 13:51:35 +01:00
Konrad `ktoso` Malawski
be7c05cad2
=tes #24270 expectNoMessage should pull the unexpected msg (#24271)
* =tes #24270 expectNoMessage should pull the unexpected msg from the queue

* Update TestKit.scala
2018-01-09 20:35:43 +09:00
fredfp
0bd408977b cluster client handover when receptionist's node leaves the cluster (#24167)
* Always add sender of GetContacts to client interactions

* Handover clients when receptionist leaves the cluster

* Revision based on code review

* Cluster receptionist only tracks connected clients
2018-01-09 10:41:33 +01:00
Nafer Sanabria
804dc4b6ba add flag crdt constants (#24208)
* add flag crdt constants

* add scaladoc
2018-01-09 10:39:06 +01:00
Rebecca Grenier
7c94bc7df4 Update tutorial_5.md (#24268)
plural noun doesn't need an apostrophe
2018-01-09 12:20:09 +09:00
Josep Prat
0796607aa4 =doc Fix dangling @@@ in howto docs #23516 (#24261)
Refs: #23516
Last Java pattern was shown for both Java and Scala.
2018-01-08 02:54:11 +01:00
kerr
dc20fc2f1e ! project upgrade to SBT 1.1.0 (#24257) 2018-01-06 09:44:38 +01:00
Heiko Seeberger
032f712301 Remove superfluous final modifier #19493 2018-01-05 09:58:07 +01:00
Christopher Batey
0380cc517a Cluster singleton manager: don't send member events to FSM during shutdown (#24236)
There exists a race where a cluter node that is being downed seens its
self as the oldest node (as it has had the other nodes removed) and it
takes over the singleton manager sending the real oldest node to go into
the End state meaning that cluster singletons never work again.

This fix simply prevents Member events being given to the Cluster
Manager FSM during a shut down, instread relying on SelfExiting.

This also hardens the test by not downing the node that the current
sharding coordinator is running on as well as fixing a bug in the
probes.
2018-01-05 09:47:43 +01:00
Philippus Baalman
1d14c387a0 Extend copyright into 2018 (#24246) 2018-01-05 09:25:34 +01:00
Christopher Batey
009214ae07
Update copyright to 2018 (#24241) 2018-01-04 17:26:29 +00:00
Christopher Batey
bd2a3de88a
Typed async testkit (#24203)
* Typed async testkit
* Pull out useful parts from internal TypedSpec into a public TestKit
* Port internal tests to use the external testkit
2018-01-04 15:09:38 +00:00
Christopher Batey
c7cbebb534 Fix record overflow race condition in flight recorder #21992
The flag used to show a record is dirty/commited was overwritten by the
last 4 bytes of the previous metadata. Most of the time this isn't
caught as the record is written fixed width and typically the last bytes
are 0s which is the same as the Commited flag. However under
concurrency this can overwrite the Dirty flag that is preventing
corruption.
2018-01-04 13:37:16 +01:00
Pritam Kadam
37f0da17b7 Allow member to leave a cluster via CoordinatedShutdown.run when MemberStatus is Joining/WeaklyUp/Up. (#24152) 2018-01-04 07:43:25 +00:00
Nafer Sanabria
1dffa344c4 Fail fast on empty string persistenceId in PersistentActor (#24239) 2018-01-03 22:22:44 +01:00
kerr
5a66976683 update java and scala doc to use the terminate method (#24233) 2018-01-03 14:18:06 +01:00
kerr
7943bd5f96 fix up AbstractActor's Java doc. (#24212) 2018-01-03 12:51:54 +01:00
Łukasz Drygała
0c0bf91661 rewrite FlatSpec tests using WordSpec #24186 2018-01-03 12:51:27 +01:00
Ayush Mishra
6d6e96179d Adding new book reference for Akka HTTP (#24218) 2018-01-03 12:47:11 +01:00
kerr
7edf3bfecf + actor #15446 add external predicate to ReceiveBuilder (#24221) 2018-01-03 10:23:31 +01:00
Sebastian Harko
9ccf71076a Docs: add dependency info in docs for akka test kit (#24232)
* add proper dependency in docs

* use new paradox syntax for dependencies

* Update testing.md
2018-01-03 10:07:37 +01:00
Manuel Bernhardt
86ab6cbadc Fixing small error in the ORMap documentation (#24227)
Previously `remove` and `delete` were duplicated
2018-01-02 17:17:04 +01:00
kerr
0f0ea65988 = paradox fix typo (#24207) 2017-12-26 16:25:31 +01:00
Nafer Sanabria
a2b3b836ab Upgrade to sbt 1.1.0-RC4 (#24206) 2017-12-25 14:30:04 +01:00
Christopher Batey
7aa831bc2f
Initial pass of typed testkits + documenation (#24187)
* Initial pass of typed testkits

Not expecting this to be the final API just want to get some
examples documented and internals hidden

Refs #23667 and #22764
2017-12-22 16:44:39 +00:00
Christopher Batey
2aab0762dd
Remove death watch and supervision mechanics (#24198)
These were missed in #24176

Also some removal of unused imports and a couple compiler warnings
2017-12-22 15:58:05 +00:00
Christopher Batey
bfbdf89776
Initial docs for typed persistence (#24197) 2017-12-22 13:43:36 +00:00
Patrik Nordwall
b395be2559 document rolling upgrade of serializers (#24200) 2017-12-22 09:06:51 +00:00
lorenzhawkes
124e6030d2 Use System.getProperty for ttl values found using legacy sun properties #24188 2017-12-21 19:48:34 +01:00
Christopher Batey
5f576a4bc5 Upgrade to SBT 1.1.0-RC2 (#24181)
This might be worth trying before the release as it contains a fix for
the NPE
2017-12-21 11:32:09 +01:00