Jonnie,
in transacted mode, who is managing the transaction demarcation? In
other words, where is the session.commit() call?
2009/2/8 sweetjonnie <jonniesav...@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
