Return-Path: 
 <users-return-31593-apmail-activemq-users-archive=activemq.apache.org@activemq.apache.org>
X-Original-To: apmail-activemq-users-archive@www.apache.org
Delivered-To: apmail-activemq-users-archive@www.apache.org
Received: from mail.apache.org (hermes.apache.org [140.211.11.3])
	by minotaur.apache.org (Postfix) with SMTP id 653C6D0D0
	for <apmail-activemq-users-archive@www.apache.org>;
 Mon, 20 Aug 2012 23:28:27 +0000 (UTC)
Received: (qmail 1626 invoked by uid 500); 20 Aug 2012 23:28:26 -0000
Delivered-To: apmail-activemq-users-archive@activemq.apache.org
Received: (qmail 1574 invoked by uid 500); 20 Aug 2012 23:28:26 -0000
Mailing-List: contact users-help@activemq.apache.org; run by ezmlm
Precedence: bulk
List-Help: <mailto:users-help@activemq.apache.org>
List-Unsubscribe: <mailto:users-unsubscribe@activemq.apache.org>
List-Post: <mailto:users@activemq.apache.org>
List-Id: <users.activemq.apache.org>
Reply-To: users@activemq.apache.org
Delivered-To: mailing list users@activemq.apache.org
Received: (qmail 1564 invoked by uid 99); 20 Aug 2012 23:28:26 -0000
Received: from athena.apache.org (HELO athena.apache.org) (140.211.11.136)
    by apache.org (qpsmtpd/0.29) with ESMTP; Mon, 20 Aug 2012 23:28:26 +0000
X-ASF-Spam-Status: No, hits=2.0 required=5.0
	tests=SPF_NEUTRAL,URI_HEX
X-Spam-Check-By: apache.org
Received-SPF: neutral (athena.apache.org: 216.139.250.139 is neither permitted
 nor denied by domain of claudio.santana@gmail.com)
Received: from [216.139.250.139] (HELO joe.nabble.com) (216.139.250.139)
    by apache.org (qpsmtpd/0.29) with ESMTP; Mon, 20 Aug 2012 23:28:21 +0000
Received: from [192.168.236.139] (helo=joe.nabble.com)
	by joe.nabble.com with esmtp (Exim 4.72)
	(envelope-from <claudio.santana@gmail.com>)
	id 1T3bO5-0007Ts-1z
	for users@activemq.apache.org; Mon, 20 Aug 2012 16:28:01 -0700
Date: Mon, 20 Aug 2012 16:28:01 -0700 (PDT)
From: pollotek <claudio.santana@gmail.com>
To: users@activemq.apache.org
Message-ID: <1345505281047-4655340.post@n4.nabble.com>
In-Reply-To: 
 <CAKWiyj1JH7+MdwQ=qCcPxF76SPrSoASOAkA6TX1K67bLLK0U8A@mail.gmail.com>
References: <1344651659040-4655028.post@n4.nabble.com>
 <53234E90-4CD0-4D54-A20F-F0301A1B1A21@fusesource.com>
 <CAKWiyj1JH7+MdwQ=qCcPxF76SPrSoASOAkA6TX1K67bLLK0U8A@mail.gmail.com>
Subject: Re: Store and Forward with embedded brokers + stand alone broker
MIME-Version: 1.0
Content-Type: text/plain; charset=us-ascii
Content-Transfer-Encoding: 7bit
X-Virus-Checked: Checked by ClamAV on apache.org

Torsten, I just tried the configuration you suggested. I made my consumer
Network Connectors duplex and I still don't see any messages making it to
the consumers.

If I connect with JMX to the stand alone broker I can see under
org.apache.activemq.broker.Connection.openwire my 3 producers connected, I
can identify the IP addresses of the servers. 

Under org.apache.activemq.broker.NetworkBridge I see my two duplex clients,
I see in the connection attributes CreatedByDuplex=true. I also see under
org.apache.activemq.brokerQueue.<name-of-my-queue>.Attributes.Subscriptions
my consumers as subscribers.

I implemented listeners for the queue advisories on the embedded brokers.
After I place a new message on the producer side I see the size of the queue
growing on the producer embedded broker but I don't see dequeueCount or
inflightCount ever changing from 0, only size changes. On the stand alone
broker queue stats I don't see EnqueueCount, DispatchCount, InFlightCount or
QueueSize ever changing from 0 either.

I also see on the stand alone broker's log messages like this one, one per
duplex consumer:

2012-08-20 21:40:03,574 | INFO  | Started responder end of duplex bridge
connection_to_nob-10.17.163.168-8080@ID:mc02-48630-1345498803060-0:1 |
org.apache.activemq.broker.TransportConnection | ActiveMQ Transport:
tcp:///10.17.163.168:56989
2012-08-20 21:40:03,576 | INFO  | Network connection between vm://broker#2
and tcp:///10.17.163.168:56989(localhost) has been established. |
org.apache.activemq.network.DemandForwardingBridgeSupport |
StartLocalBridge: localBroker=vm://broker#2

Do you guys have any other ideas? Would it be handy to submit configuration
files or log files on a specific log level to help solve this issue?

It's very strange that if I test the topology you suggested to test first,
to have only embedded brokers on the producer side but the consumers
connected directly messages actually flow. But if they both have embedded
brokers messages just don't flow to the consumers.



--
View this message in context: http://activemq.2283324.n4.nabble.com/Store-and-Forward-with-embedded-brokers-stand-alone-broker-tp4655028p4655340.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.