Spring/spring-framework
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity
14,733 Commits 18 Branches 0 Tags
df8412bded77faadd60d62dc5c78ca8b2b44a481
Commit Graph

582 Commits

Author SHA1 Message Date
Rossen Stoyanchev
b6e252495a Protect against NPE in DefaultSubscriptionRegistry 
Follow-up fix on the recent commit:
https://github.com/spring-projects/spring-framework/commit/44c31a

Issue: SPR-15543
 2017-05-22 16:08:34 -04:00
Bao Tran
44c31a6aad Fix duplicate STOMP subscription id issue 
Issue: SPR-15543
 2017-05-19 15:20:14 -04:00
Juergen Hoeller
9e3f4ccce9 Merge pull request #1394 from alexander-riss/keySet 
Fix inefficient use of keySet operators in messaging classes

Issue: SPR-15553
 2017-05-16 11:22:22 +02:00
Alexander Riss
e49a5d8424 fix inefficient use of keySet operators in messaging classes 
issue: SPR-15553
 2017-05-16 10:41:22 +02:00
Juergen Hoeller
e93e49f268 ErrorMessage.toString() includes original message at top level 
Issue: SPR-15459
 2017-04-19 20:50:20 +02:00
Gary Russell
e677342628 Add originalMessage to ErrorMessage 
Issue: SPR-15459
 2017-04-19 14:04:25 -04:00
Sebastien Deleuze
4d9144132e Upgrade to Reactor Core 3.1 
Issue: SPR-15318
 2017-04-11 18:13:04 +02:00
Juergen Hoeller
5986f881d0 HandlerMethod evaluates ResponseStatus annotation for early caching 
Issue: SPR-15227
 2017-04-08 15:56:05 +02:00
Brian Clozel
b799013567 Update to Reactor Aluminium SNAPSHOT 
Currently the BOM versions are:

* reactor-core 3.0.6.BUILD-SNAPSHOT
* reactor-netty 0.6.2.BUILD-SNAPSHOT

This commit fixes as well a few deprecations in reactor-core.
 2017-03-10 15:20:40 +01:00
stonio
7d062df992 Use String#isEmpty() 
Closes gh-1335
 2017-02-22 11:55:17 +01:00
Juergen Hoeller
d2cc97af47 Polishing 2017-02-21 22:41:40 +01:00
Rossen Stoyanchev
f219680d42 Add equals/hashcode for STOMP Subscription 
Issue: SPR-15229
 2017-02-21 15:05:06 -05:00
Stephane Maldini
ba97432043 prepare for reactor-netty 0.6.1.RELEASE 2017-02-21 16:00:19 +00:00
Juergen Hoeller
370e3d683a Polishing 2017-02-20 23:00:12 +01:00
Juergen Hoeller
74bdcd8ed4 MutableMessageHeaders serializes itself as regular MessageHeaders 
Issue: SPR-15262
 2017-02-17 20:59:17 +01:00
Juergen Hoeller
50d93d3794 Consistently support CompletionStage next to CompletableFuture 
Issue: SPR-15258
 2017-02-15 23:16:11 +01:00
Rossen Stoyanchev
60517b23e2 StompSession supports custom headers for UNSUBSCRIBE 
Issue: SPR-15131
 2017-01-31 17:55:53 -05:00
Juergen Hoeller
9b26fcd7d2 Refined assertion messages 
Issue: SPR-15196
 2017-01-31 15:56:39 +01:00
Juergen Hoeller
1b2dc3638f Revisit Assert to avoid single-arg assert methods (with refined messages) 
Issue: SPR-15196
 2017-01-30 22:15:55 +01:00
Arjen Poutsma
69c16f3821 Add headers in InterceptingClientHttpRequest 
This commit *adds* the "intercepted" headers to the ClientHttpRequest,
as opposed to replacing them, which is what happened before this commit.

Issue: SPR-15166
 2017-01-30 14:18:50 +01:00
Juergen Hoeller
8038fb9c8b HandlerMethod pre-resolves parameter types at construction time 
Issue: SPR-15186
 2017-01-25 11:09:43 +01:00
Juergen Hoeller
12973ac702 Polishing 2017-01-24 00:12:53 +01:00
Juergen Hoeller
f095aa20eb Polishing 2017-01-23 21:28:40 +01:00
Juergen Hoeller
e9db4d6f96 Proper resolution of Optional.empty() for header arguments 
Issue: SPR-15151
 2017-01-17 10:46:37 +01:00
Juergen Hoeller
62e530ec94 Resolve minor 4.3.x deprecations in master 
Issue: SPR-15139
 2017-01-16 21:43:12 +01:00
Juergen Hoeller
047786acef Revised InvocableHandlerMethod exception messages (controller vs endpoint vs handler) 
Introduces dedicated MethodArgumentResolutionException for spring-messaging invocations.

Issue: SPR-15139
 2017-01-16 21:14:46 +01:00
Juergen Hoeller
7c05b427a7 MimeTypeUtils constants cleanup: removed web media types 
Issue: SPR-15137
 2017-01-12 23:30:57 +01:00
Juergen Hoeller
743ce2cda6 Polishing 2017-01-12 23:30:38 +01:00
Sam Brannen
9ed66bf2eb Clean up warnings across code base 2017-01-07 01:54:38 +01:00
Gary Russell
80bc8fc596 Implement MessagingException.toString() 
Issue: SPR-15091
Closes gh-1284
 2017-01-05 10:25:04 +01:00
Rossen Stoyanchev
e62b104e03 Resource cleanup on shutdown in ReactorNettyTcpClient 2016-12-28 21:37:12 -05:00
Rossen Stoyanchev
698c885e06 Reconnect failures delegated to TcpConnectionHandler 
When connecting with a ReconnectStrategy we can only report the outcome
of the first connect to the ListenableFuture<Void> return value.

Failures for all subsequent attempts to reconnect however must be
channeled to TcpConnectHandler#afterConnectFailure which is used in
the STOMP broker relay for example to publish
BroadcastAvailability(true/false) events.
 2016-12-28 21:37:07 -05:00
Rossen Stoyanchev
ea274ebc0a Fix decoding issue in Reactor TcpClient 
When decoding STOMP messages unread portions of a given input ByteBuf
must be kept until more input is received and the next complete STOMP
frame can be parsed.

In Reactor Net 2.x this was handled for us through the "remainder"
field in NettyChannelHandlerBridge. The Reactor Netty 0.6 upgrade
however applied only a simple map operator on the input ByteBuf
after which the buffer is relased.

This commit replaces the use of a simple map operator for decoding
and installs a ByteToMessageDecoder in the Netty channel pipeline
which has a built-in ability to preserve and merge unread input into
subsequent input buffers.
 2016-12-28 21:36:37 -05:00
Rossen Stoyanchev
fdf88c9795 Workaround for onReadIdle issue in Reactor TcpClient 
https://github.com/reactor/reactor-netty/issues/22
 2016-12-28 21:36:37 -05:00
Rossen Stoyanchev
2a3e01399a Polish ReactorNettyTcpClient 2016-12-28 21:36:37 -05:00
Juergen Hoeller
5c48daa8eb Remove unused Log object from MessageHeaderAccessor 
Issue: SPR-15045
 2016-12-22 23:34:19 +01:00
Juergen Hoeller
ae62341fa3 Avoid deprecated Scheduler.shutdown() in favor of Scheduler.dispose() 2016-12-22 22:35:54 +01:00
Juergen Hoeller
4c005e6336 ResolvableType-based matching respects generic factory method return type 
Includes consistent use of ResolvableType.resolve() wherever applicable.

Issue: SPR-15011
 2016-12-17 23:10:48 +01:00
Stephane Maldini
2802926c1d update STOMP support to reactor-netty 0.6 2016-12-13 17:31:09 +00:00
Stephane Maldini
70bab23609 update STOMP support to reactor-netty 0.6 2016-12-13 17:29:43 +00:00
Rossen Stoyanchev
b3fa1b40a0 Synchronized updates of STOMP header key cache 
Issue: SPR-14901
 2016-12-08 11:13:57 -05:00
Christoph Dreis
9b76dc2ab4 SPR-14901 Allow customization of STOMP message header encoding 
Fixes SPR-14901
 2016-12-08 11:13:56 -05:00
Sergei Ustimenko
e4ed1f6ffd ChannelFutureMono renamed to FutureMono 
In the latest reactor-netty there is renaming
of ChannelFutureMono class to FutureMono. Thus
build fails on the latest master.
 2016-12-03 18:56:42 +01:00
Juergen Hoeller
f6fc0a86b3 Polishing 
(cherry picked from commit 0028b29)
 2016-12-01 20:11:47 +01:00
Rossen Stoyanchev
b874692452 Simplify ReactorNettyTcpClient input 
Create a ReactorNettyCodec to hold the decoding and encoding function
and consumer along with a package-private sub-class that delegates to
StompDecoder and StompEncoder.

Issue: SPR-14531
 2016-11-30 21:17:04 -05:00
Rossen Stoyanchev
85c93f5d67 Polish Reactor Netty TCP client support 2016-11-30 21:17:04 -05:00
Stephane Maldini
870f61fd8e update STOMP support to reactor-netty 2016-11-30 21:17:04 -05:00
Juergen Hoeller
5458a427a1 Polishing 2016-11-30 22:31:47 +01:00
Rossen Stoyanchev
a203b74d20 PayloadArgumentResolver has useDefaultResolution flag 
Issue: SPR-14937
 2016-11-28 17:00:22 -05:00
Sebastien Deleuze
a143b57d4b Polish Kotlin nullable support 
This commit polishes Kotlin nullable support by reusing
MethodParameter#isOptional() instead of adding a new
MethodParameter#isNullable() method, adds
Kotlin tests and introduces Spring Web Reactive
support.

Issue: SPR-14165
 2016-11-24 18:28:50 +01:00