Commit graph

19315 commits

Author SHA1 Message Date
Richard Imaoka
29dec00c45 +doc Add more description about actor path alias, symbolic link #20773 (#20866) 2016-07-05 22:00:48 +02:00
Patrik Nordwall
675e137d06 =act let onReceive throw Throwable, #20231 (#20781)
* I also tried to change the lifecycle methods (e.g. postStop) but
  that would break source compatibility for code that called super.postStop
2016-07-05 17:58:33 +02:00
Patrik Nordwall
9fbab1f268 Merge pull request #20768 from denisrosca/master
Warning for actors with value class arguments
2016-07-05 16:49:41 +02:00
Konrad Malawski
8666d05f06 =doc Improve readme a bit, more links, and sections (#20889)
* =doc Improve readme a bit, more links, and sections

* Add link to issues

* Update README.md

* Update README.md

* Update README.md
2016-07-05 16:23:25 +02:00
Patrik Nordwall
f0f755bf08 Merge pull request #20828 from choffmeister/choffmeister-20826-unregister-leaving-distributed-pubsub-nodes
Remove distributed pubsub nodes on leave
2016-07-05 15:48:07 +02:00
Andrea Peruffo
a230f2fe34 =str switch to java std lib ThreadLocalRandom. (#20877) 2016-07-05 14:59:48 +02:00
gosubpl
06aaa273f1 doc #20466 akka http java dsl examples - file upload directives (#20859)
* #20466 file upload - first example test done

* #20466 second test from FileUploadDirectivesExample passing in Java

* #20466 FileUploadDirectives examples file rename plus docs

*  #20466 post-review changes - adding better JAVA Multipart API

* #20466 Multipart Java conversions fix and added spec for the Java side of the model
2016-07-05 10:26:27 +02:00
Konrad Malawski
91eb27947b +doc add http (experimental) migration guide to ease upgrading DSLs (#20860)
* +doc add http (experimental) migration guide to ease upgrading DSLs

* Update migration-guide-2.4.x-experimental.rst
2016-07-01 12:37:49 +02:00
Patrik Nordwall
8b274ebc62 ignore PubSub Status message from unknown node, #20846 (#20847)
* ignore PubSub Status message from unknown node, #20846

Reproducer:
1. old cluster of node1, node2 and node3
2. shutdown node3 and start it again with same host:port, let it
   join itself and not the old cluster
3. node1 and node2 will continue to gossip to the node3 address and
   Status message is accepted and replied to (Delta is ignored from
   unknown node)

Solution:
* ignore status message from unknown node
* also added a reply flag in the Status message to break the
  back-and-forth replies in case the deltas are not accepted,
  this is not needed for fixing this bug, but it adds an extra
  level of safety
2016-07-01 12:12:23 +02:00
Patrik Nordwall
b85cee604a Merge pull request #20857 from akka/wip-20856-netty-3.10.6-patriknw
update to Netty 3.10.6.Final, #20856
2016-07-01 12:11:21 +02:00
drewhk
79d6bb42ae Merge pull request #20840 from drewhk/wip-20487-fix-racy-foreachparallelspec-drewhk
#20487: Fix race in FlowForeachParallelSpec
2016-07-01 12:04:55 +02:00
drewhk
76832c3db2 Merge pull request #20837 from drewhk/wip-20829-groupby-double-pull-drewhk
#20829 Fix double pull in GroupBy
2016-07-01 12:04:33 +02:00
Simão Martins
2a182a6c4e +doc #20794 explain Prop edge cases. (#20861)
* +doc #20794 explain Prop edge cases.

* Create a CompileOnly spec for props edge cases.
2016-07-01 11:32:20 +02:00
Endre Sándor Varga
336d4caafd #20829 Fix double pull in GroupBy 2016-07-01 11:08:16 +02:00
Endre Sándor Varga
9e2da7be32 #20487: Fix race in FlowForeachParallelSpec 2016-07-01 11:07:06 +02:00
monkey-mas
dce174b455 !htp #20102 Fix authentication scheme of WWW-Authentication header for OAuth2 over HTTP (#20756) 2016-06-30 10:28:40 +02:00
Christian Hoffmeister
fcd290cd9a Remove distributed pubsub nodes on leave #20826
This ensures that gracefully leaving nodes (which would terminate after
their own removed event) are already unregistered on all other pubsub
nodes, before termination.
2016-06-30 09:19:39 +02:00
Konrad Malawski
d4d9c1943e =htc #20789 fix double push of requestPrepOut in HTTP blueprint (#20841)
* =htc #20789 fix double push of requestPrepOut in HTTP blueprint

* =htc simplify fix, can pull eagerly but under this condition

* =htc make early response a single line
2016-06-30 00:11:44 +02:00
Patrik Nordwall
3aa19a0e7c update to Netty 3.10.6.Final, #20856 2016-06-29 20:38:18 +02:00
Patryk Jażdżewski
421eb3d021 =htp simple head test to cheack manual completion with empty Source (#20853)
* simple head test to cheack manual completion with empty Source, for issue 20182
2016-06-29 13:50:58 +02:00
Patrik Nordwall
e7def17ce3 Merge pull request #20777 from richard-imaoka/wip-fix-circuitbreaker-remaining-timeout-richard-imaoka
Fix CircuitBreaker Open state's remainingTimeout() method (#20029)
2016-06-28 15:53:56 +02:00
Patrik Nordwall
f791cf123b stop PoolInterfaceActor on shutdown, #20842 (#20844) 2016-06-28 13:47:23 +02:00
Michal Sitko
72f8544efd +htp #18929 add withSizeLimit directive (#20760)
withSizeLimit and withoutSizeLimit directives added
2016-06-28 12:14:44 +02:00
Daniel Moran
e00a86271a =htc #19361 Convert UpgradeStage to GraphStage (#20835) 2016-06-28 11:58:12 +02:00
Patrik Nordwall
adc931a493 Merge pull request #20839 from akka/wip-20831-migration-guide-patriknw
rename 2.5 migration guide, #20831
2016-06-27 17:58:59 +02:00
Patrik Nordwall
77633401f9 rename 2.5 migration guide, #20831 2016-06-27 15:24:49 +02:00
drewhk
cadb148da3 Merge pull request #20838 from drewhk/wip-19931-expectRequest-update-pending-drewhk
#19931 Track pending requests properly on expectRequest
2016-06-27 14:01:01 +02:00
Endre Sándor Varga
e54d2933bd #19931 Track pending requests properly on expectRequest 2016-06-27 12:56:29 +02:00
Patryk Jażdżewski
62b4ecf67c +htc #20456 Add hot connection pool via the minConnections setting (#20723)
* 20456: add hot connection pool via the minConnections setting

* added the akka.http.host-connection-pool.min-connections setting to reference.conf
* modified config implementation s o it's being read, with 0 as default
* based on the setting two types of pools will be created - hot and cold
* hot ones will start ASAP and not close when the number of active connections fall to 0

* PR remarks: english, remove getIntOpt ...

Moving logic into PoolConductor WIP

* WIP: moving minConnections logic into PoolConductor, needs more precise tests

* added testing via expectNextN in ConnectionPoolSpec.scala; fixed the bug with skipping the actor state in PoolSlot

* fix comments from PR: make sure PoolConductor produces only SwitchSlotCommand

* fix typo: slotSettings -> slots

* Fix style after code review
- inline short snippets
- shorter Mima
- better naming
- make SlotCommands final
2016-06-27 10:55:39 +02:00
Richard Imaoka
1ca40730ef =str Deprecate InvalidAbsorbTermination, please use GraphStage instead. (#20288) (#20386) 2016-06-25 11:37:22 +02:00
Kevin Deng
e8b4ca2acd =htc Ensure DNS resolution is performed for all new connections #20690 (#20791)
Pass in an unresolved InetSocketAddress to ensure that each new
TcpOutgoingConnection will perform DNS resolution.

This prevents a connection pool from always using the same IP address for a host
even if the DNS mapping changes (e.g. in a failover).
2016-06-25 11:31:35 +02:00
Tobias Pfeifer
3723959b69 Akka-HTTP: basicAuthentication directive promotes insecure passwords #18858 (#20820)
the Credentials Object used in the authenticateBasic Directive can be verified against passwords that are stored with a hashing function. By providing the same hashing function as an argument the clear-text password in the HttpCredentials will be hashed the same way prior to comparing against the stored secret.
2016-06-25 11:24:54 +02:00
Hawstein
6777e7f7d9 +doc #20466 example snippet for akka http java dsl: ParameterDirectives (#20823) 2016-06-23 23:29:01 +02:00
Martynas Mickevičius
2836e990cb Merge pull request #20805 from 2m/wip-sigar-loader-extract-dir-2m
#20804 add a note for unique per instance extract directory
2016-06-23 10:14:01 +03:00
kbrowder
d6eebd22ef +htt #20815 Add expectNext(d: FiniteDuration) and requestNext(d: FiniteDuration) (#20819)
* Add expectNext(d: FiniteDuration) and requestNext(d: FiniteDuration) for issue 20815

* add some comments on requestNext
2016-06-22 21:27:09 +02:00
Michał Płachta
00c5f49c7a Replace PushStage-based Log with GraphStage (part of #19834) (#20788)
* Replace PushStage-based Log with GraphStage (part of #19834)

* Remove LogLogic and FilterLogic toStrings
2016-06-22 16:36:18 +02:00
Martynas Mickevičius
672a10a7ea #20804 add a note for unique per instance extract directory
If extract directory for sigar loader is shared, first instance
JVM crashes when the second one is started.
2016-06-22 16:30:40 +03:00
Martynas Mickevičius
e39255cef0 Merge pull request #20809 from 2m/wip-#20808-restart-node-2m
#20808 clarify docs on the quarantined node restart
2016-06-22 16:27:45 +03:00
gosubpl
4b89fcd643 +doc #20466 akka http java dsl example snippets timeout directives (#20812)
* #20466 added checks to the TimeoutDirectivesExampleSpec

* #20466 added missing Java directive wrapper, added Java test, added some comments to Scala spec

* #20466 test minor fixes (typos, comments, unused code)

* #20466 replaced placeholders with proper snippets in Java docs

* #20466 added proper withRequestTimeout example to JavaTestServer

* #20466 comment - clarifies the request-timeout = infinite case

* #20466 post-review changes (#20812)
2016-06-22 01:55:28 +02:00
Fabian Gutierrez
ee77273fac akka http javadsl - add path directive tests (#20813)
* akka http javadsl - add debugging directive test

* fixes line breaks

* add additional examples on PathDirectives

* link documentation to test examples

* include example on redirectToNoTrailingSlashIfPresent and redirectToTrailingSlashIfMissing

* include example on redirectToNoTrailingSlashIfPresent and redirectToTrailingSlashIfMissing
2016-06-22 01:13:27 +02:00
Patryk Jażdżewski
7259fcc534 +htc #20272 HttpMessageParser swallows IllegalHeaderException (#20783)
Catch clause in HttpMessageParser.parseBytes will intercept IllegalHeaderException being thrown and translate them into proper errors.
2016-06-21 16:30:25 +02:00
Johan Andrén
277e7124e0 Improve map stage diagrams (#20551)
* =doc Add clarity for GraphStage image with map transformation

* Clarified that the function is applied in the map graph stage diagrams

* Make application of f more visible
2016-06-21 16:28:46 +02:00
Martynas Mickevicius
2de90adc02 #20808 clarify docs on the quarantined node restart 2016-06-20 13:10:43 +02:00
Felix Satyaputra
4d9268214d +rem Support serialization of scala Some and None (#20801) 2016-06-19 17:55:10 +02:00
Hawstein
cc22ed4560 +doc example snippet for akka http java dsl: SecurityDirectives (#20717) 2016-06-19 02:06:19 +02:00
Chris Birchall
f246c56087 +doc Add more imports to the stream quick start guides for Java and Scala (#20797)
* Add more imports to the stream quick start guides.

This makes it easier for people to execute the code samples while they
read through the guide.

* Change line endings to be consistent with other files

For some reason these 2 files had CR+LF line endings.
2016-06-18 11:15:17 +02:00
Patrik Nordwall
a9cb8ab4b5 Merge pull request #20762 from jypma/java_base
Allow Java API to create actor publishers with stash
2016-06-14 14:28:27 +02:00
Konrad Malawski
5899658416 =str #20214 remove debug println in TLSActor (#20769) 2016-06-13 18:36:40 +02:00
Richard S. Imaoka
f0e9de4e56 Fix CircuitBreaker Open state's remainingTimeout() method (#20029) 2016-06-13 23:14:45 +09:00
Konrad Malawski
374a852553 =htc #20683 added more docs, documented expected double-run behaviour (#20765) 2016-06-13 14:11:09 +02:00