activemq-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Timothy Bish (JIRA)" <>
Subject [jira] [Closed] (AMQ-2056) Jencks container sometimes hangs when maxMessagesPerSessions is < maxSessions
Date Mon, 29 Oct 2012 20:10:12 GMT


Timothy Bish closed AMQ-2056.

    Resolution: Won't Fix

Jencks is EOL at this point.
> Jencks container sometimes hangs when maxMessagesPerSessions is < maxSessions
> -----------------------------------------------------------------------------
>                 Key: AMQ-2056
>                 URL:
>             Project: ActiveMQ
>          Issue Type: Bug
>          Components: JCA Container
>         Environment: Mac OX/X
>            Reporter: Adrian Trenaman
>             Fix For: 5.x
>         Attachments: jencks-blocking-consumers.tar
> I've found that if I configure Jencks with a low maxMessagesPerSessions (e.g. 3) and
a higher maxSessions (e.g. 8) then my consumers hang after about 30 messages and no more messages
get consumed.
> Any idea why this might be? I find that if I make the maxMessagesPerSessions (which AFAIK
matches the queue prefetch value) higher then it seems to work. I'm happy to do this, but
I'm puzzled as to why this occurs.
> Any help gratefully accepted - sample Spring config below. Also, I've attached sample
code to this issue. Run the RequestHandler server from within Eclipse against a standalone
broker, and then just use the ActiveMQ Web Console to sent 1000 messages to the queue RA.request
> /Ade
>     <bean id="listenerJcaConnector" class="org.jencks.JCAConnector">
>         <property name="jcaContainer" ref="jencksContainer"/>
>         <property name="transactionManager" ref="transactionManager"/>
>         <property name="activationSpec">
>                     <bean class="org.apache.activemq.ra.ActiveMQActivationSpec">
>                                 <property name="destination" value="RA.REQUEST"/>
>                                 <property name="destinationType" value="javax.jms.Queue"/>
>   <property name="maxSessions" value="8"/>
>                                 <property name="maxMessagesPerSessions" value="3"/>
<!-- effectively, this just matches the prefetch size -->
>                     </bean>
>         </property>
>         <property name="ref" value="messageListener"/>
>     </bean> 

This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators
For more information on JIRA, see:

View raw message