activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From javierco <vjavi...@gmail.com>
Subject Re: Producer to Topic with Consumer down, the broker is waiting?
Date Mon, 10 Dec 2012 20:48:20 GMT
Here it is:
- running ActiveMQ 5.6.0 standalone on its own JVM and using the default
configuration, so I guess no need to post those files? (let me know
otherwise)
- running both producer and consumer on separate instances of Apache Tomcat
7.0.27
- app is using Spring Framework 3.1.1

- this is the bean config for the Producer:
        
        <bean id="jmsConnectionFactory"
class="org.apache.activemq.pool.PooledConnectionFactory"
            destroy-method="stop">
            <property name="connectionFactory">
                <bean class="org.apache.activemq.ActiveMQConnectionFactory">
                    <property name="brokerURL"
value="tcp://127.0.0.1:61616"/>
                </bean>
            </property>
        </bean>
        
        <bean id="destination"
class="org.apache.activemq.command.ActiveMQTopic">
            <constructor-arg value="broadcastTopic" />
        </bean>
        
        <bean id="jmsTemplate"
class="org.springframework.jms.core.JmsTemplate">
            <property name="connectionFactory" ref="jmsConnectionFactory" />
            <property name="defaultDestination" ref="destination" />
        </bean>
        
        <bean id="producer" class="JmsMessageProducer">
            <property name="template" ref="jmsTemplate" />
        </bean>

- this is the bean config for the Consumer
        
        <bean id="jmsConnectionFactory"
class="org.apache.activemq.pool.PooledConnectionFactory"
              destroy-method="stop">
            <property name="connectionFactory">
                <bean class="org.apache.activemq.ActiveMQConnectionFactory">
                    <property name="brokerURL"
value="tcp://127.0.0.1:61616"/>
                </bean>
            </property>
        </bean>
        
        <bean id="topicDestination"
class="org.apache.activemq.command.ActiveMQTopic">
            <constructor-arg value="broadcastTopic" />
        </bean>
        
        <bean id="consumer" class="JmsDataExchanger" />
        
        <bean id="messageListener"
class="org.springframework.jms.listener.SimpleMessageListenerContainer">
            <property name="connectionFactory" ref="jmsConnectionFactory" />
            <property name="destination" ref="topicDestination" />
            <property name="messageListener" ref="consumer" />
            <property name="subscriptionDurable" value="true" />
            <property name="clientId" value="myClient" />
            <property name="durableSubscriptionName" value="myClient" />
        </bean>

If this is not enough please let me know, I will try to recreate this issue
in a small test case in the meantime. Thanks!



--
View this message in context: http://activemq.2283324.n4.nabble.com/Producer-to-Topic-with-Consumer-down-the-broker-is-waiting-tp4660452p4660462.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Mime
View raw message