Hi Konrad,
Thanks for your reply. I did try created DefaultPollingConsumerPollStrategy
instance however the methods required to be overridden needs an instance
org.apache.camel.Camel and Endpoint, as below,however my consumers are of
akka's UntypedConsumerActors, so was wondering if we have some kind of
support in akka as well for defining poll strategy.Kindly help
- begin
- boolean begin(Consumer consumer, Endpoint endpoint)
- commit
- void commit(Consumer consumer, Endpoint endpoint, int
polledMessages)
- rollback
- boolean rollback(Consumer consumer, Endpoint endpoint, int
retryCounter, Exception e) throws Exception
On Tuesday, August 5, 2014 8:21:43 PM UTC+5:30, Konrad Malawski wrote:
>
> Hello Ratika,
> AFAIK (and shown in the linked page) Camel can configure such things by
> simply appending more options to the `endpointURI`.
> Akka-camel is simply passing it through to Camel, so anything that works
> with plain Camel like this can be done with Akka-Camel.
>
> Define your pollStrategy somewhere and then use it in the URI, like shown
> in the last section of the linked document.
> In case if won't work, let us know what the exact problem is and we'll try
> to help out :-)
>
>
>
> On Tue, Aug 5, 2014 at 4:40 PM, <[email protected] <javascript:>>
> wrote:
>
>> Hi Martynas,
>>
>> We are having both IBMQ and Hornet Queue, we have created JMSAdapters
>> which extends UntypedConsumerActors and these instances have member
>> variable endpointURI which is read through configurations(properties
>> files). We have options of configuring poll strategy including custom using
>> camel without akka, pls see the links below, wanted to know if we can do
>> the same akka-camel compoment
>>
>> http://camel.apache.org/polling-consumer.html
>>
>> I want to configure JMSAdapters which are ConsumerActors with endpointURI
>> having custom poll strategy ( a bean extending
>> DefaultPollingConsumerPollStrategy)
>> or something similar.
>>
>> Thanks
>> Ratika
>>
>>
>> On Thursday, July 31, 2014 9:54:20 PM UTC+5:30, Martynas Mickevičius
>> wrote:
>>
>>> Hello Ratika,
>>>
>>> since Camel does not support HornetQ out-of-the-box could you elaborate
>>> a bit more how are you using it with akka-camel? Also do you have a way of
>>> changing poll strategy when using HornetQ from Camel without akka?
>>>
>>>
>>> On Tue, Jul 29, 2014 at 3:25 PM, <[email protected]> wrote:
>>>
>>>> Hi,
>>>>
>>>> In our Akka based application there is a need to control the
>>>> UntypedConsumerActors ( required for flow control) who listen on the
>>>> endpoint URI's. Is there a way we can set up an custom poll strategy on
>>>> these Endpoint URI and consumers so that it polls (consumes messages from
>>>> Endpoint which is HornetQ) when required and otherwise not. Kindly help.
>>>>
>>>> --
>>>> >>>>>>>>>> Read the docs: http://akka.io/docs/
>>>> >>>>>>>>>> Check the FAQ: http://doc.akka.io/docs/akka/
>>>> current/additional/faq.html
>>>> >>>>>>>>>> Search the archives: https://groups.google.com/
>>>> group/akka-user
>>>> ---
>>>> You received this message because you are subscribed to the Google
>>>> Groups "Akka User List" group.
>>>> To unsubscribe from this group and stop receiving emails from it, send
>>>> an email to [email protected].
>>>> To post to this group, send email to [email protected].
>>>>
>>>> Visit this group at http://groups.google.com/group/akka-user.
>>>> For more options, visit https://groups.google.com/d/optout.
>>>>
>>>
>>>
>>>
>>> --
>>> Martynas Mickevičius
>>> Typesafe <http://typesafe.com/> – Reactive
>>> <http://www.reactivemanifesto.org/> Apps on the JVM
>>>
>> --
>> >>>>>>>>>> Read the docs: http://akka.io/docs/
>> >>>>>>>>>> Check the FAQ:
>> http://doc.akka.io/docs/akka/current/additional/faq.html
>> >>>>>>>>>> Search the archives: https://groups.google.com/group/akka-user
>> ---
>> You received this message because you are subscribed to the Google Groups
>> "Akka User List" group.
>> To unsubscribe from this group and stop receiving emails from it, send an
>> email to [email protected] <javascript:>.
>> To post to this group, send email to [email protected]
>> <javascript:>.
>> Visit this group at http://groups.google.com/group/akka-user.
>> For more options, visit https://groups.google.com/d/optout.
>>
>
>
>
> --
> Cheers,
> Konrad 'ktoso' Malawski
> hAkker @ Typesafe
>
> <http://typesafe.com>
>
--
>>>>>>>>>> Read the docs: http://akka.io/docs/
>>>>>>>>>> Check the FAQ:
>>>>>>>>>> http://doc.akka.io/docs/akka/current/additional/faq.html
>>>>>>>>>> Search the archives: https://groups.google.com/group/akka-user
---
You received this message because you are subscribed to the Google Groups "Akka
User List" group.
To unsubscribe from this group and stop receiving emails from it, send an email
to [email protected].
To post to this group, send email to [email protected].
Visit this group at http://groups.google.com/group/akka-user.
For more options, visit https://groups.google.com/d/optout.
