Camel: Create Custom Endpoint

[sandra_nagl]

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!

[rhn-support-pchhabra]

Hi Sandra,

Not sure if I understood you correctly here, what kind of java object will your route be receiving from?

For your route, I would suggest you to have a consumer which will accept the data then use a processor which would help you transform your data into the required format and then pass it on to the producer which would be your AMQ endpoint.

Also, can you share a sample reproducer of what you have configured so far? I can have a look at it and understand the requirement accordingly.

Regards
Pulkit

[alele]

I believe, documentation[1] and [2] might help you along with some community articles:

[1] https://access.redhat.com/documentation/en-us/red_hat_jboss_fuse/6.3/html/apache_camel_development_guide/endpointintf

[2] https://access.redhat.com/documentation/en-us/red_hat_jboss_fuse/6.3/html/apache_camel_development_guide/component-impl-…

[3] Creating A Custom Camel Component - DZone Integration

[4] Apache Camel: Writing Components

--Avadhut