This problem is only found 2 times, I have no dump file.
This is the configuration of the producer
mq.brokerURL=failover:(tcp://192.168.83.64:61616?wireFormat.maxInactivityDuration=0)&maxReconnectDelay=1000
mq.userName=admin
mq.password=123456
mq.maxConnections=1
mq.maximumActiveSessionPerConnection=500

<context:property-placeholder location="classpath*:/activemq.properties" />
        <bean id="connectionFactory"
class="org.apache.activemq.pool.PooledConnectionFactory"
destroy-method="stop">
                <property name="connectionFactory">
                        <bean 
class="org.apache.activemq.ActiveMQConnectionFactory">
                                <property name="brokerURL" 
value="${mq.brokerURL}" />
                                <property name="userName" 
value="${mq.userName}" />
                                <property name="password" 
value="${mq.password}" />
                        </bean>
                </property>
                <property name="maxConnections" value="${mq.maxConnections}" />
                <property name="maximumActiveSessionPerConnection"
value="${mq.maximumActiveSessionPerConnection}" />
        </bean>

        <bean id="queueDestination"
class="org.apache.activemq.command.ActiveMQQueue">
                <constructor-arg index="0" value="xhGeek.demo" />
        </bean>
        <bean id="jmsQueueTemplate"
class="org.springframework.jms.core.JmsTemplate">
                <property name="connectionFactory" ref="connectionFactory" />
                <property name="defaultDestination" ref="queueDestination" />
                <property name="receiveTimeout" value="10000"></property>
        </bean>

        <bean id="senderService"
class="com.xinhuanet.mq.service.impl.SenderServiceImpl">
                <property name="jmsTemplate" ref="jmsQueueTemplate"></property>
                <property name="destinations">
                        <map>
                                <entry key="xhGeek.demo">
                                        <bean 
class="org.apache.activemq.command.ActiveMQQueue">
                                                <constructor-arg index="0" 
value="xhGeek.demo" />
                                        </bean>
                                </entry>
                                <entry key="xhGeek.test">
                                        <bean 
class="org.apache.activemq.command.ActiveMQQueue">
                                                <constructor-arg index="0" 
value="xhGeek.test" />
                                        </bean>
                                </entry>
                                <entry key="xhGeek.test2">
                                        <bean 
class="org.apache.activemq.command.ActiveMQQueue">
                                                <constructor-arg index="0" 
value="xhGeek.test2" />
                                        </bean>
                                </entry>
                                <entry key="xhGeek.msg-center.message">
                                        <bean 
class="org.apache.activemq.command.ActiveMQQueue">
                                                <constructor-arg index="0" 
value="xhGeek.msg-center.message" />
                                        </bean>
                                </entry>
                                <entry key="xhGeek.msg-center.fqremove">
                                        <bean 
class="org.apache.activemq.command.ActiveMQQueue">
                                                <constructor-arg index="0" 
value="xhGeek.msg-center.fqremove" />
                                        </bean>
                                </entry>
                                <entry 
key="xhGeek.relationship-center.changepoint">
                                        <bean 
class="org.apache.activemq.command.ActiveMQQueue">
                                                <constructor-arg index="0"
value="xhGeek.relationship-center.changepoint" />
                                        </bean>
                                </entry>

                                .....   (About 30)

                                <entry key="xhMobile.credit">
                                        <bean 
class="org.apache.activemq.command.ActiveMQQueue">
                                                <constructor-arg index="0" 
value="xhMobile.credit" />
                                        </bean>
                                </entry>
                        </map>
                </property>
        </bean>

        <bean id="topicDestination"
class="org.apache.activemq.command.ActiveMQTopic">
                <constructor-arg index="0" value="xhGeek-topic" />
        </bean>
        <bean id="jmsTopicTemplate"
class="org.springframework.jms.core.JmsTemplate">
                <property name="connectionFactory" ref="connectionFactory" />
                <property name="defaultDestination" ref="topicDestination" />
                <property name="pubSubDomain" value="true" />
                <property name="receiveTimeout" value="10000" />
        </bean>
        <bean id="publisherService"
class="com.xinhuanet.mq.service.impl.PublisherServiceImpl">
                <property name="jmsTemplate" ref="jmsTopicTemplate"></property>
                <property name="destinations">
                        <map>
                                <entry key="VirtualTopic.xhGeek.authSystem">
                                        <bean 
class="org.apache.activemq.command.ActiveMQTopic">
                                                <constructor-arg index="0" 
value="VirtualTopic.xhGeek.authSystem" />
                                        </bean>
                                </entry>
                                <entry key="VirtualTopic.xhInteract.picture">
                                        <bean 
class="org.apache.activemq.command.ActiveMQTopic">
                                                <constructor-arg index="0" 
value="VirtualTopic.xhInteract.picture" />
                                        </bean>
                                </entry>
                                <entry key="VirtualTopic.xhInteract.video">
                                        <bean 
class="org.apache.activemq.command.ActiveMQTopic">
                                                <constructor-arg index="0" 
value="VirtualTopic.xhInteract.video" />
                                        </bean>
                                </entry>
                                <entry key="VirtualTopic.xhGeek.test">
                                        <bean 
class="org.apache.activemq.command.ActiveMQTopic">
                                                <constructor-arg index="0" 
value="VirtualTopic.xhGeek.test" />
                                        </bean>
                                </entry>
                                <entry key="VirtualTopic.xhGeek.liveUserMGT">
                                        <bean 
class="org.apache.activemq.command.ActiveMQTopic">
                                                <constructor-arg index="0" 
value="VirtualTopic.xhGeek.liveUserMGT" />
                                        </bean>
                                </entry>
                                <entry key="xhGeek.testtopic">
                                        <bean 
class="org.apache.activemq.command.ActiveMQTopic">
                                                <constructor-arg index="0" 
value="xhGeek.testtopic" />
                                        </bean>
                                </entry>
                                <entry key="xhShop.staticHtml">
                                        <bean 
class="org.apache.activemq.command.ActiveMQTopic">
                                                <constructor-arg index="0" 
value="xhShop.staticHtml" />
                                        </bean>
                                </entry>
                                <entry key="VirtualTopic.xhGeek.notice">
                                        <bean 
class="org.apache.activemq.command.ActiveMQTopic">
                                                <constructor-arg index="0" 
value="VirtualTopic.xhGeek.notice" />
                                        </bean>
                                </entry>
                        </map>
                </property>
        </bean>



--
View this message in context: 
http://activemq.2283324.n4.nabble.com/activemq-3000-messages-can-not-be-received-tp4715396p4715643.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Reply via email to