2 Replies Latest reply on Aug 9, 2017 11:04 PM by Avadhut Lele

    Camel: Create Custom Endpoint

    Sandra Nagl Newbie

      Hello,

       

      I have a Fuse project where I define a route (with Blueprint), which should get data in form of objects from a specific Java SDK, wraps them as messages and forwards them in the route. They should be filtered according to a specific property and send to an ActiveMQ queue, where another microservice should take it from.

       

      Unfortunately I have problems creating a custom endpoint. I already created an Endpoint Class (and registered it in the blueprint xml as a bean) which inherits from the DefaultEndpoint in order to create a consumer and producer. But I don't really know which one I need to accomplish my task. Do I have to create a consumer which creates the SDK instance and the Listeners where I get my data from, or is it achieved through a producer? How do I create a Message and store my object in it, to send it through the route for further processing?

       

      Sorry if my question was already asked, but I have read through several articles dealing with custom endpoints and still have not really a clue where to start with my specific problem.

       

      Thanks in advance!

      Best regards!