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

21453 commits

This branch
This branch
All branches
Author SHA1 Message Date
Johan Andrén
3ad2db52c4 Remove the JUnit test runner (#23784) 2017-10-15 18:01:54 +02:00
Christopher Batey
cd8ec9f981 Merge pull request #23768 from chbatey/artery-startup 
Block ActorSystem creation until Artery is bound
 2017-10-13 14:51:23 +01:00
Christopher Batey
53c07a4f10 Block ActorSystem creation until Artery is bound 2017-10-13 14:05:44 +01:00
Konrad `ktoso` Malawski
129f0c9ed5 Update community tag to help wanted (#23802) 
* Update community tag to help wanted

Because of github recommendation

* Update CONTRIBUTING.md
 2017-10-12 21:27:19 +09:00
Johan Andrén
4b654d637f Don't use TestActorRef for async testing #23445 2017-10-11 15:29:02 +02:00
Daniel Moss
ff5e768e16 Corrected link to docs sample #23759 (#23760) 2017-10-11 12:02:17 +02:00
Jimin Hsieh
c09474e54c =doc Full word "upstream" in docs (#23797) 2017-10-10 10:32:32 +09:00
Martynas Mickevičius
4d5528f474 Update Config to v1.3.2 (#23790) 2017-10-09 13:23:28 +02:00
Zahari Dichev
1266468184 Swap unit for Void so we dont get wrong type exceptions on JDK9 (#23794) 2017-10-07 11:05:31 -07:00
Patrik Nordwall
01cfa7e337 Merge pull request #23777 from akka/wip-23773-typed-sharding-persistence-patriknw 
Typed ClusterSharding must handle PersistentBehavior, #23773
 2017-10-06 16:45:45 +02:00
Martynas Mickevičius
d787912a8a Merge pull request #23764 from johanandren/wip-23724-interleave-flow-test-fail-johanandren 
Eager close tests for InterleaveSpec made deterministic
 2017-10-06 14:42:59 +03:00
Troxid
c4ebba77d7 Fix broken links in documentation, #23787 2017-10-06 10:51:26 +02:00
Arnout Engelen
b1df13d4d4 Update scalariform (#23778) (#23783) 2017-10-06 10:30:28 +02:00
David Gómez G
63ccdeec16 Update event-bus.md (#23786) 
Removed a duplicate sentence (comming from an automatic merge) at line 24 :"An event bus must define the following three type parameters:"
 2017-10-05 23:45:40 -07:00
Christopher Batey
3107ea342c Fix scala example in sharding doc (#23785) 2017-10-06 08:36:37 +02:00
Alexander Golubev
d706d5344b +str add java Compression.gzip and deflate (#23779) 2017-10-05 22:33:07 -07:00
Patrik Nordwall
ae0b9fe081 https for snapshot repo (#23780) 2017-10-04 09:29:29 -07:00
Johan Andrén
9e68d6e88f Fork tests #22979 2017-10-04 14:22:25 +02:00
Johan Andrén
b03b777040 Fail ignore sink matval on abrupt termination #23726 (#23728) 2017-10-04 09:29:19 +02:00
Aleksey Nikiforov
df77df4b02 SharedKillSwitch memory leak fix #23622 2017-10-04 09:02:16 +02:00
Johan Andrén
c581da4e98 Widen within spans downwards in PersistentFSMSpec (#23715) 
* Widen within spans downwards in PersistentFSMSpec #23691

* Adjust times instead
 2017-10-03 18:51:23 +02:00
Patrik Nordwall
2049d9630c Typed ClusterSharding must handle PersistentBehavior, #23773 
* becuase we use the `PropsAdapter` in sharding and the `PersistentBehavior` can't be wrapped.
 2017-10-03 15:29:09 +02:00
Johan Andrén
5dc376bdd7 Eager close tests for InterleaveSpec made deterministic #23724 2017-10-02 11:05:23 +02:00
novacekm
96ffced4dc = #23749 Fixes logging when serialization is not defined on NotSerializableException (#23750) 2017-09-29 11:09:57 +09:00
Johan Andrén
26e0a4f00b Clean up JVM shutdown hooks on actor system termination (#23514) 2017-09-28 13:03:48 +02:00
Patrik Nordwall
f85a124a17 Merge pull request #23563 from nick-nachos/wip-21677-leveldbJournalCompaction 
Added journal compaction behavior for LevelDB #21677
 2017-09-28 12:34:18 +02:00
Patrik Nordwall
60378954ee Merge pull request #23745 from akka/wip-multi-dc-doc-patriknw 
incorporate feedback on the multi-dc docs
 2017-09-28 11:30:27 +02:00
Patrik Nordwall
689920fefd incorporate feedback on the multi-dc docs 2017-09-28 10:56:32 +02:00
Johannes Rudolph
d2827ef982 =per #23739 deprecate State.using to deter Java users (#23740) 
`State.using` is a valid pattern in regular FSM. However, for persistent FSM
it makes no sense and is marked as `private[akka]`. The `private[akka]` modifier does
not translate into bytecode so that Java users won't see that it should not be used.

Deprecating it will allow us to remove it in the future.

Fixes #23739.
 2017-09-28 10:54:38 +09:00
Konrad `ktoso` Malawski
136ebcb67c =io #23404 stop using sun.net.InetAddressCachePolicy, JDK9 prep 2017-09-27 13:58:19 +02:00
Christopher Batey
6458fed725 Fix race in CircuitBreakerSpec #23413 (#23729) 
The successful Future could complete after one of the Failure futures as
they're all a call to Future.apply so scheduled on different threads.
 2017-09-27 15:33:37 +09:00
Konrad `ktoso` Malawski
40228e851d =doc #23421 move Kill docs around and fix snippet (#23429) 2017-09-27 15:32:01 +09:00
Patrik Nordwall
6498cc234d fix debug logging in Receptionist and TimerScheduler (#23725) 2017-09-27 15:16:01 +09:00
Patrik Nordwall
a10b00ed02 harden RestartSpec, less timing sensitive, #23593 (#23731) 2017-09-26 21:46:52 +09:00
Johan Andrén
af5f84ddac mockito version supporting jdk9 #23402 2017-09-26 08:51:53 +02:00
Christopher Batey
4a2b6b23e5 Remove structural type that relies on runtime type in sun.nio #23400, #23403 2017-09-26 08:43:52 +02:00
Patrik Nordwall
776191c31d Merge pull request #23595 from akka/wip-23585-multi-dc-restart-patriknw 
Verify removal and add of new node incarnation in multi-dc, #23585
 2017-09-25 17:58:48 +02:00
Patrik Nordwall
6085f78b72 Merge pull request #23617 from akka/wip-22156-lost-refuseUid-patriknw 
Keep the refuseUid in a better way, #22156
 2017-09-25 17:57:58 +02:00
Patrik Nordwall
5fc6d5a04a Verify removal and add of new node incarnation in multi-dc, #23585 
* MemberRemoved must be published before MemberUp, e.g. when restarted
  in other DC
* remove from failureDetector when receiving gossip with new member,
  not only new joining member

* increase timeout in MultiDcSingletonManagerSpec
 2017-09-25 16:47:06 +02:00
Kirill Yankov
dfd94d3aea New implementation of expectNoMsg in TestKit #23224 2017-09-25 16:37:47 +02:00
Patrik Nordwall
cd4ee59cc8 Add parameter eagerClose to Flow.interleave #22710 (#23718) 
* overloaded methods added for binary compatibility
* Doc improve: remove unnecessary example, reword eagerClose description
* Test eagerClose = true when other stream closed
 2017-09-25 23:26:54 +09:00
Patrik Nordwall
d660f8971e Keep the refuseUid in a better way, #22156 
* The scenario described in the issue can cause the quarantine marker to
  be lost when creating a new endpoint for that address. Then when later
  creating another endpoint from an inbound connection the uid is considered
  confirmed and Ack message is accepted, triggering the unexpected seq number
  issue.
* The refuseUid was kept in the endpoint policy markers, but that is just very
  complicated and as illustrated by this issue not always safe.
* Instead, keep the refuseUid separately so it's not lost when registering
  new endpoint.
* The purpose of WasGated was only to try to keep the refuseUid (as far as I know),
  and that is not needed any longer.

mima filter
 2017-09-25 16:25:09 +02:00
Guido Medina
9df5d80268 Java 9 Unsafe access to String value type mismatch. (#23710) 
It needs to account for both Java 8 and 9 where the types are char[] and byte[] respectively.
 2017-09-25 23:22:49 +09:00
gosubpl
9d7b81f11c fix issue with vvector handling in ORSet.mergeRemoveDelta #22890 2017-09-25 16:16:20 +02:00
Patrik Nordwall
12196d674e enforce same DC for isOlderThan, #23307 (#23625) 2017-09-25 11:50:28 +02:00
Christopher Batey
b43bdc49d8 Merge pull request #23713 from chbatey/docs-mjvm-link 
=doc Fix multi jvm sample link
 2017-09-25 10:21:19 +01:00
Rafał Sumisławski
d4c929d771 Make sending messages to dead letters by DistributedPubSubMediator configurable. #23462 (#23615) 2017-09-25 11:15:06 +02:00
Christopher Batey
d8cd40d250 =doc Fix multi jvm sample link 2017-09-25 09:46:25 +01:00
Christopher Batey
4669b4854d Fix minor docs typo (#23709) 2017-09-24 19:15:15 +02:00
Cause Chung
5892c2a569 Add more doc for framing on tcp streaming #23325 2017-09-23 12:09:05 +02:00