Commit graph

77 commits

Author SHA1 Message Date
Johan Andrén
f66ee1cbe8
Handle lost typed receptionist removals #24887
Keep track of removed actors and re-remove them when ORMultiMap conflict has reintroduced them
2018-11-09 10:58:18 +01:00
Patrik Nordwall
3ccc67b3d6
Merge pull request #25812 from akka/wip-25706-thenRun-patriknw
align Effect API between scaladsl and javadsl, #25706
2018-11-06 16:09:39 +01:00
Patrik Nordwall
a948f5572b align Effect API between scaladsl and javadsl, #25706
scaladsl:
* stop => stop()
* andThenStop() => thenStop()

javadsl:
* andThen => thenRun
2018-11-06 15:02:08 +01:00
Arnout Engelen
079aa46733 Introduce 'MemberDowned' member event (#25854)
* Introduce 'MemberDowned' member event

Compatiblity note: MemberEvent is a sealed trait, so it is debatable whether
it is acceptable to introduce a new member.

* Be more conservative (more like leaving), add test
2018-11-05 10:03:06 +00:00
kerr
fafc59b19d update headers to regular comment (#25807) 2018-10-29 05:19:37 -04:00
Patrik Nordwall
abb3429bc8
Merge pull request #25804 from akka/wip-25750-AbstractBehavior-patriknw
Rename MutableBehavior to AbstractBehavior, #25750
2018-10-18 13:16:48 +02:00
Patrik Nordwall
4131036a12
PersistenceId type to differentiate between persistenceId and entityId, #25703 (#25704)
* PersistenceId type to differentiate between persistenceId and entityId, #25703

* both entityId (for sharding) and persistenceId as String types was easy
  mix-up
* utility method in EntityTypeKey to concatenaty the type and entityId to
  a unique persistenceId

* support custom separator to enable compatilbility with Lagom's javadsl
2018-10-17 13:53:50 +02:00
Patrik Nordwall
ad3ad15747 Rename MutableBehavior to AbstractBehavior, #25750
* Also cleanup javadsl Receive, which is only used from AbstractBehavior
* Clarify further in docs that the functional vs OO style is a matter of taste
2018-10-17 08:53:37 +02:00
Patrik Nordwall
d71ba251ed make java sample code independent of Scala (#25800)
* need this for gathering and compiling java sources (in IDE),
  https://github.com/patriknw/akka-compile-ide-java
2018-10-16 13:52:54 +01:00
Johan Andrén
b0de255d27 Docs for typed distributed data (#25747)
* Typed distributed data docs shaping up
2018-10-12 08:14:01 +01:00
Patrik Nordwall
d9af08757e rename PersistentBehaviors.receive to PersistentBehavior.apply 2018-10-09 13:47:22 +02:00
Christopher Batey
2045a0fbf7 Clarify supervision of singleton actors (#25681)
* Clarify supervision of singleton actors
* Document supervision for typed singletons
2018-10-08 14:42:18 +02:00
Arnout Engelen
e822b69f82 Specify the artery port '0' to avoid address already in use 2018-10-02 15:30:41 +02:00
Patrik Nordwall
6d8d646fe5
Merge pull request #25539 from akka/wip-25480-sharding-start-patriknw
Simplify signature of ClusterSharding.spawn, #25480
2018-09-21 14:21:33 +02:00
Johan Andrén
a8cfe1e0ff
Merge pull request #25654 from johanandren/wip-25620-remove-typed-persistence-ctx-param-johanandren
Remove the ActorContext parameter from the scaladsl command handler
2018-09-21 13:51:09 +02:00
Johan Andrén
10fc413238 Some usages of the removed signatures 2018-09-21 10:34:41 +02:00
Patrik Nordwall
0804daf1a5 Simplify signature of ClusterSharding.spawn, #25480 2018-09-20 11:11:33 +02:00
Patrik Nordwall
0f56a6d1ed Passivate for Typed Sharding, #24478
* also moved singleton doc sample to own file
* and mv /doc/ to /docs/ as in other places
2018-09-20 11:04:32 +02:00
Christopher Batey
1d0603dab9 make scalatest suite type agnostic 2018-09-17 17:54:54 +02:00
Patrik Nordwall
b16e4d5e4d ActorTestKit overhaul, #24598
* composition is the basic building block for ActorTestKit
* ActorTestKitWordSpec for integration with ScalaTest
  (automatic shutdown)

* Use ActorTestKitWordSpec in our own tests

* doc TestException
2018-09-17 17:00:15 +02:00
Patrik Nordwall
5371aa17e4 cleanup some systemActor stuff (#25606)
* remove the ActorRef.apply(Future) since that is uncertain, see ticket #25305
2018-09-14 14:18:47 +01:00
Johan Andrén
26d251c917
Use multiple ddata keys for the typed receptionist service registry #23704 2018-07-11 11:36:00 +02:00
Patrik Nordwall
d5d908e1eb
Merge pull request #25290 from chbatey/issue-25288
Cluster sharding: Set waiting for state timeout for tests
2018-07-02 20:23:20 +02:00
Johan Andrén
75f044a0d0 Don't trigger graceful leave #24728 2018-07-02 15:57:36 +02:00
Christopher Batey
ee7e699d23 Cluster sharding: Set waiting for state timeout for tests
Default is 5s which means if the first Read is lost and
a test ddata have any secondary nodes to query it'll
timeout waiting to get the state.

E.g. read being ignored due to loading durable state then
never gets retries
2018-07-02 12:50:29 +01:00
Richard Imaoka
84d53d1ad1 Persistence: replace initialState with emptyState (#25129) 2018-05-25 14:29:22 +02:00
Patrik Nordwall
f750f73e1f define interfaces for all Typed extensions, #24776 2018-05-22 09:23:50 +03:00
Richard Imaoka
6ec46e762f Add example for Java typed serialization (#25007)
* Add example for Java typed serialization (#24993)
2018-05-21 15:30:44 +01:00
Patrik Nordwall
b08d3acb4b Rename Typed TestKit, #25084
Artifact:
akka-testkit-typed -> akka-actor-testkit-typed

Package:
akka.testkit.typed -> akka.actor.testkit.typed

Config:
akka.typed -> akka.actor.typed
akka.testkit.typed -> akka.actor.testkit.typed
2018-05-21 11:51:51 +02:00
jorgesg1986
1b83e339f4 Removed not used UntypedPropsBehavior (#25054)
Removed unnecessary pattern matching
2018-05-07 11:15:52 +09:00
Patrik Nordwall
74eb7999d8
Merge pull request #24958 from akka/wip-typed-extension-setup-patriknw
Possibility to replace Typed extensions via ActorSystemSetup, #24954
2018-05-03 11:04:32 +02:00
Christopher Batey
188b74a013 Remove application.conf from typed test projects (#25015)
It breaks assembly for multi-jvm jobs. Only needs to be in
the tests project.
2018-04-30 10:58:35 +02:00
Christopher Batey
23373565db
Fix typed cluster singleton cross dc proxies (#24936)
* Fix typed cluster singleton cross dc proxies
* Adds first multi-jvm test for typed cluster
2018-04-27 12:44:44 +01:00
Patrik Nordwall
fad74150ee
Merge pull request #24963 from chbatey/reduce-jenkins-logs
Reduce size of jenkins logs
2018-04-24 14:19:09 +02:00
Christopher Batey
4d20b2a660 Reduce size of jenkins logs
Each build is now over 40mb logs.

A lot of DEBUG logging was left on for test failures that have been
fixed. Added an issue # for ones that are still valid or if if it on
as the test verifies debug
2018-04-24 08:49:41 +01:00
Christopher Batey
b6a27deaea Fix snippets in typed cluster docs 2018-04-24 01:38:53 +09:00
Patrik Nordwall
d2b14f5c9c Possibility to replace Typed extensions via ActorSystemSetup, #24954 2018-04-23 14:58:07 +02:00
Johan Andrén
093f0ef14b Cluster receptionist and new reincarnation of node, #23683
* Drop anonymous functions/classes when creating testkit system name.
* Reproducer
* Added custom serializer
2018-04-12 19:00:58 +02:00
Patrik Nordwall
896aa7e33b use java.time.Duration in Typed javadsl, #24646 (#24804) 2018-04-02 08:30:49 +01:00
Johan Andrén
9ac83812ae More generous timeout in typed ClusterApiSpec (#24797)
* More generous timeout

* ActorTestKit.shutdown
2018-03-28 01:18:43 +09:00
Jimin Hsieh
3685ce619e Remove some of Unused import warning (#24750)
* Remove `Unused import` of `akka-actor-typed`

* Remove `Unused import` of `akka-actor-typed-tests`

* Remove `Unused import` of `akka-stream-tests`

* Remove `Unused import` of `akka-persistence`

* Remove `Unused import` of `akka-persistence-typed`

* Remove `Unused import` of `akka-cluster-typed`

* Remove `Unused import` of `akka-cluster-sharding-typed`

* Format source code
2018-03-20 12:01:15 +09:00
Konrad `ktoso` Malawski
b3fbf6869b
=typ #24683 Behaviors receive, receiveMessage, receivePartial, receiveMessagePartial (#24718)
* wip

* =typ #24683 Behaviors receive, receiveMessage, receivePartial,
receiveMessagePartial

* move MutableBehavior out as separate file

* receive, receiveSignal

* missing copy

* final cleanup

* cleanup, formatting
2018-03-20 00:20:13 +09:00
Johan Andrén
38c0bbef7c
Split up receptionist implementations #24615 2018-03-15 12:16:04 +01:00
Konrad `ktoso` Malawski
563c7fbcf0 Issue 24594: Integration with sbt-headers and initial header population 2018-03-13 15:45:55 +01:00
Konrad Malawski
70e225b734 =per native typed implementation of Eventsourced=>PersistendBehavior
timeout is explicitly a message of Command

persitAll and chainable side effects work well

more tests pasing

additional sanity check that mutable behaviors work as expected

unstashing needs to "loop through" the AdapterActor otherwise Stopped
won't work

solve unstashing/stop issue, by not randomly init()ing, but unstashing

snapshotting works

all tests green

rebased

nicer log source

remove IncomingCommand wrapper, we dont need it

no need for shared counter

remove not needed methods and state

more state cleanup, using Behaviors.same

reminder that we DO need that same alias, since stash does not work with
the Behavior.same

introduce config for stash buffer

stopping now works after persisting

compile fix

cleanup

reduced number of adapter styles needed for co-existence of persistence

final cleanup done, less passing around 40 objects, carriers provided
now
2018-03-13 00:40:13 +09:00
Patrik Nordwall
7d67524bb5 lazy init of SerializationExtension in Artery, #24620 (#24667)
to avoid loading serializers before ActorRefProvider has been initialized
2018-03-09 16:59:33 +09:00
Johan Andrén
14773ad2d4 Receptionist message improvements, #24511 and #24492 2018-02-22 12:58:28 +01:00
Patrik Nordwall
c5de70db10
Merge pull request #24589 from akka/wip-23683-prune-receptionist-patriknw
prune entries in ClusterReceptionist from nodes that have been removed, #23683
2018-02-22 12:38:43 +01:00
Johan Andrén
ede094a2c6 Typed Java testkit, #24551
* Java specific testkit
* Separate all the APIs
* Dilate the default timeouts
* TestKit -> ActorTestKit to be consistent with BehaviorTestKit
* Only have stuff in packages expected for this module
* Auto testkit-system-naming that works (verified)
* Separate actually working apis for manual timer
* More docs
* Separate apis for BehaviorTestKit effects
* Moved the example tests into the testkit, added samples for JUnit/ScalaTest
* TestKitJunitResource: No need to explicitly provide class, also overload for just custom config
2018-02-22 12:25:04 +01:00
Patrik Nordwall
cec2659440 prune entries in ClusterReceptionist from nodes that have been removed, #23683 2018-02-22 08:09:40 +01:00