You are viewing a plain text version of this content. The canonical link for it is here.
Posted to users@servicemix.apache.org by Dave Stanley <ds...@gmail.com> on 2009/04/07 16:56:27 UTC
Re: SMX 3.2.3 JMS consumer does not work?!
Ivan, can you try the flow without jms transactions. I'm curious to know if
that changes the behaviour.
/Dave
On Wed, Apr 1, 2009 at 10:29 AM, jonesgeek <wi...@jonesgeeks.com> wrote:
>
> When you're referencing beans from the application context, aren't you
> suppose to use the # sign?
>
> so marshaler="marshaler" should be marshaler="#marshaler"
> and connectionFactory="connectionFactory" should be
> connectionFactory="#connectionFactory"?
>
> Will
>
>
> Ivan Pryvalov wrote:
> >
> > Ivan Pryvalov пишет:
> >> Hi!
> >>
> >> I looked at admin console of AMQ and found that messages has not read.
> >> Also there is 1 active consumer. So, it seems, it is hanging of
> >> amq/jms-consumer.
> >>
> >> What configuration of jms-consumer more stable? Should I use another
> >> CASHE_LEVEL, or maybe it is issue in activemq-core-4.1.1.jar ?
> >
> > Also it seems servicemix-internal-flow is died... JMX-client (jconsole)
> > works normally about 1-2 minutes, then does not respond...
> > Service can be undeploied, but if try to deploy again - no messages in
> > console.
> >
> > Any ideas?
> >
> >
> > Ivan Pryvalov.
> >
> >>
> >>
> >> Thanks,
> >> Truly yours,
> >> Ivan Pryvalov.
> >>
> >>
> >>
> >> Ivan Pryvalov пишет:
> >>> Jean-Baptiste Onofré пишет:
> >>>> Hi Ivan,
> >>>>
> >>>> I guess that your marshaller implements the
> >>>> org.apache.servicemix.jms.JmsMarshaler interface.
> >>>
> >>> I used following (as base from servicemix-jms component):
> >>>
> >>> public class CustomConsumerMarshaler implements JmsConsumerMarshaler
> >>>
> >>> public class CustomProviderMarshaler implements JmsProviderMarshaler
> >>>
> >>>
> >>>>
> >>>> Have you try to add debug message in entry of the toSOAP() and
> >>>> toJMS() methods to check if the message is lost before using the
> >>>> marshaler, in the marshaler or after ?
> >>>>
> >>>> Regards
> >>>> JB
> >>>>
> >>>> On Monday 02 March 2009 - 21:40, Ivan Pryvalov wrote:
> >>>>> Hi servicemix-community!
> >>>>>
> >>>>>
> >>>>> Recently I faced some issue:
> >>>>>
> >>>>> Env: SMX 3.2.3, external ActiveMQ 5.1.0. SMX has service-assembly
> >>>>> which consist of jms-provider and jms-consumer.
> >>>>>
> >>>>> Jms-provider consumers NormilizedMessages, convert it to JMS-message
> >>>>> and send to some queue A.
> >>>>>
> >>>>> Jms-consumer consumers JMS-messages from queue A, convert it to NM
> >>>>> and send NM to destination endpoint.
> >>>>>
> >>>>> So, workflow is very simple.
> >>>>>
> >>>>> In both provider- and consumer- jms-endpoints I use custom
> >>>>> marchallers and some debug log is written.
> >>>>>
> >>>>> Today I found that jms-consumer reads jms-messages, but no one
> >>>>> debug messages is written in console... and destination endpoint
> >>>>> does not get new NormilizedMessage... So, message is lost...
> >>>>>
> >>>>> I saw ActiveMq 5.1.0 web-console and count of messages sent equals
> >>>>> to count of messages read for queue A. So, jms-consumer really has
> >>>>> read jms-message. But message lost somewhere beetwen reading
> >>>>> jms-message and executing consumer's code.
> >>>>>
> >>>>> Only reconfiguring and redeploying of SA with another queue B helped
> >>>>> me.
> >>>>>
> >>>>>
> >>>>> Have someone faced this issue? Maybe my configuration is not good?
> >>>>>
> >>>>>
> >>>>>
> >>>>> /* xbean.xml of jms-consumer */
> >>>>>
> >>>>> <jms:consumer service="oxmail:mailSenderService"
> >>>>> endpoint="jmsConsumerEndpoint"
> >>>>> targetService="oxmail:mailSenderService"
> >>>>> targetInterface="oxmail:mailSenderService"
> >>>>> destinationName="some.queue.A"
> >>>>> connectionFactory="connectionFactory"
> >>>>> concurrentConsumers="1"
> >>>>>
> >>>>> marshaler="marshaler"
> >>>>>
> >>>>> synchronous="yes"
> >>>>> transacted="jms"
> >>>>> />
> >>>>>
> >>>>> <bean id="marshaler" class="test.CustomConsumerMarshaler">
> >>>>> <property name="mep"
> >>>>> value="http://www.w3.org/2004/08/wsdl/in-only" />
> >>>>> </bean>
> >>>>>
> >>>>> <amq:connectionFactory id="connectionFactory"
> >>>>> brokerURL="tcp://localhost:61616" />
> >>>>>
> >>>>>
> >>>>>
> >>>>>
> >>>>> Truly yours,
> >>>>> Ivan Pryvalov.
> >>>>>
> >>>>
> >>>
> >>>
> >>
> >>
> >
> >
> >
>
> --
> View this message in context:
> http://www.nabble.com/SMX-3.2.3--JMS-consumer-does-not-work-%21-tp22295151p22827781.html
> Sent from the ServiceMix - User mailing list archive at Nabble.com.
>
>
Re: SMX 3.2.3 JMS consumer does not work?!
Posted by Gert Vanthienen <ge...@gmail.com>.
Ivan,
Another thing: I notice the Exchange gets sent over the JMS Flow. Are
you using a second container with clustering or do you have another
use case for using that flow? If not, could you try disabling the
flow to see if that helps (cfr.
http://servicemix.apache.org/nmr-flows.html at the bottom of the
page)?
Regards,
Gert Vanthienen
------------------------
Open Source SOA: http://fusesource.com
Blog: http://gertvanthienen.blogspot.com/
2009/4/7 Dave Stanley <ds...@gmail.com>:
> Ivan, can you try the flow without jms transactions. I'm curious to know if
> that changes the behaviour.
>
> /Dave
>
> On Wed, Apr 1, 2009 at 10:29 AM, jonesgeek <wi...@jonesgeeks.com> wrote:
>
>>
>> When you're referencing beans from the application context, aren't you
>> suppose to use the # sign?
>>
>> so marshaler="marshaler" should be marshaler="#marshaler"
>> and connectionFactory="connectionFactory" should be
>> connectionFactory="#connectionFactory"?
>>
>> Will
>>
>>
>> Ivan Pryvalov wrote:
>> >
>> > Ivan Pryvalov пишет:
>> >> Hi!
>> >>
>> >> I looked at admin console of AMQ and found that messages has not read.
>> >> Also there is 1 active consumer. So, it seems, it is hanging of
>> >> amq/jms-consumer.
>> >>
>> >> What configuration of jms-consumer more stable? Should I use another
>> >> CASHE_LEVEL, or maybe it is issue in activemq-core-4.1.1.jar ?
>> >
>> > Also it seems servicemix-internal-flow is died... JMX-client (jconsole)
>> > works normally about 1-2 minutes, then does not respond...
>> > Service can be undeploied, but if try to deploy again - no messages in
>> > console.
>> >
>> > Any ideas?
>> >
>> >
>> > Ivan Pryvalov.
>> >
>> >>
>> >>
>> >> Thanks,
>> >> Truly yours,
>> >> Ivan Pryvalov.
>> >>
>> >>
>> >>
>> >> Ivan Pryvalov пишет:
>> >>> Jean-Baptiste Onofré пишет:
>> >>>> Hi Ivan,
>> >>>>
>> >>>> I guess that your marshaller implements the
>> >>>> org.apache.servicemix.jms.JmsMarshaler interface.
>> >>>
>> >>> I used following (as base from servicemix-jms component):
>> >>>
>> >>> public class CustomConsumerMarshaler implements JmsConsumerMarshaler
>> >>>
>> >>> public class CustomProviderMarshaler implements JmsProviderMarshaler
>> >>>
>> >>>
>> >>>>
>> >>>> Have you try to add debug message in entry of the toSOAP() and
>> >>>> toJMS() methods to check if the message is lost before using the
>> >>>> marshaler, in the marshaler or after ?
>> >>>>
>> >>>> Regards
>> >>>> JB
>> >>>>
>> >>>> On Monday 02 March 2009 - 21:40, Ivan Pryvalov wrote:
>> >>>>> Hi servicemix-community!
>> >>>>>
>> >>>>>
>> >>>>> Recently I faced some issue:
>> >>>>>
>> >>>>> Env: SMX 3.2.3, external ActiveMQ 5.1.0. SMX has service-assembly
>> >>>>> which consist of jms-provider and jms-consumer.
>> >>>>>
>> >>>>> Jms-provider consumers NormilizedMessages, convert it to JMS-message
>> >>>>> and send to some queue A.
>> >>>>>
>> >>>>> Jms-consumer consumers JMS-messages from queue A, convert it to NM
>> >>>>> and send NM to destination endpoint.
>> >>>>>
>> >>>>> So, workflow is very simple.
>> >>>>>
>> >>>>> In both provider- and consumer- jms-endpoints I use custom
>> >>>>> marchallers and some debug log is written.
>> >>>>>
>> >>>>> Today I found that jms-consumer reads jms-messages, but no one
>> >>>>> debug messages is written in console... and destination endpoint
>> >>>>> does not get new NormilizedMessage... So, message is lost...
>> >>>>>
>> >>>>> I saw ActiveMq 5.1.0 web-console and count of messages sent equals
>> >>>>> to count of messages read for queue A. So, jms-consumer really has
>> >>>>> read jms-message. But message lost somewhere beetwen reading
>> >>>>> jms-message and executing consumer's code.
>> >>>>>
>> >>>>> Only reconfiguring and redeploying of SA with another queue B helped
>> >>>>> me.
>> >>>>>
>> >>>>>
>> >>>>> Have someone faced this issue? Maybe my configuration is not good?
>> >>>>>
>> >>>>>
>> >>>>>
>> >>>>> /* xbean.xml of jms-consumer */
>> >>>>>
>> >>>>> <jms:consumer service="oxmail:mailSenderService"
>> >>>>> endpoint="jmsConsumerEndpoint"
>> >>>>> targetService="oxmail:mailSenderService"
>> >>>>> targetInterface="oxmail:mailSenderService"
>> >>>>> destinationName="some.queue.A"
>> >>>>> connectionFactory="connectionFactory"
>> >>>>> concurrentConsumers="1"
>> >>>>>
>> >>>>> marshaler="marshaler"
>> >>>>>
>> >>>>> synchronous="yes"
>> >>>>> transacted="jms"
>> >>>>> />
>> >>>>>
>> >>>>> <bean id="marshaler" class="test.CustomConsumerMarshaler">
>> >>>>> <property name="mep"
>> >>>>> value="http://www.w3.org/2004/08/wsdl/in-only" />
>> >>>>> </bean>
>> >>>>>
>> >>>>> <amq:connectionFactory id="connectionFactory"
>> >>>>> brokerURL="tcp://localhost:61616" />
>> >>>>>
>> >>>>>
>> >>>>>
>> >>>>>
>> >>>>> Truly yours,
>> >>>>> Ivan Pryvalov.
>> >>>>>
>> >>>>
>> >>>
>> >>>
>> >>
>> >>
>> >
>> >
>> >
>>
>> --
>> View this message in context:
>> http://www.nabble.com/SMX-3.2.3--JMS-consumer-does-not-work-%21-tp22295151p22827781.html
>> Sent from the ServiceMix - User mailing list archive at Nabble.com.
>>
>>
>