activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Gary Tully <gary.tu...@gmail.com>
Subject Re: Q Consumers stop receiving messages
Date Mon, 09 Feb 2009 10:45:16 GMT
Jonnie,
in transacted mode, who is managing the transaction demarcation? In
other words, where is the session.commit() call?

2009/2/8 sweetjonnie <jonniesavell@yahoo.com>:
>
> at least one in the thread mentioned persistence and i wonder if my problem
> is related.
>
> i am newbie/retarded and cannot get my embedded broker to deliver transacted
> messages to my async client in my ActiveMQ 5.2 environment.
>
> connection.createSession(false, Session.AUTO_ACKNOWLEDGE) works: message is
> delivered.
> connection.createSession(true, Session.SESSION_TRANSACTED) fails: message is
> not delivered although no errors appear.
>
> When a transacted session is created, the bad behavior is detected
> regardless of whether amqPersistenceAdapter or journaledJDBC is specified as
> the persistence method.
>
> Would someone be willing to take a look at the following excerpts and tell
> me if they spot an error (and if so, what it is)? I thank all for their
> time.
>
> What follows are the contents of two configuration files:
> (1) application configuration:
> <beans>
>    <bean id="broker"
>          class="org.apache.activemq.xbean.BrokerFactoryBean">
>        <property name="config" value="classpath:QueueConfiguration.xml" />
>        <property name="start" value="true"/>
>    </bean>
>
>    <bean id="connectionFactory"
>          class="org.apache.activemq.ActiveMQConnectionFactory"
>          depends-on="broker">
>        <property name="brokerURL" value="vm://localhost"/>
>    </bean>
>
>    <!-- autowire="constructor" -->
>    <bean id="staging"
>          class="org.apache.activemq.command.ActiveMQQueue">
>        <constructor-arg index="0" value="internal"/>
>    </bean>
> </beans>
>
> (2) the configuration file above references QueueConfiguration.xml which is
> listed below:
> <beans>
>    <bean
> class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer">
>        <property name="locations">
>
> <value>classpath:com.indigententerprises.configuration.internalqueuing.properties</value>
>        </property>
>    </bean>
>
>    <bean id="derby-ds"
>          class="org.apache.derby.jdbc.EmbeddedDataSource">
>        <property name="databaseName" value="derbydb"/>
>        <property name="createDatabase" value="create"/>
>    </bean>
>
>    <!-- embedded -->
>    <amq:broker useJmx="false"
>                brokerName="localhost"
>                dataDirectory="${brokerdirectory}"
>                persistent="true">
>        <amq:persistenceAdapter>
>            <!-- amq:amqPersistenceAdapter syncOnWrite="true"
>
> directory="${amqpersistencedirectory}"
>                                           maxFileLength="20 mb"/ -->
>
>            <amq:journaledJDBC dataDirectory="${amqpersistencedirectory}"
> dataSource="#derby-ds"/>
>        </amq:persistenceAdapter>
>        <amq:transportConnectors/>
>    </amq:broker>
> </beans>
>
>
> --
> View this message in context: http://www.nabble.com/Q-Consumers-stop-receiving-messages-tp21438163p21895847.html
> Sent from the ActiveMQ - User mailing list archive at Nabble.com.
>
>



-- 
http://blog.garytully.com

Open Source SOA
http://FUSESource.com

Mime
View raw message