THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
If you know the type of the body of the messagemessage payload (its body), you can use an overloaded version of toObservable() to pass in the class and get a typesafe Observable<T> back:
...