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

14186 commits

This branch
This branch
All branches
Author SHA1 Message Date
Stanislav Savulchik
2d8cb3764e =act Fix tell method scaladoc 2014-08-25 14:05:52 +07:00
Konrad Malawski
17e27eed62 Merge pull request #15723 from savulchik/patch-2 
Improve formatting in scala actors.rst
 2014-08-22 15:13:25 +02:00
Stanislav Savulchik
c314f99481 =doc Improve formatting in scala actors.rst 2014-08-22 16:51:18 +07:00
Konrad Malawski
2a8d1c4727 Merge pull request #15713 from ktoso/port-fix-local-snapshotstore-recovery-ktoso 
=per #15671 fix local snapshot store picking up wrong file (Validation)
 2014-08-21 15:47:01 +02:00
Brendan Lawlor
f336b24830 =per #15671 fix local snapshot store picking up wrong file. 
Added spec test to cover fix for bug 15671

Replaced deprecated NamedProcessor with NamedPersistentActor. Cleaned up unused message handling. Typos and misspellings.
 2014-08-21 13:56:19 +02:00
Roland Kuhn
296f5a7cab Merge pull request #15503 from akka/wip-15501-add-bounded-nonblocking-mpmc-mailbox-√ 
+act - #15501 - Adding support for a Non-blocking, bounded, MPMC mailbox...
 2014-08-20 16:05:57 +02:00
Roland Kuhn
2efc846ea5 Merge pull request #15697 from fwbrasil/fix-typo 
fix typo 'inctance'
 2014-08-20 11:34:37 +02:00
Roland Kuhn
3d0cf9d602 Merge remote-tracking branch 'pr/15597' 2014-08-20 11:26:01 +02:00
Flavio W. Brasil
e3dd4de44e fix typo 'inctance' 2014-08-20 10:26:23 +02:00
Patrik Nordwall
7659f333cb Merge pull request #15658 from akka/wip-coroner-adjustment-patriknw 
=tes Increase coroner timeout for some tests
 2014-08-20 07:44:20 +02:00
Patrik Nordwall
c517de4f21 Merge pull request #15669 from akka/wip-15664-dist-filenames-patriknw 
=pro #15664 Use scala version in dist files
 2014-08-20 07:39:46 +02:00
Roland Kuhn
6de1043516 Merge pull request #15676 from benmccann/https-repos 
Security: use https to fetch repo artifacts in examples
 2014-08-19 16:41:13 +02:00
Ben McCann
36943a5444 Security: use https to fetch repo artifacts. See http://blog.ontoillogical.com/blog/2014/07/28/how-to-take-over-any-java-developer/ 2014-08-19 07:21:14 -07:00
Martynas Mickevičius
200d6eb0d3 Merge pull request #15627 from 2m/udp-proto-family 
!act #15626 expose DatagramChannel creation in SocketOption
 2014-08-19 15:25:51 +03:00
Dominic Black
af657880e2 !con #15496 Remember entries in cluster sharding 
- Move all entry related logic out of the ShardRegion and into a
  new dedicated child `Shard` actor.
- Shard actor persists entry started and passivated messages.
- Non passivated entries get restarted on termination.
- Shard Coordinator restarts shards on other regions upon region failure or handoff
- Ensures shard rebalance restarts shards.
- Shard buffers messages after an EntryStarted is received until state persisted
- Shard buffers messages (still) after a Passivate is received until state persisted
- Shard will retry persisting state until success
- Shard will restart entries automatically (after a backoff) if not passivated and remembering entries
- Added Entry path change to the migration docs
 2014-08-19 13:13:20 +01:00
Martynas Mickevicius
325e05ee27 !act #15626 expose DatagramChannel creation in DatagramChannelCreator 
* move channel creation logic to a separate trait
* new Java API: AbstractSocketOption
 2014-08-19 14:02:23 +03:00
Roland Kuhn
4ce7766164 Merge pull request #15596 from nitsanw/master 
Update AbstractNodeQueue.java to avoid redundant reads of head in peekNode
 2014-08-18 19:45:05 +02:00
Patrik Nordwall
c4ee032ead =pro #15664 Use scala version in dist files 2014-08-15 11:44:59 +02:00
Patrik Nordwall
e3ee59c94d Merge pull request #15662 from raboof/AtLeastOnceDeliveryDocs 
Improve docs for AtLeastOnceDelivery recovery
 2014-08-14 16:03:20 +02:00
Arnout Engelen
64c3cabbbc Improve docs for AtLeastOnceDelivery recovery 
The Eventsourced migration guide currently suggested AtLeastOnceDelivery is
less useful than it actually is :)
 2014-08-13 22:48:35 +02:00
Patrik Nordwall
416ed4c632 Merge pull request #15660 from akka/wip-15648-classpath-master-patriknw 
=15648 ker Use wildcard in microkernel classpath (for validation)
 2014-08-13 17:37:34 +02:00
Patrik Nordwall
450b5c2285 =15648 ker Use wildcard in microkernel classpath 
* scala-library.jar had changed name to scala-library-2.10.4.jar
* use wildcard to avoid same problem when scala-library version is changed
* the wilcard will only include jar files in the lib directory, and not the
  lib/akka directory, see 'Understanding class path wildcards'
  http://docs.oracle.com/javase/6/docs/technotes/tools/windows/classpath.html

(cherry picked from commit 996de05b44531bda517ef8ee274a34ad76e9716f)
 2014-08-13 17:36:33 +02:00
Roland Kuhn
8ac109dda0 =doc #15638 clarify message ordering rule 
add a missing reference to the fact that it only applies to messages sent directly
 2014-08-13 17:31:42 +02:00
Patrik Nordwall
a3e5d6b584 =tes Increase coroner timeout for some tests 2014-08-13 14:21:00 +02:00
Konrad Malawski
aa855aa0dd Merge pull request #15653 from akka/port-impr-efforts-to-in-order-during-replay-ALOD-ktoso 
=per #15590 Increase efforts to in-order on start of ALOD (for Validation)
 2014-08-12 12:46:04 +02:00
Patrik Nordwall
3373fe018b Merge pull request #15645 from jonas/actorref-java-example-typo 
=act Fix typo in ActorRef Java example
 2014-08-12 11:35:40 +02:00
Konrad 'ktoso' Malawski
fdb0d9ee3b =per #15590 Increase efforts to in-order on start of ALOD 
AtLeastOnceDelivery can delivery out-of-order, and that's OK.
Although, in the case of message replay followed by taking user land
commands which may trigger `deliver` calls, it is nicer to at least once
try to send the replayed but not confirmed deliveries *first*, before
sending the completely new deliveries.

This change acomplishes this by triggering redelivery explicitly when
recovery has finished, and setting the timestamps on these messages a
bit in the past, so they hit their redelivery deadline right away during
this recovery induced redelivery.

Resolves #15590
 2014-08-12 11:28:25 +02:00
Patrik Nordwall
be88399ad5 Merge pull request #15413 from akka/wip-11715-logging-filter-patriknw 
+act,slf #11715 Add configurable LoggingFilter
 2014-08-12 09:12:12 +02:00
Patrik Nordwall
d963f6e981 Merge pull request #15637 from akka/wip-15167-TestTimeSpec-patriknw 
=tes #15167 Harden TestTimeSpec
 2014-08-11 20:18:28 +02:00
Patrik Nordwall
813543e8f8 +act,slf #11715 Add configurable LoggingFilter 
* The filter is used by the LoggingAdapter before publishing
  to the event bus
* Slf4jLoggingFilter uses backend log level configuration
  (e.g. logback.xml)
 2014-08-11 20:08:44 +02:00
Jonas Fonseca
104a40035e =act Fix typo in ActorRef Java example 2014-08-09 08:51:57 -04:00
Nitsan Wakart
87aea390b1 Forgotten bracket 2014-08-08 15:34:30 +02:00
Nitsan Wakart
24ac90448d Doc stars err 2014-08-08 15:33:44 +02:00
Nitsan Wakart
a1311d4a93 Fixe documentation to state consumer only access is allowed to poll/peek/peekNode/pollNode 2014-08-08 15:27:12 +02:00
Nitsan Wakart
74d0f0cc6c Fix isEmpty() and count() 
isEmpty() need not rely on peek(which is intended for consumer use) and instead compare head to tail.
count() should stop counting at max int to avoid wrap.
 2014-08-08 15:17:36 +02:00
Viktor Klang
945fde4294 +act - #15501 - Adding support for a Non-blocking, bounded, MPMC mailbox called 'NonBlockingBoundedMailbox' 2014-08-08 14:20:39 +02:00
Roland Kuhn
51062ff494 Merge pull request #1869 from ktonga/wip-3737-interceptors-chain-for-receive-ktonga 
#3737 Interceptors chain for receive
 2014-08-08 09:52:00 +02:00
Patrik Nordwall
4e54672198 =tes #15167 Harden TestTimeSpec 2014-08-07 11:58:44 +02:00
Patrik Nordwall
6d44a80905 Merge pull request #15629 from akka/wip-15613-rename-DistributedPubSubMediatorSpec-patriknw 
=con #15613 Rename one of the DistributedPubSubMediatorSpec classes
 2014-08-07 11:14:58 +02:00
Gaston M. Tonietti
b92e0c99b4 +con #13737 Interceptors chain for Actors' bahavior. 
* Add new pattern to akka-contrib.
* Mixin ReceivePipeline trait into Actors that have to be intercepted.
 2014-08-06 15:50:59 -03:00
Konrad Malawski
072950da53 Merge pull request #15630 from savulchik/patch-1 
Fix typo in scala remoting.rst
 2014-08-06 12:52:37 +02:00
Stanislav Savulchik
f807d312f6 =doc Fix typo in scala remoting.rst 2014-08-06 15:38:52 +07:00
Patrik Nordwall
4c4b1a1d27 =con #15613 Rename one of the DistributedPubSubMediatorSpec classes 2014-08-06 10:12:12 +02:00
Konrad Malawski
2a252fa2fb Merge pull request #15624 from ktoso/docs-cluster-joining-ktoso 
=doc #15565 improved wording in cluster-usage docs
 2014-08-05 18:32:55 +02:00
Konrad 'ktoso' Malawski
9ae039c2cf =doc #15565 improved wording in cluster-usage docs 2014-08-05 16:30:55 +02:00
Konrad Malawski
575fa2c173 Merge pull request #15623 from ktoso/port-15616-master-ktoso 
=pro #15616 UTF-8 charset and exception with offending file (for Validation)
 2014-08-05 14:15:27 +02:00
Viktor Klang
6a96c88430 =pro #15616 UTF-8 charset and exception with offending file (for Validation) 2014-08-05 12:04:42 +02:00
Konrad Malawski
e380c30400 Add abbrev for project changes to CONTRIBUTING.md 
As noticed during https://github.com/akka/akka/pull/15617, we didn't hint people to use `=pro` when changing things in the project / build.
 2014-08-05 11:50:35 +02:00
Konrad Malawski
eb766d49f3 Merge pull request #15601 from LeonardMeyer/LMeyer-specfix-#15600 
=con #15600 Fix config in PeekMailboxSpec
 2014-08-04 15:44:55 +02:00
Martynas Mickevičius
9f1a4f8645 Merge pull request #15417 from hajile/master 
+act #15502: Pluggable DNS resolution in akka-io
 2014-08-02 20:20:05 +03:00