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.
