activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From sweetjonnie <jonniesav...@yahoo.com>
Subject Re: Q Consumers stop receiving messages
Date Sun, 08 Feb 2009 04:30:14 GMT

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.


Mime
View raw message