sdeleuze / spring-reactive-playground Goto Github PK

I tried to run this example in my machine, I am getting webscoket connection error. below is the error message.
Uncaught DOMException: Failed to execute 'send' on 'WebSocket': Still in CONNECTING state.
at HTMLTextAreaElement. (http://localhost:8080/file?name=websocket.html:26:20)

One more doubt is that, in Spring 4.x we were having
@MessageMapping("")
@sendto(""), are these got removed in Spring 5.0?

Can you please provide this as a maven project

There's a couple of configuration issues from using the code out the box.

The first is that in PostgresConfiguration the username is hardcoded to "seb" instead of coming from the configuration file application.properties.

The second is that the POST request fails with a

Request failure [status: 415, reason: "Content type 'application/json' not supported"]

I suppose the JSON support is not properly configured in the example.

I managed to solve the JSON problem by doing

List<HttpMessageConverter<?>> converters =
            Arrays.asList(new ResourceHttpMessageConverter(),
                new CodecHttpMessageConverter<Object>(new JacksonJsonEncoder(), new JacksonJsonDecoder()),
                new CodecHttpMessageConverter<String>(new StringEncoder(), new StringDecoder()));

handlerAdapter.setMessageConverters(converters);

However, the POST request only accepts a single Person at the time, and not as the Flux<Person> and the documentation seem to suggest that it could also accept an array of them.

In this case I got a JsonMappingException: Can not deserialize instance of playground.Person out of START_ARRAY token because the mapper is trying to get Person type out of the JSON string.

I just wanted to build the project and I got compile error: "cannot find symbol ReactiveMongoDbFactory reactiveMongoDbFactory"
Should I add other dependencies? The jar is downloaded but this class is missing...
I use Gradle 3.0 and Windows 10.

Once I fixed the gradle wrapper I get compile errors:

...
/home/dsyer/dev/boot/reactive-sample/src/main/java/playground/Application.java:33: error: cannot find symbol
import org.springframework.http.server.reactive.ErrorHandlingHttpHandler;
                                               ^
  symbol:   class ErrorHandlingHttpHandler
  location: package org.springframework.http.server.reactive
/home/dsyer/dev/boot/reactive-sample/src/main/java/playground/Application.java:35: error: cannot find symbol
import org.springframework.http.server.reactive.InternalServerErrorExceptionHandler;
                                               ^
  symbol:   class InternalServerErrorExceptionHandler
  location: package org.springframework.http.server.reactive
/home/dsyer/dev/boot/reactive-sample/src/main/java/playground/mongo/MongoPersonRepository.java:28: error: cannot find symbol
import reactor.Publishers;
              ^
  symbol:   class Publishers
  location: package reactor
...

This repo seems to me that it serves as the canonical example of how Spring with reactive support looks like.
It would be great if it could be updated to use latest Spring 5 build snapshot that includes Reactive support.

Or perhaps is there some example inside the Spring Framework repository that better serves the purpose of demonstrating Spring's reactive capabilities?

Thanks!

To be tested with our various HTTP engines

Spring Reactive should provide a way to run the blocking code in a dedicated thread, see https://github.com/spring-projects/spring-reactive/issues/56.

Cf. alaisi/postgres-async-driver#4 (comment)

Already discussed with Simon Baslé: AsyncN1qlQueryResult API makes not very easy to deal with errors since they are now emitted as errors in the main Observable<AsyncN1qlQueryRow>.

They will maybe provide an adapter to make our job easier in 2.x drivers. API may be improved in 3.x driver