activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Tim Bain <tb...@alumni.duke.edu>
Subject Re: Reply message not forwarded across temporary bridged destination
Date Tue, 09 Dec 2014 02:06:05 GMT
Your <dynamicallyIncludedDestinations> doesn't appear to include any rule
that would result in messages and subscriptions on the temporary reply
queue being bridged between the brokers; it looks to me like you're only
bridging the request queue.

On Mon, Dec 8, 2014 at 3:56 PM, azdvorak <alex.zdvorak@gmail.com> wrote:

> After upgrading from ActiveMQ 5.6 to 5.10, reply messages (initiated from a
> request / reply transaction) are not being forwarded across the temporary
> destination created for the reply message.
>
> Setup:
>
> *AMQ-A and AMQ-B are configured in a static network of brokers
> (configuration below).
> *Distributed queue, "test.distributed.queue", will be used for
> communication.
> *Consumer (that is to handle request / reply) is consuming on AMQ-A
> "test.distributed.queue"
>
> Observed Behavior:
>
> *A request/reply message is published to AMQ-B "test.distributed.queue"
> **The replyTo Temporary Queue is created, and a consumer is attached to
> destination. I see it instantiated on both AMQ brokers via DEBUG level
> logging.
> *The message is forwarded across the network of brokers : AMQ-B > AMQ-A
> "test.distributed.queue"
> *The Consumer receives the message & performs the business logic task
> *The Consumer sends response to the temporary destination on AMQ-A
> ** PROBLEM: The message is not forwarded to AMQ-B where the producer is
> listening for the response.
> *The timeout interval expires
> *The temporary destination is destroyed
> **I see the message is purged in the AMQ-A log files as the temp
> destination
> is destroyed.
>
> With ActiveMQ 5.6 the reply message is forwarded across the temporary
> destination (AMQ-A > AMQ-B) such that the original producer was able to
> consume the response. When I turn on debug logging I do not see any errors
> or warnings. There is simply a lack of action (forwarding of the message).
>
> Is this a regression and/or did the behavior change?
> Is there something we need to change in our configuration (server or
> client)?
>
> Please let me know if I can provide any more information. Log levels,
> environment details etc.
>
> Here is our ActiveMQ broker (server) configuration for both AMQ-A and
> AMQ-B:
>
> <beans
>   xmlns="http://www.springframework.org/schema/beans"
>   xmlns:amq="http://activemq.apache.org/schema/core"
>   xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
>   xsi:schemaLocation="http://www.springframework.org/schema/beans
> http://www.springframework.org/schema/beans/spring-beans-2.0.xsd
>   http://activemq.apache.org/schema/core
> http://activemq.apache.org/schema/core/activemq-core.xsd
>   http://activemq.apache.org/camel/schema/spring
> http://activemq.apache.org/camel/schema/spring/camel-spring.xsd">
>
>
>     <bean
>
> class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer">
>         <property name="locations">
>                 <list>
>
> <value>file:///${activemq.base}/conf/credentials.properties</value>
>
> <value>file:/opt/company/activemq/config/activemq.properties</value>
>
> <value>file:/etc/opt/company/activemq/activemq.properties</value>
>                 </list>
>         </property>
>     </bean>
>
>     <broker xmlns="http://activemq.apache.org/schema/core"
>             brokerName="CompanyActiveMQ"
>             deleteAllMessagesOnStartup="false"
>             advisorySupport="true">
>
>
>
>        <destinationPolicy>
>            <policyMap>
>                 <policyEntries>
>                     <policyEntry
>                        queue="com.company.product.channels.>"
>                        producerFlowControl="false"
>                        memoryLimit="100mb" >
>
>                        <deadLetterStrategy>
>                            <individualDeadLetterStrategy
> processExpired="false" />
>                        </deadLetterStrategy>
>                     </policyEntry>
>
>                 </policyEntries>
>             </policyMap>
>         </destinationPolicy>
>
>
>         <managementContext>
>             <managementContext
>                 connectorPort="1099"
>                 jmxDomainName="org.apache.activemq"
>                 createConnector="false" />
>         </managementContext>
>
>
>
>         <networkConnectors>
>                 <networkConnector name="activemqNetworkConnector"
> decreaseNetworkConsumerPriority="true" networkTTL="2"
> uri="static:(tcp://${remote.network.host}:${remote.network.port})">
>                         <dynamicallyIncludedDestinations>
>                                 <queue
> physicalName="com.company.product.channels.test.distributed.queue"/>
>                         </dynamicallyIncludedDestinations>
>                 </networkConnector>
>         </networkConnectors>
>
>
>          <persistenceAdapter>
>
>              <kahaDB directory="${activemq.base}/data/kahadb" />
>         </persistenceAdapter>
>
>
>         <plugins>
>            <statisticsBrokerPlugin />
>         </plugins>
>
>
>          <sslContext>
>             <sslContext
>                 keyStore="file:${activemq.base}/conf/broker.ks"
>                 keyStorePassword="password"
>                 trustStore="file:${activemq.base}/conf/broker.ts"
>                 trustStorePassword="password"/>
>         </sslContext>
>
>
>         <systemUsage>
>             <systemUsage sendFailIfNoSpace="true">
>                 <memoryUsage>
>                     <memoryUsage limit="100 mb" percentUsageMinDelta="20"
> />
>                 </memoryUsage>
>                 <storeUsage>
>                     <storeUsage limit="2 gb" name="foo"/>
>                 </storeUsage>
>                 <tempUsage>
>                     <tempUsage limit="200 mb"/>
>                 </tempUsage>
>             </systemUsage>
>         </systemUsage>
>
>
>         <transportConnectors>
>             <transportConnector name="openwire" uri="tcp://0.0.0.0:61616"
> updateClusterClients="false" rebalanceClusterClients="false"
> updateClusterClientsOnRemove="false"/>
>
>
>         </transportConnectors>
>
>     </broker>
>
>
> </beans>
>
>
>
> --
> View this message in context:
> http://activemq.2283324.n4.nabble.com/Reply-message-not-forwarded-across-temporary-bridged-destination-tp4688578.html
> Sent from the ActiveMQ - User mailing list archive at Nabble.com.
>

Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message