Julien Viet
8295da5067
MessageConsumer unregistration cleanup
2019-11-04 10:46:55 +01:00
Julien Viet
15e694ca63
WorkerExecutor close() should return a Future<Void>
2019-11-04 10:46:38 +01:00
Julien Viet
f490d45892
JsonObject equality should check the map keys instead of the sizes -closes #3170
2019-11-03 09:11:20 +01:00
Julien Viet
07b6ad2e80
AsyncMap should use context promises
2019-11-03 00:36:48 +01:00
Julien Viet
07fe826f3c
Remove unused Vertx instance in AsyncMapTest leaking file descriptor
2019-10-31 16:33:26 +01:00
Julien Viet
f59a6fc901
Use right future style in MessageProducerImpl
2019-10-31 09:09:33 +01:00
Julien Viet
77e925b683
Cleanup
2019-10-30 21:58:00 +01:00
Julien Viet
1fce3dc1f5
Update cluster manager to return a Future instead of using a callback - closes #3166
2019-10-30 12:19:42 +01:00
Julien Viet
ed2ea884d8
Avoid using Promise.promise in HTTP/2 ping/pong pong frame handler
2019-10-29 21:43:42 +01:00
Julien Viet
37b437da98
Avoid using Promise.promise for DatagramSocket
2019-10-29 21:38:55 +01:00
Julien Viet
8a74e1544b
Catch throwable instead of exception in Future#future(Handler) factory method
2019-10-29 20:58:02 +01:00
Julien Viet
d625c10d6b
Minor improvement of executeBlocking methods with futures
2019-10-29 14:49:22 +01:00
Julien Viet
39d0fed1cd
Fix test not passing for domain sockets due to not using the correct address in client
2019-10-29 09:58:32 +01:00
Julien Viet
034ef54098
Expose client context internally
2019-10-28 18:22:19 +01:00
Julien Viet
471b3a32fb
Use context futures in Vert.x API - fixes #3164
2019-10-28 14:05:05 +01:00
Julien Viet
6defdbfb94
Context promise/future - fixes #3163
2019-10-28 14:01:47 +01:00
Julien Viet
7dcfa8c80f
Add an execute(T,Handler<T>) method on ContextInternal to execute a context task from anywhere
2019-10-28 12:47:37 +01:00
Julien Viet
80e1cc7e85
Rework HTTP client
2019-10-25 11:14:02 +02:00
Julien Viet
a655b9b4c4
Obtain context in HttpClientRequest when the request is created and not at connect time
2019-10-25 10:49:42 +02:00
Julien Viet
48751f950a
Improve Netty promise/future listener adapter and use it when possible
2019-10-25 10:49:42 +02:00
Julien Viet
707ad8c1bb
NetSocketInternal#writeMessage(Object) should return a Future<Void> and not be fluent
2019-10-25 10:32:38 +02:00
Julien Ponge
1ab9884cb2
Update copyright notices
...
This also:
1. updates copyright to 2011-2019,
2. adds missing headers,
3. harmonizes to "Contributors to the Eclipse Foundation"
(replacing a "Copyright Red Hat, Inc." by that is correct).
Signed-off-by: Julien Ponge <julien.ponge@gmail.com >
2019-10-24 15:09:37 +02:00
Julien Viet
8dbface343
Merge pull request #3158 from vietj/event-bus-iso
...
Event bus improvements
2019-10-23 20:05:01 +02:00
Julien Viet
474b35eb48
Introduce specific classes to split behavior/state between MessageConsumer implementation and ReplyHandler implementations delegating to HandlerRegistration
2019-10-23 18:47:13 +02:00
Julien Viet
157f59dcf4
Remove src field from MessageImpl as it can be avoided
2019-10-20 09:22:30 +02:00
Julien Viet
64ee11b0a1
Improve event bus tracing so that the response is traced when it is sent
2019-10-20 09:20:18 +02:00
Julien Viet
dcf3174cab
Add address on HandlerHolder
2019-10-20 09:20:18 +02:00
Julien Viet
deadcc1f93
Remove unecessary method param
2019-10-20 09:20:18 +02:00
Julien Viet
c6dd46d10c
Move the replier message info on the replied message itself
2019-10-20 09:20:18 +02:00
Julien Viet
a06aa2a296
Reply address is never set in MessageImpl constructor
2019-10-20 09:20:18 +02:00
Julien Viet
05067ca881
Move sender metrics/tracing concerns to OutboundDeliveryContext
2019-10-20 09:20:18 +02:00
Julien Viet
79c13877b9
Make OutboundDeliveryContext not anymore an inner class of EventBus
2019-10-20 09:20:18 +02:00
Julien Viet
d6869caa0b
Use promise first in EventBus instead of async result handler
2019-10-20 09:20:18 +02:00
Julien Viet
bbaf418793
Set the handler registration context when it is created instead of delaying it to when the consumer handler is set
2019-10-20 09:20:18 +02:00
Julien Viet
42cdd34b47
Make consumer metric update from EventBus to HandlerRegistration
2019-10-20 09:20:06 +02:00
Julien Viet
9a31e2439a
Rename io.vertx.core.impl.NetSocketInternal to io.vertx.core.net.impl.NetSocketInternal - fixes #3152
2019-10-17 22:57:13 +02:00
Julien Viet
12fa90e87c
Restrict tests for native transport in CI as now job fails due to time limit exceeded
2019-10-16 14:16:29 +02:00
Julien Viet
2fca36d31b
Netty upgrade to 4.1.42.Final - see https://github.com/eclipse-vertx/vert.x/issues/3146
2019-10-16 11:37:15 +02:00
Julien Viet
733c1e097b
WebSocket writePing/writePong should return a Future<Void> and accept an overloaded async result handler
2019-10-15 14:25:33 +02:00
Julien Viet
c429731ae2
MessageConsumer unregister() should return a Future<Void>
2019-10-15 14:25:33 +02:00
Julien Viet
9824a7f34f
Remove useless future() construction
2019-10-15 14:25:33 +02:00
Julien Viet
11f4e9942c
Revert "Detect and print deadlocks in JVM when blocked thread checker detects a blocked thread"
...
This reverts commit 8580977000
2019-10-15 13:52:00 +02:00
Julien Viet
aaf5fd72e6
Fix synchronisation regression leading to potential deadlock
2019-10-15 13:51:30 +02:00
Julien Viet
8580977000
Detect and print deadlocks in JVM when blocked thread checker detects a blocked thread
2019-10-15 13:28:48 +02:00
Julien Viet
ceb1bf116b
Provide the Future#flatMap method as alias of Future#compose method - closes #3145
2019-10-15 12:43:48 +02:00
Julien Viet
95f82b52bd
Extend Future#compose to allow remapping errors - closes #3144
2019-10-15 12:33:03 +02:00
Kowalczyk
9391ea39bd
2934 make compressed http2 request possible
...
Signed-off-by: Kowalczyk <bkowalczyyk@gmail.com >
2019-10-15 11:56:12 +02:00
Julien Viet
9c87fdfda0
Use Netty future/promise in AsyncResolveConnectHelper to remove unecessary concurrency - fixes #3142
2019-10-15 11:13:58 +02:00
Julien Viet
d97c6ccad8
Improve usage of synchronization in HttpClientRequest
2019-10-14 10:41:00 +02:00
Julien Viet
1018724a96
Do not lock the handler calls in AsyncFile - see #3140
2019-10-14 10:09:27 +02:00
