Reputation: 107
Right now, I am getting my feet wet using Spring Cloud Dataflow and I have a use case where we would like to record traffic on the RabbitMQ Message Bus to a Log file.
My first attempt was a simple:
create --name test --definition "rabbit | log" --deploy
Running this I was able to see the ASCII output to the log file. However, I would to dump the contents of the message (Google Protocol Buffer) being transported by RabbitMQ to the log file. So, I was thinking I could do something like:
create --name test --definition "rabbit | transform=new Envelope.parse(payload.toBytes()) | log
(This is a minor detail but, all of my GPB messages are encapsulted by a common class "Envelope").
How can I include the .jar file for my GPB class into Spring Cloud Dataflow ? Or is there a better way to do this ?
Upvotes: 0
Views: 121
Reputation: 4156
If you need extra classes on you classpath, you have to configure the apps to include them. Take a look on the docs of the app-starters on how to get this working: http://docs.spring.io/spring-cloud-stream-app-starters/docs/Bacon.RELEASE/reference/html/
Upvotes: 1