I ended up doing this, may be similar functionality can be added in future
releases to existing Mina component.
1. copied all Mina component related classes to create custom Mina component
to fit my needs.
2. receivehandler extends mina api's iohandleradpater
3. added member variable iohandleradapter to component to share between
Minaproducer and Minaconsumer.
4. create receivehandler in minaconsumer onstart() method and assign it to
the minacomponent. 5.Minaconsumer object instance is passed to
receivehandler to initiate the route on message event.
6.access the receivehandler in Mina producer and pass it to connect method.
used the same receivehandler object between producers in case of
loadbalanced producers.
Please let me know if you guys have any comments/issues with above approach.
Thanks,
Anand
anandsk wrote:
>
> actually, I copied Mina component and modifying only the code to share
> receivehandler and connection between producer and consumer. I need to be
> able to load balance on failure. procuder loadbalances using loadbalancer
> component on exception.Consumer just listens for message.
> I just had a question regrading loss of unprocessed messages in case of
> IO/connection failure,suppose I got 3 messages from remote server and I am
> in the middle of processing number 2 onmessage event and connection
> failure happend and reestablish connection with new IP would I loose
> message number 2 or 3.
>
> Thanks,
> Anand
>
>
> Ashwin Karpe wrote:
>>
>> Hi,
>>
>> You might want to look at the Mina component source code for gathering
>> details on how to write a mina like component yourself. But I suspect you
>> have done this already ;)
>>
>> Cheers,
>>
>> Ashwin...
>>
>>
>>
>> anandsk wrote:
>>>
>>> since there is a bug with async route with Mina in camel 2.2.0,
>>> I am thinking of writing a custom component to achieve following as per
>>> huntc suggestion. I am assuming that I can use load balancer component
>>> in case of connection failure to rotate IP addresses in combination with
>>> custom component.I will deploy this as a war app and I am using spring.
>>> I have to use single TCP connection and need to send and receive
>>> messages asynchronously. can someone help me with high level steps to
>>> achieve this?. I am assuming I don't need to worry about thread
>>> synchronization and thread safety as I have to use single connection
>>> object.
>>>
>>> I am thinking all I need to do is
>>> 1. extend defaultcomponent and override createendpoint method to return
>>> the same object everytime(declare a singleton spring minaconnector bean
>>> and use annotation to inject into this component).
>>>
>>> 2. extend defaultproducer and override process method to send message on
>>> using singleton spring object.
>>>
>>> 3. extend defaultconsumer and override dostart(establishconnection and
>>> register IOhandler for message receive events) and dostop(disconnect)
>>>
>>> 4. implement messagereceived of IOhandleradapter
>>> I am not sure what goes in here, how to pass the message to next
>>> processor/endpoint for futher processing?.
>>>
>>> 5. extend defaultendpoint and
>>> override createproducer and return number 2 class above.
>>> overrise createconsumer and return number 3 class above.
>>>
>>> 6. ofcourse I need to define this component in spring, so that it is
>>> visible to camel.
>>>
>>> can someone validate above items and let me know, if I need to do
>>> anything else.
>>>
>>> I am thing my sample route would like this.
>>>
>>> from("file:///test/test/response")
>>> .convertBodyTo(String.class)
>>> .to("mycomponent://localhost:6202");
>>>
>>> from("mycomponent://localhost:6202")
>>> .to("log:+++ reply++++");
>>>
>>>
>>>
>>>
>>>
>>>
>>>
>>>
>>>
>>>
>>>
>>>
>>
>>
>
>
--
View this message in context:
http://old.nabble.com/custom-component-using-Mina-tp27879624p27937811.html
Sent from the Camel - Users mailing list archive at Nabble.com.
