You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@activemq.apache.org by "Timothy Bish (JIRA)" <ji...@apache.org> on 2018/01/12 15:00:00 UTC
[jira] [Commented] (AMQ-6885) NetworkConnector working only in
forward [ not working in reverse ]
[ https://issues.apache.org/jira/browse/AMQ-6885?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16324082#comment-16324082 ]
Timothy Bish commented on AMQ-6885:
-----------------------------------
Version 5.12.x is not a supported version. You would need to move to a supported version and try that. For help with configuration you should be asking on the users mailing list.
> NetworkConnector working only in forward [ not working in reverse ]
> -------------------------------------------------------------------
>
> Key: AMQ-6885
> URL: https://issues.apache.org/jira/browse/AMQ-6885
> Project: ActiveMQ
> Issue Type: Bug
> Components: activemq-camel, activemq-pool
> Affects Versions: 5.12.3
> Reporter: Rajesh Malla
>
> We are using request/reply message pattern : *Broker1 <- -> Broker2 -> Consumer*
> producer sending request message to Broker1, using n/w connector [DiscoveryNetworkConnector] message forward to Broker2. Consumer who is receiving message from Broker2 and responding to Broker2. Till this part is working, which should further forward to Broker1 which is not happening.
> Broker1 creating temp-queue and listening on that, same temp-queue name created in broker2 and sends to Consumer.
> When consumer is responding to that broker2 - temp-queue, here messages are not moving to Broker1.
> 1) we are using http transport connectors
> 2) broker1 -> broker2 [prefetch=1000 default], DiscoveryNetworkConnector
> 3) broker -> consumer [queuePrefetch = 0 working by applying patch of MessagePull from AMQ-6877]
> 4) components : servicemix 5.6.0 [ AMQ 5.12.3, CAMEL-JMS 2.16.2], *jdk 1.8*
> 5) we are using n/w connectors
> broker1 -> broker2 [httpconnector]
> broker2 -> broker1 [httpconnector]
> Code adding networkconnector :
> URI uri = new URI("static://" + server.getUrl());
> NetworkConnector networkConnector = new DiscoveryNetworkConnector(uri);
> networkConnector.setBrokerURL(server.getUrl());
> for (String queueName : listOfQueues)
> networkConnector.addDynamicallyIncludedDestination(new ActiveMQQueue(queueName));
> for (String queueName : excludedQueues)
> networkConnector.addExcludedDestination(new ActiveMQQueue(queueName));
> networkConnector.setName(uniqueName);
> networkConnector.setPassword(pwd);
> networkConnector.setUserName(username);
> broker.addNetworkConnector(networkConnector);
> activemq.xml :
> <broker id="broker"
> brokerName="jbroker"
> dataDirectory="basedir/activemq"
> xmlns="http://activemq.apache.org/schema/core"
> sslContext="mainsslConxt"
> persistent="false"
> populateJMSXUserID="true">
>
> <destinationPolicy>
> <policyMap>
> <policyEntries>
>
> <policyEntry queue=">" producerFlowControl="true" useCache="false" memoryLimit="64 mb">
> <deadLetterStrategy>
> <individualDeadLetterStrategy />
> </deadLetterStrategy>
> </policyEntry>
> </policyEntries>
> </policyMap>
> <managementContext>
> <managementContext createMBeanServer="false" createConnector="false" />
> </managementContext>
> <plugins>
>
> <authorizationPlugin>
> <map>
> <authorizationMap>
> <authorizationEntries>
> <authorizationEntry queue=">" read="ALL" write="ALL" admin="ADMIN" />
>
> </authorizationEntries>
> </authorizationMap>
> </map>
> </authorizationPlugin>
>
> <discardingDLQBrokerPlugin dropAll="false" dropOnly="(?!xyz).*" dropTemporaryTopics="true" dropTemporaryQueues="true" />
> </plugins>
>
> <transportConnectors>
> <transportConnector name="http" uri="http://0.0.0.0:port1" />
> <transportConnector name="https" uri="https://0.0.0.0:port2" />
> </transportConnectors>
> </broker>
--
This message was sent by Atlassian JIRA
(v6.4.14#64029)