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

14421 commits

This branch
This branch
All branches
Author SHA1 Message Date
Dale Wijnand
abdb9e1f2d Fix code example in TestKit docs. 2015-02-03 11:40:46 +00:00
Patrik Nordwall
953a316563 Merge pull request #16748 from hepin1989/fix-16667-master 
=clu #16667 fix Inconsistent message order in ClusterMessageSerializer &...
 2015-01-30 09:11:12 +01:00
Roland Kuhn
7083eb46c8 Merge pull request #16665 from akka/wip-akka-typed-∂π 
add akka-typed project with generic ActorRef
 2015-01-29 14:06:21 +01:00
Roland Kuhn
d9efd041f7 add akka-typed project with generic ActorRef 
This is the first step towards more type-safety in Actor interactions,
comprising:

* generic ActorRef[T] that only accepts T messages
* generic ActorSystem[T] extends ActorRef[T] (sending to the guardian,
  whose Props[T] are provided for ActorSystem construction)
* removed the Actor trait: everything in there has been made into
  messages and signals
* new Behavior[T] abstraction that consumes messages (of type T) or
  Signals (lifecycle hooks, Terminated, ReceiveTimeout, Failed),
  producing the next Behavior[T] as the result each time
* the ask pattern is provided and yields properly typed Futures
* variants of ActorContext are provided for synchronous testing of
  Behaviors

All of this is implemented without touching code outside akka-typed
(apart from making guardianProps configurable), creating wrapper objects
around ActorRef, ActorContext, ActorSystem, Props and providing an Actor
implementation that just runs a Behavior.
 2015-01-29 11:42:28 +01:00
hepin
8554b8a5ab =clu #16667 fix Inconsistent message order in ClusterMessageSerializer & MessageSerializer 2015-01-29 18:05:07 +08:00
Roland Kuhn
50d1569f37 Merge pull request #16634 from dimbleby/stable-priority-mailbox 
Introduce stable priority mailboxes.
 2015-01-28 15:10:24 +01:00
dch
8df81e6b72 Introduce stable priority mailboxes. 
Similar to existing priority mailboxes, but these preserve FIFO ordering
for messages of equal priority.
 2015-01-28 11:20:59 +00:00
Patrik Nordwall
0cea1a47ae Merge pull request #16731 from akka/wip-16653-netcat-TcpNoDelay-master-patriknw 
=act #16653 swallow exception from setTcpNoDelay (for validation)
 2015-01-28 11:08:47 +01:00
Patrik Nordwall
83d75528ee =act #16653 swallow exception from setTcpNoDelay 
* some versions of netcat (`nc -z`) doesn't allow setTcpNoDelay

(cherry picked from commit c4ca93eec652c31f48b7203999dc8b27c3ebc70a)

Conflicts:
	akka-actor/src/main/scala/akka/io/TcpConnection.scala
 2015-01-28 09:30:20 +01:00
Patrik Nordwall
73e315f8df Merge pull request #16711 from carrot-garden/persistence-protocol-traits-2 
+ akka-persistence: add internal message protocol traits
 2015-01-28 09:03:45 +01:00
Roland Kuhn
3fac74b81e Merge pull request #16662 from akka/wip-15865-getMDC-∂π 
=act #15865 add LogEvent.getMDC Java API
 2015-01-28 08:09:04 +01:00
Roland Kuhn
186a02f806 fix up java8 ActorDocTest compilation 2015-01-28 07:46:33 +01:00
Roland Kuhn
ed71c37318 Merge pull request #16668 from meln1k/wip-16614-include-best-practice-tip-on-messages-in-companion-object-in-docs-meln1k 
=doc #16614 Include best-practice tip on messages in companion object in docs
 2015-01-27 18:38:52 +01:00
Roland Kuhn
168cc74e8a =act #15865 add LogEvent.getMDC Java API 2015-01-27 18:34:07 +01:00
Andrei Pozolotin
98ac9f7020 + akka-persistence: add internal message protocol traits 
2 more snapshot messages used for internal plugin acknowledgement in
https://github.com/akka/akka/blob/master/akka-persistence/src/main/scala/akka/persistence/snapshot/SnapshotStore.scala
* see #16612 
* see #16633
 2015-01-27 10:04:11 -06:00
Roland Kuhn
9463c9ff6c Merge branch 'tmp' 2015-01-27 16:26:04 +01:00
Roland Kuhn
a18c1bbafb fix up wrong includecode comments in FaultHandlingDocSpec 2015-01-27 16:25:13 +01:00
Konrad Malawski
47d429adce Merge pull request #16707 from meln1k/wip-16706-wrong-reference–in-logging-docs-meln1k 
=doc #16706 fixed wrong link and minor style fixes
 2015-01-26 14:28:29 +01:00
Konrad Malawski
385373f23e Merge pull request #16705 from 2m/wip-samples-pr-validation 
=pro #16704 add validatePullRequest task to samples
 2015-01-26 14:28:08 +01:00
Nikita Melkozerov
a8632befc6 =doc #16614 Include best-practice tip on messages in companion object in docs 2015-01-23 22:40:55 +05:00
Patrik Nordwall
4437f775e5 Merge pull request #16679 from akka/wip-dry_run-patriknw 
=pro unset dry_run flag
 2015-01-23 12:12:47 +01:00
Martynas Mickevičius
d29c978871 =pro #16704 add validatePullRequest task to samples 
* move validatePullRequest to separate autoplugin
* move MiMa settings to separate autoplugin
 2015-01-22 20:26:34 +02:00
Nikita Melkozerov
d461675e6a =doc #16706 fixed wrong link and minor style fixes 2015-01-22 23:15:44 +05:00
Patrik Nordwall
0c42971758 Merge pull request #16700 from akka/wip-16684-scala-2.11.5-samples-patriknw 
=sam #16684 Change to scala 2.11.5 in samples
 2015-01-22 16:10:06 +01:00
Patrik Nordwall
83e7e716ba =sam #16703 temp remove osgiDiningHakkersSampleMavenTest from samples aggregate 2015-01-22 14:23:35 +01:00
Patrik Nordwall
08ffba6246 =sam #16684 Change to scala 2.11.5 in samples 2015-01-22 14:13:55 +01:00
Martynas Mickevičius
0b50d650f1 Merge pull request #16678 from etaty/patch-2 
=doc s/will always by/will always be/
 2015-01-21 12:28:27 +01:00
Valerian
5a9f623cb6 =doc s/will always by/will always be/ 2015-01-20 16:47:51 +01:00
Patrik Nordwall
7e2dfebf51 Merge pull request #16475 from carrot-garden/cluster-metrics-module 
+ akka-cluster-metrics: new akka module
 2015-01-20 09:36:23 +01:00
Andrei Pozolotin
7b9f77a073 + akka-cluster-metrics: new akka module 
* new akka module split from akka-cluster
* provide sigar provisioning
* fix ewma usage
* resolve #16121
* see #16354
 2015-01-19 10:23:54 -06:00
Patrik Nordwall
baca3644e2 Merge pull request #16677 from akka/wip-16624-cluster-unreachable-stalled-master-patriknw 
=clu #16624 Expand the monitored nodes when unreachable (for validation)
 2015-01-19 15:07:05 +01:00
Patrik Nordwall
31939046ed =pro unset dry_run flag 
* dry_run=false doesn't work for me
 2015-01-19 14:03:15 +01:00
Patrik Nordwall
bc87dcad78 =clu #16624 Expand the monitored nodes when unreachable 
* Otherwise the leader might stall (cannot remove downed nodes)
  if many nodes are shutdown at the same time and nobody in the
  remaining cluster is monitoring some of the shutdown nodes.

(cherry picked from commit 1354524c4fde6f40499833bdd4c0edd479e6f906)

Conflicts:
	akka-cluster/src/main/scala/akka/cluster/ClusterHeartbeat.scala
	project/AkkaBuild.scala
 2015-01-19 13:22:46 +01:00
Patrik Nordwall
dc0547dd73 Merge pull request #16676 from akka/wip-16623-sysmsg-ordering-master-patriknw 
=rem #16623: Fix concurrent reliable delivery actors (for validation)
 2015-01-19 13:20:40 +01:00
Patrik Nordwall
a1d7199a42 =rem #16623: Fix concurrent reliable delivery actors 
(cherry picked from commit 4f7c90660226b05edc3581454d18fd53a4762802)

Conflicts:
	project/AkkaBuild.scala
 2015-01-19 10:03:40 +01:00
Roland Kuhn
cedfaa35cc Merge pull request #16660 from akka/wip-16659-SnapshotHeader2.10-∂π 
=per #16659 fix deserialization of SnapshotHeader AND SWITCH TO Scala 2.11.4
 2015-01-16 14:35:17 +01:00
Roland Kuhn
93ef92bcfb =per #16659 fix deserialization of SnapshotHeader 
This needs to be done differently for Scala 2.10 and 2.11 since
scala.Option’s serialVersionUID changed between these series.
 2015-01-16 14:34:59 +01:00
Konrad Malawski
9dae14e1a5 Merge pull request #16649 from meln1k/wip-16630-add-actor-system-name-to-Slf4jLogger-context-meln1k 
+slf #16630 Add the actor system name to the Slf4jLogger context
 2015-01-16 10:34:09 +01:00
Roland Kuhn
a4a985035e Merge pull request #16575 from akka/wip-15864-remove-ømq-∂π 
-zer #15864 remove zeromq module
 2015-01-16 10:19:45 +01:00
Roland Kuhn
239619e68f -zer #15864 remove zeromq module 2015-01-15 20:19:35 +01:00
Roland Kuhn
f0be7f8a21 Merge pull request #16429 from hepin1989/master 
=rem #16428 optimize protobuf serializer for master
 2015-01-15 15:17:37 +01:00
Roland Kuhn
d400598037 Merge pull request #16645 from MQ-EL/master 
The size of ActorCell is not 64bytes
 2015-01-15 13:51:07 +01:00
Nikita Melkozerov
e49ea9b5e4 +slf #16630 Add the actor system name to the Slf4jLogger context 2015-01-14 20:17:46 +05:00
Konrad Malawski
0b632e6437 Merge pull request #16644 from tenorviol/master 
Minor cleanup of scala fsm example
 2015-01-14 09:44:53 +01:00
Patrik Nordwall
b457f6e5e0 Merge pull request #16633 from carrot-garden/persistence-protocol-traits 
+ akka-persistence: add internal message protocol traits, resolve #16612
 2015-01-14 08:14:51 +01:00
Chris Johnson
2d312f1a91 Super minor change to scala fsm example: added named boolean arg 2015-01-13 22:01:06 -08:00
qian miao
cd58afc7f0 The size of ActorCell is not 64bytes 
I measured ActorCell is 84bytes, 88bytes and 92bytes in 32/64-bit system
environment. So I changged the annotation of ActorCell.
 2015-01-14 13:07:28 +08:00
Andrei Pozolotin
4208aacd2c + akka-persistence: add internal message protocol traits 
* resolve #16612
 2015-01-13 12:40:40 -06:00
Konrad Malawski
e110cd1213 Merge pull request #16595 from Arneball/master-arneball-patch 
Rebased 16537 - Constant moved to val, will removed unneccesary allocation
 2015-01-13 17:23:34 +01:00
Konrad Malawski
3f64d9fc34 Merge pull request #16639 from ktoso/bump-genjavadoc 
=pro update genjavadoc version to enable crosspublishing
 2015-01-12 20:01:00 +01:00