Commit graph

14160 commits

Author SHA1 Message Date
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
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
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
Konrad Malawski
9dae0ad525 Merge pull request #15602 from ktoso/github-tagging-impr-ktoso
!scr do not remove tags (github) that are not set on an issue
2014-07-30 14:19:43 +02:00
Konrad Malawski
21c6662769 Merge pull request #15369 from kjanosz/tail-chopping-router
+act #13004 Adding TailChopping router
2014-07-30 12:48:01 +02:00
Konrad 'ktoso' Malawski
e5b12b61cc !scr do not remove tags (github) that are not set on an issue
Since the updated github issues views, it shows all "removed tags",
events in the issue even if the removed tag was never set on the issue.
So this script would always show up as "removed validating,needs-attention"
Even if the issue never had the label needs-attention set to it,
which is confusing visually.

This change introduces that we only remove tags that actually are set on
the issue.
2014-07-30 11:48:38 +02:00
LeonardMeyer
92041b0995 =con #15600 Fix config in PeekMailboxSpec 2014-07-30 10:21:31 +02:00
Krzysztof Janosz
1658f96862 +act #13004 Adding TailChopping router 2014-07-29 20:27:03 +02:00
Ilya Epifanov
5954302658 +act #15502: Pluggable DNS resolution in akka-io 2014-07-29 00:12:58 +04:00
drewhk
b88c964bd4 Merge pull request #15573 from spray/w/fix-TCP-pull-mode
=act #15572 don't read recursively in pullMode when a complete buffer was read
2014-07-28 10:19:19 +02:00
Johannes Rudolph
1e0b61a160 =act #15572 don't read recursively in pullMode when a complete buffer was read 2014-07-24 11:02:08 +02:00
Martynas Mickevičius
bb56b88b9a Merge pull request #15568 from HawaiianSpork/socketOptionAfterConnect
!act #13490 Changed the callback to SocketOption to accept a channel instead of a Socket, this allows for using the nio features.
2014-07-24 11:24:47 +03:00
Konrad Malawski
69aa415f43 Merge pull request #15586 from ktoso/forward-port-test-hardedning-ktoso
For Validation, 3 test hardening commits from release-2.3
2014-07-23 17:06:53 +02:00
Konrad 'ktoso' Malawski
c76b8a0338 =con #15574 impr TimerBasedThrottlerSpec stability
* the lower bound was rather racy, depends on "where in it's Tick"
  time the throtteler currently was. In general the upper bound is also
  not exact, but "good enough" because the `.5` is an estimation of "the
  throtteler must finish it's previous tick, and then it sends the data"
2014-07-23 15:48:59 +02:00
Konrad 'ktoso' Malawski
ad2a800298 =per #15559 use the same config as all other peristence tests
* this includes the default expect timeout of 10s (instead of 3s)
2014-07-23 15:48:51 +02:00
Konrad 'ktoso' Malawski
ba3543b046 =per #15575 lessen timing issue in AtLeastOnce spec
* lower redelivery interval does not change semantics here (no one
  answers anyway), and lessens the changes to be "unlucky" with gc pauses
* was unable to reproduce error with snapshotting in 80 builds on
  jenkins. Brainstormed possible errors but not found yet..
2014-07-23 15:48:46 +02:00
Michael R. Maletich
a6d3704ef6 !act #13490 Changed the callback to SocketOption to accept a channel instead of a Socket, this allows for using the nio features.
For example in Java 7 you can now join a multicast group:

case class JoinGroup(group: InetAddress, networkInterface: NetworkInterface) extends SocketOption {

  override def afterConnect(c: DatagramChannel): Unit = {
    c.join(group, networkInterface)
  }
}

  IO(Udp) ! Udp.Bind(self, new InetSocketAddress(MulticastListener.port),
    options=List(ReuseAddress(true),
      JoinGroup(MulticastListener.group, MulticastListener.interf)))

Other minor changes:

 - changed all methods in SocketOption to take a Channel instead of a Socket.  The socket can be gotten from the Channel but not the reverse.
 - all methods that are called before the bind are now called beforeBind for consistency.
 - All network connections now call the beforeBind and afterConnect.
2014-07-22 20:22:53 -05:00
Konrad Malawski
cb05725c1e Merge pull request #15561 from ktoso/master
=act #13970 Send transistion on goto(CurrentState) in FSM
2014-07-19 14:57:17 +02:00
Łukasz Dubiel
2c88bb1169
=act #13970 Send transistion on goto(CurrentState) in FSM
When in `A`:
* `goto(A)` will trigger `onTransition(A -> A)`
* `stay()` will NOT trigger `onTransition`

Includes:
* migration guide
* docs updates
* test
2014-07-18 17:36:55 +02:00
Konrad Malawski
466c20e3cd Merge pull request #15553 from ktoso/port-volatileLogLevel-ktoso
=act #15488 add @volatile logLevel, and benchmark (for validation)
2014-07-17 17:20:41 +02:00
Konrad 'ktoso' Malawski
6a09d478de =act #15488 add @volatile logLevel, and benchmark
Summary:
* made `logLevel` @volatile
* Perf benchmark and results are attached.

Please review @viktorklang
2014-07-17 14:59:32 +02:00
Konrad Malawski
f0c9f68368 Merge pull request #15549 from ktoso/port-fix-java-persistence-link-ktoso
=doc #15543 java docs should link to java persistence (for Validation)
2014-07-16 19:22:59 +02:00
Konrad 'ktoso' Malawski
8fcac922b4 =doc #15543 link to persistence in java docs should point to java persistence 2014-07-16 16:37:59 +02:00
Konrad Malawski
b28b290fe3 Merge pull request #15481 from duarten/master
Removed guard around _logLevel
2014-07-16 11:34:09 +02:00
Konrad Malawski
975e5d1455 Merge pull request #15541 from ktoso/port-doc-typed-router-ktoso
+doc #15537 add Typed router pattern (for validation)
2014-07-15 12:07:34 +02:00
Konrad 'ktoso' Malawski
ba2411833a +doc #15537 add Typed router pattern
Conflicts:
	akka-docs/rst/scala/code/docs/persistence/PersistenceDocSpec.scala
2014-07-15 10:22:23 +02:00
Konrad Malawski
5c80e35fe7 Merge pull request #15527 from ktoso/port-persistence-tck-ktoso
+per #13815 akka-persistence-tck based on @krasserm's work
2014-07-14 21:11:21 +02:00