Mailing-List: contact users-help@activemq.apache.org; run by ezmlm
Precedence: bulk
Reply-To: users@activemq.apache.org
Received-SPF: pass (athena.apache.org: domain of gary.tully@gmail.com
 designates 209.85.128.190 as permitted sender)
DomainKey-Signature: a=rsa-sha1; c=nofws;
        d=gmail.com; s=gamma;
        h=mime-version:in-reply-to:references:date:message-id:subject:from:to
         :content-type:content-transfer-encoding;
        b=tgAmXwoleXTgeO2WTT/sI7TCjIHyHP1KrKjSzGq5NxJaomoiTLJzoFs1Rb7BLMxU5L
         Ik0FUYt5LB31zcUiG0VeiwFBWq7QEmSYXzicf5TOZfgwDy1oHcy6kHJbhTCCp8uH37HP
         VhskAu25N7MInuomiY1ILFBajGqRnl7uMG/sU=
MIME-Version: 1.0
In-Reply-To: <21895847.post@talk.nabble.com>
References: <21438163.post@talk.nabble.com> <21440240.post@talk.nabble.com>
	 <3a73c17c0901131024x4add14b5v220dd60ed2cb64d3@mail.gmail.com>
	 <21442857.post@talk.nabble.com>
	 <7b3355cb0901131143p777046ecte017761cb4bcc794@mail.gmail.com>
	 <21443338.post@talk.nabble.com>
	 <5a56ce1b0901301602o553c4b96k72455fa2034287e4@mail.gmail.com>
	 <C5B03A98.7827%Bill_Schuller@intuit.com>
	 <5a56ce1b0902051041g518c3c2q1a05895844f2b234@mail.gmail.com>
	 <21895847.post@talk.nabble.com>
Date: Mon, 9 Feb 2009 10:45:16 +0000
Message-ID: <3a73c17c0902090245i22ae418ct7dc7c3b29cfe6c8@mail.gmail.com>
Subject: Re: Q Consumers stop receiving messages
From: Gary Tully <gary.tully@gmail.com>
To: users@activemq.apache.org
Content-Type: text/plain; charset=ISO-8859-1
Content-Transfer-Encoding: 7bit

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