Commit graph

1043 commits

Author SHA1 Message Date
Patrik Nordwall
13974c7358 Merge pull request #21503 from jgordijn/wip-fix-typo-in-dd-doc
doc - Change WeaklyUp is used in DD #21502
2016-09-30 14:25:44 +02:00
drewhk
bfc9da4b2a Merge pull request #21599 from drewhk/wip-21209-afr-docs-drewhk
#21209: Added docs for AFR
2016-09-30 12:50:02 +02:00
Endre Sándor Varga
99363cce45 #21209: Added docs for AFR 2016-09-30 12:49:28 +02:00
Patrik Nordwall
768ca37d53 Merge pull request #21600 from akka/wip-21209-artery-docs2-patriknw
docs for media driver, #21209
2016-09-30 12:45:44 +02:00
Patrik Nordwall
261288c7db docs for media driver, #21209 2016-09-30 12:13:28 +02:00
Patrik Nordwall
f8c68a9534 remove docs about pluggable transports from old docs, #21209 2016-09-30 12:13:08 +02:00
drewhk
9e1ed4c7fb Merge pull request #21591 from drewhk/wip-21209-artery-docs-additions-drewhk
#21209: Added docs for cpu-idle and large messages
2016-09-30 11:16:02 +02:00
Endre Sándor Varga
4112206974 #21209: Added docs for cpu-idle and large messages 2016-09-30 11:10:56 +02:00
Patrik Nordwall
a28e21e99d Merge pull request #21593 from akka/wip-artery-docs-patriknw
Artery docs for Quarantine
2016-09-30 11:04:45 +02:00
Patrik Nordwall
ce33fec7e1 Artery docs for Quarantine, #21209 2016-09-30 11:03:43 +02:00
Roland Kuhn
bf928af092 remove Props in akka-typed
The deployment configuration is realized as an internally linked list,
which makes it allocation-free in the common case but retains full
extensibility.
2016-09-30 07:47:50 +02:00
Patrik Nordwall
577f43233a Merge pull request #21587 from akka/wip-merge-to-master-patriknw
Merge Artery into master
2016-09-29 15:45:27 +02:00
drewhk
a0f2120e8b Merge pull request #21588 from drewhk/wip-21209-artery-docs-skeleton2-drewhk
#21209: Skeleton for Artery docs
2016-09-29 15:08:09 +02:00
Endre Sándor Varga
496297c52f #21209: Skeleton for Artery docs 2016-09-29 14:58:42 +02:00
Patrik Nordwall
54f5b836fc Merge branch 'master' into wip-merge-to-master-patriknw 2016-09-29 13:56:37 +02:00
Patrik Nordwall
ddb2b5cd28 fix typo in futures.rst (#21536) 2016-09-23 18:20:28 +02:00
Jeroen Gordijn
a18b59f0dc Change doc: reflect WeaklyUp is used in DD #21502 2016-09-22 09:53:14 +02:00
Nafer Sanabria
94d7237d17 +str add zipWithIndex to FlowOps #21290 2016-09-21 08:41:56 +02:00
Richard Imaoka
98bfbbb4b3 Add documentation for ReplayFilter #20301 2016-09-12 16:18:06 +02:00
Patrik Nordwall
e8ce261faf Merge branch 'master' into wip-sync-2.4.10-patriknw 2016-09-09 14:12:16 +02:00
Roland Kuhn
320271cc31 new implementation for Akka Typed #21131
This is the first step towards a completely new and optimized actor
implementation for Akka Typed. The full previously existing test suite
passes for both implementations. The following is an incomplete list of
things that remain to be done:

* document the semantic differences between untyped and typed, in
  particular around actor restarts and the delivery ordering guarantees
  for Terminated messages (also document the difference between
  ActorSystemImpl and ActorSystemAdapter)
* implement EventStream and logging—this currently just delegates to an
  extra untyped ActorSystem (of course To Be Fixed)
* implement dispatcher selection
* implement and test queue size limitation
* implement optimized message queue instead of CLQ (for zero-allocation
  messaging)
* clean up test log output (something does not work with TestEventListener
  and EventFilter for ActorSystemImpl tests)
* document the capabilities (or more appropriately: the limitations) of
  interoperability between ActorSystemImpl and ActorSystemAdapter
* fix ActorPath UID generation (i.e. make sure that everything gets a
  meaningful value instead of zero)
* re-evaluate throughput/rescheduling logic in ActorCell

Oh, and by the way: as per PerformanceSpec (doing simple ping-pong) the
new implementation is ca. 30% faster than the adapter over akka-actor
:-)
2016-09-08 10:10:35 +02:00
Richard S. Imaoka
e35c8b0d31 Comment on persistenceId uniqueness (#21060) 2016-09-06 14:20:48 +09:00
Patrik Nordwall
0a75f992e4 Update links to Lightbend RPv2, more warnings about auto-down 2016-09-02 10:26:47 +02:00
Jan Ypma
09f2d83e69 +tes #21198 Allow TestActor/TestKit/TestProbe to create child actors
This is useful in at least two scenarios:
- Unit testing actors that communicate to their parent directly
- Testing re-creating (typically persistent) actors with the same name
2016-09-01 11:38:07 +02:00
drewhk
4821fb158e #20904: Increase timeouts in TestKitDoc tests, use Sink.seq (#21260) 2016-08-31 17:20:05 +01:00
Konrad Malawski
b1d07498e2 =htp fix for infinite timeout disabling timeout infrastructure (#20817) (#21295)
* fix for infinite timeout disabling timeout infrastructure (#20817)

* filtering out timeout-access header in tests where necessary (#20817)

* filtering out timeout-access header in additional tests (#20817)

* added DummyCancellable object to avoid allocation (#20817)

* added test showing that timeout is correctly reset for both infinite as well as finite initial request-timeout (#20817)
2016-08-31 09:49:41 +01:00
Patrik Nordwall
90cce8579a Merge branch 'master' into wip-sync-artery-dev-patriknw 2016-08-31 08:59:49 +02:00
gosubpl
7d7a5e51da added test showing that timeout is correctly reset for both infinite as well as finite initial request-timeout (#20817) 2016-08-30 22:18:26 +02:00
Johan Andrén
012919fdb3 OrElse stage for fallback when no elements emitted #21024 2016-08-30 13:35:59 +02:00
dyk
0e302d2236 =htp Extract RemoteAddress.Unknown when cannot find client ip (#21289)
* handle unknown client ip

* updated doc

* fixed java dsl test
2016-08-26 15:47:36 +01:00
gosubpl
fcc1d12879 fix for infinite timeout disabling timeout infrastructure (#20817) 2016-08-25 23:32:14 +02:00
Jamie Longmuir
440848c741 Add warning to Akka DD docs about freq add/deletes of top-level entit… (#21269)
* Add warning to Akka DD docs about freq add/deletes of top-level entities - fixes #21249
2016-08-25 16:47:58 +02:00
drewhk
67d0d2a4e3 Merge pull request #21183 from drewhk/wip-20890-stream-hub-drewhk
Stream Hubs
2016-08-24 13:33:02 +02:00
Endre Sándor Varga
bc358f3188 20890 Added MergeHub and BroadcastHub 2016-08-24 11:43:24 +02:00
Bernard Leach
ac8c4dc1b1 +Doc #20192 update http example to always consume response (#21241)
The single-request-in-actor-example does not consume the response
in where the status code is not OK.  Although this is unlikely
to cause backpressure issues as the response is likely to have
a HttpEntity.Strict entity, the example is confusing as it
does not follow the warning about always consuming the response.
2016-08-24 11:16:08 +02:00
Patrik Nordwall
8ab02738b7 Merge branch 'master' into wip-sync-artery-dev-2.4.9-patriknw 2016-08-23 20:14:15 +02:00
Wade Waldron
a397696f05 Added a note to the serialization section regarding desugared names #21263
* Updated note with changes from PR

* Updated note with changes from PR
2016-08-23 17:50:35 +02:00
Patrik Nordwall
7f2b6f8b54 Merge pull request #21186 from agolubev/21049-gaps-in-stages-overview-doc-agolubev
=str 21049 gaps in Source/Sink sections of stages-overview documentation
2016-08-23 12:08:38 +02:00
Alexander Golubev
024d95690c =str 21049 gaps in FlowOps section of stages-overview documentation 2016-08-23 10:51:30 +02:00
2beaucoup
0ed4a2aae9 =htp clean up json stream unmarshalling (#21233) 2016-08-19 16:21:33 +02:00
Lukasz Kusek
b873536e68 =doc fix akka-http timeouts documentation #21214
change akka.http.http-connection-pool -> akka.http.host-connection-pool
2016-08-17 21:05:53 +01:00
matsu-chara
1cb088ed81 fix eventbus doc-code (#21189)
remove `new AnyRef`

before:

```
new AnyRef {
  class Listener extends Actor {
    def receive = {
      case m: Jazz       => println(s"${self.path.name} is listening to: ${m.artist}")
      case m: Electronic => println(s"${self.path.name} is listening to: ${m.artist}")
    }
  }
```

after:
```
class Listener extends Actor {
  def receive = {
    case m: Jazz       => println(s"${self.path.name} is listening to: ${m.artist}")
    case m: Electronic => println(s"${self.path.name} is listening to: ${m.artist}")
  }
}
```
2016-08-16 15:20:44 +02:00
Hawstein
3e2bdb55a3 add extractActorSystem directive (#21097) 2016-08-16 14:59:05 +02:00
matsu-chara
d0eca7ef5d remove duplicated sentences (#21187) 2016-08-15 17:25:08 +02:00
Alexander Golubev
d3cbcf9342 =str 21049 gaps in Source/Sink sections of stages-overview documentation 2016-08-12 17:32:21 -04:00
Johan Andrén
22d669f7f0 More generous timeout in file upload sample spec #20727 2016-08-09 18:03:35 +02:00
Johan Andrén
ddb2218f0a Extra clarification and link to juc.ThreadPoolExecutor from docs #21109 2016-08-09 14:00:13 +02:00
Stefano Bonetti
16e3e01ba2 =doc websocket - amending streaming to streamed msgs #19945 2016-08-09 13:10:52 +02:00
Stefano Bonetti
f150b23c59 =doc adding a note about websocket idle-timeout #19945 2016-08-08 16:00:04 +02:00
Shivansh Srivastava
25e4586aa0 [#21090] Added the improved code for loggingResponsetime and added the link in the docs (#21118)
* [#21090] Added the improved code for loggingResponsetime and added the link in the docs

* [#21090] Added javadocs for logRequestResponseTime

* [#21090] Removed the compilation error caused by the missing imports

* [#21090] Removed the compilation error caused by type

* [#21090] Improved the identation of the code

* [#21090] Improved the identation of the code

* [#21090] Removed the empty line

* [#21090] Refactored the documentation with clear explanations
2016-08-05 16:16:14 +02:00