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

11845 commits

This branch
This branch
All branches
Author SHA1 Message Date
Endre Sándor Varga
4dcb38c758 Changed to enabled retry gate by default, when testtransport is used 2012-12-18 18:56:18 +01:00
Endre Sándor Varga
3bfef958d4 Reenabled ignored cluster tests 2012-12-18 16:08:22 +01:00
Endre Sándor Varga
748d10f1b3 Merged with master 2012-12-18 16:08:06 +01:00
Endre Sándor Varga
55be17419e Merge branch 'master' into wip-2053d-actorbased-remote-drewhk 
Conflicts:
	akka-docs/rst/java/code/docs/serialization/SerializationDocTestBase.java
	akka-docs/rst/scala/code/docs/serialization/SerializationDocSpec.scala
	akka-remote-tests/src/main/scala/akka/remote/testconductor/NetworkFailureInjector.scala
	akka-remote/src/main/scala/akka/remote/RemoteActorRefProvider.scala
 2012-12-18 15:15:01 +01:00
Viktor Klang (√)
dfc7e33ee1 Merge pull request #948 from ryanlecompte/master 
Minor scaladoc updates
 2012-12-18 05:40:19 -08:00
Viktor Klang (√)
31cd2b0ef7 Merge pull request #958 from akka/wip-2742-forwardport-master-√ 
#2742 - making reuseAddress default false on windows with option to tur...
 2012-12-18 05:32:27 -08:00
Endre Sándor Varga
4bd507646d Removed explicit usage of null as root cause for EndpointException 2012-12-18 14:30:05 +01:00
Endre Sándor Varga
4c7691fe40 Removed implicit conversions from ActorRef to AssociationEventListener and HandleEventListener 2012-12-18 14:30:04 +01:00
Endre Sándor Varga
752e43a0e7 Implemented strictly ordered shutdown between remoteDaemon and transport in RARP. 2012-12-18 14:30:03 +01:00
Endre Sándor Varga
7de56b406b Removed Await in creation of the manager actor of actor based transport adapters. 2012-12-18 14:30:02 +01:00
Endre Sándor Varga
b886fcd54c Added clarifications to driver-adapter stack building method 2012-12-18 14:29:25 +01:00
Endre Sándor Varga
eb3a0de01b Added flushing shutdown to Remoting 2012-12-18 14:29:21 +01:00
Endre Sándor Varga
ddcb2192eb Improved protocol driver stack initialization sequence 2012-12-18 14:28:50 +01:00
Endre Sándor Varga
8dc60cca4e - Added AddressUrlEncoder to centralize address string encoding at one place 
- Removed HasTransport trait from NettyHelpers
- Fixed unsafe initialization of boss and worker executors in netty driver when using an akka dispatcher
 2012-12-18 14:27:00 +01:00
Endre Sándor Varga
6bd64d55bd - Fixes in contrib and docs 
- Fixed getExternalAddressFor
 2012-12-18 14:26:55 +01:00
Endre Sándor Varga
f1177464ad Fixed handling of passive connections in the failureinjector and remoting 2012-12-18 14:26:54 +01:00
Endre Sándor Varga
a7b78bf78b Integration with the TestConductor 
- Removed old FailureInjector from TestConductor
- Fixed tests to work with the new remoting
- Plugged ThrottlerTransportAdapter into TestConductor
 2012-12-18 14:26:53 +01:00
Endre Sándor Varga
fbdd830a08 - Removed usage of nulls from Remoting 
- Eliminated dangerous closed-over states in Props usages
 2012-12-18 14:26:05 +01:00
Endre Sándor Varga
d46a4b6916 - Removed usage of null from Endpoint 
- Fixed race resolution logic in FailureDetectorRegistry to not create unnecessary instances
 2012-12-18 14:24:37 +01:00
Endre Sándor Varga
9f006789fc Made RemotingEvents sealed and final 2012-12-18 14:23:38 +01:00
Viktor Klang (√)
7abf15c45b Merge pull request #951 from akka/wip-2726-reliable-proxy-√ 
#2726 - removing a potential race between initializing the ReliableProx...
 2012-12-18 04:53:50 -08:00
Viktor Klang
6afed38d5d Adding migration docs for the Scheduler changes. 2012-12-18 13:50:20 +01:00
Viktor Klang (√)
27dec68f6c Merge pull request #949 from akka/wip-2722-ask-value-class-√ 
#2722 - Making AskableActorRef a value class (cannot be made an implici...
 2012-12-18 04:42:55 -08:00
Viktor Klang (√)
18508a19f7 Merge pull request #955 from akka/wip-2810-java-api-for-current-system-√ 
#2810 - Adding a Java API for JavaSerializer.currentSystem + added test...
 2012-12-18 04:41:38 -08:00
Viktor Klang (√)
0cefc9c602 Merge pull request #956 from akka/wip-2812-graceful-stop-timeout-√ 
#2812 - Fixing PatternSpec for gracefulStop by testing for juc.TimeoutE...
 2012-12-18 04:39:22 -08:00
Viktor Klang (√)
f0792459e5 Merge pull request #954 from akka/wip-2721-sender-in-scheduler-√ 
#2721 - Adding implicit sender to Scheduler + tests
 2012-12-18 04:36:58 -08:00
Viktor Klang
3ff997a3ca #2742 - making reuseAddress default false on windows with option to turn it on for everybody or off for everybody 2012-12-18 13:34:53 +01:00
Viktor Klang
00d8fc4851 #2812 - Fixing PatternSpec for gracefulStop by testing for juc.TimeoutException (common ancestor) 2012-12-18 11:16:41 +01:00
Viktor Klang
978c86339f #2721 - Adding implicit sender to Scheduler + tests 2012-12-18 10:25:48 +01:00
Viktor Klang
146834832d #2810 - Adding a Java API for JavaSerializer.currentSystem + added tests 2012-12-18 01:25:21 +01:00
Viktor Klang
ac67edc103 #2726 - removing a potential race between initializing the ReliableProxySpec 2012-12-17 17:37:34 +01:00
Viktor Klang
f9f2f156e8 #2722 - Making AskableActorRef a value class (cannot be made an implicit value class and retain correct behavior) 2012-12-17 16:14:07 +01:00
Roland Kuhn
68f72459a3 Merge pull request #946 from akka/wip-2807-akka-kernel-detection-∂π 
allow cross-versioned akka-kernel deps for dist task to work, see #2807
 2012-12-17 02:29:10 -08:00
Björn Antonsson
f6d90efa98 Merge pull request #909 from akka/wip-2692-cluster-membership-events-ban 
Change cluster MemberEvents to only be published on convergence. See #2692
 2012-12-17 02:26:51 -08:00
Ryan LeCompte
88e51baf74 more documentation fixes 2012-12-16 20:03:17 -08:00
Roland
837662ddf7 allow cross-versioned akka-kernel deps for dist task to work, see #2807 2012-12-15 14:41:31 +01:00
Viktor Klang (√)
cb7330f738 Merge pull request #943 from akka/wip-2799-master-√ 
#2799 - forwardporting the fix to allow null reponses to TypedActor cal...
 2012-12-15 00:56:42 -08:00
Viktor Klang
2fd422e3f4 #2799 - forwardporting the fix to allow null reponses to TypedActor calls 2012-12-14 23:50:23 +01:00
Viktor Klang (√)
13e571fdaf Merge pull request #945 from akka/wip-2674-√ 
#2673 + #2674 - Seq[Byte] becomes ByteString and Frame gets removed, lo...
 2012-12-14 10:48:54 -08:00
Viktor Klang
24566c167c #2673 + #2674 - Seq[Byte] becomes ByteString and Frame gets removed, lots of cleanup in ZMQ API 2012-12-14 18:25:04 +01:00
Viktor Klang (√)
5b477e99e7 Merge pull request #939 from akka/wip-2776-√ 
#2776 - deprecating and introducing alternatives for methods and parame...
 2012-12-14 09:16:35 -08:00
Sam Halliday
280e1aa21a java.util.logging backend for ActorLogging system, see #2805 
[RK: assembled commit log from original branch, squashed]
akka-contrib:
- an event handler which properly sets the ThreadID on log records
- a LoggingAdapter which does synchronous logging to j.u.l.Logger
- a small logging mixin for the aforementioned adapter
 2012-12-14 17:23:38 +01:00
Viktor Klang
d0717aaec6 #2776 - deprecating and introducing alternatives for methods and parameters ending with '_?' 2012-12-14 14:55:21 +01:00
Björn Antonsson
a03460329d Change cluster MemberEvents to only be published on convergence. See #2692 
Conflicts:
	akka-cluster/src/main/scala/akka/cluster/ClusterEvent.scala
	akka-cluster/src/main/scala/akka/cluster/ClusterJmx.scala
	akka-cluster/src/main/scala/akka/cluster/ClusterMetricsCollector.scala
	akka-cluster/src/main/scala/akka/cluster/ClusterReadView.scala
	akka-cluster/src/multi-jvm/scala/akka/cluster/MultiNodeClusterSpec.scala
	akka-docs/rst/cluster/cluster-usage-java.rst
	akka-docs/rst/cluster/cluster-usage-scala.rst
	akka-kernel/src/main/dist/bin/akka-cluster
 2012-12-14 12:46:13 +01:00
Patrik Nordwall
0c9ad2f791 Merge pull request #938 from akka/wip-2779-down-terminated-patriknw 
Publish AddressTerminated after a node is Down, not when unreachable, see #2779
 2012-12-14 01:38:25 -08:00
Patrik Nordwall
c325877c6a Merge pull request #936 from akka/wip-2306-min-nodes-startup-patriknw 
min-nr-of-members and registerOnMemberUp, see #2306
 2012-12-14 01:36:41 -08:00
Patrik Nordwall
44ab9f116f min-nr-of-members and registerOnMemberUp, see #2306 
* Leader moves joining members to up when min-nr-of-members reached
* Tested by MinMembersBeforeUpSpec
* Used in factorial sample
* Docs
 2012-12-12 14:00:06 +01:00
Patrik Nordwall
1cd3a05f41 Publish AddressTerminated after a member is Downed/Removed, see #2779 
* Instead of when unreachable

* Note that ClusterRouterConfig is not changed, i.e. routees will be removed
  when unreachable
* Routers that are not wrapped by ClusterRouterConfig will watch as usual, i.e.
  remove routees when Terminated, i.e. node down
 2012-12-12 12:55:22 +01:00
Roland Kuhn
761f1c6258 Merge pull request #929 from richdougherty/wip-2773-edit-migration-guide 
Add intro to migration guide and do a minor edit. Fixes #2773
 2012-12-10 05:09:52 -08:00
Raymond Roestenburg
5ad22c8e9c camel: ticket #2781 
ProducerSupport.transformOutgoingMessage was called from wrong context.
 2012-12-10 13:59:40 +01:00