Mailing-List: contact users-help@activemq.apache.org; run by ezmlm
Precedence: bulk
Reply-To: users@activemq.apache.org
Received-SPF: pass (nike.apache.org: domain of christian.posta@gmail.com
 designates 209.85.210.177 as permitted sender)
MIME-Version: 1.0
In-Reply-To: <1357962185037-4661679.post@n4.nabble.com>
References: <1296518752949-2367852.post@n4.nabble.com>
	<1296518752950-2367853.post@n4.nabble.com>
	<F82AF9B8-C8B2-416C-82AC-01FC32FE6F2D@gmail.com>
	<1296518752935-2367855.post@n4.nabble.com>
	<1296518752926-3250209.post@n4.nabble.com>
	<1302591175903-3443852.post@n4.nabble.com>
	<1302625180388-3445066.post@n4.nabble.com>
	<1302685229549-3446638.post@n4.nabble.com>
	<1357962185037-4661679.post@n4.nabble.com>
Date: Sat, 12 Jan 2013 07:56:10 -0700
Message-ID: 
 <CAKS7T5N-fkJj_vdMbmdQq_LdVDBeam1njyDk-_U-arU08KG1tA@mail.gmail.com>
Subject: Re: Stuck messages - Dispatch issues
From: Christian Posta <christian.posta@gmail.com>
To: "users@activemq.apache.org" <users@activemq.apache.org>
Content-Type: multipart/alternative; boundary=f46d044305cecc6df704d3189c7d

--f46d044305cecc6df704d3189c7d
Content-Type: text/plain; charset=ISO-8859-1

Looks like your network connectors are in one direction only, ie, node1 -->
node2
What this means is messages will only flow across the network FROM node1 TO
node2 based on the demand (consumers) on node2. They will not flow the
other way unless you set up a bridge in the other direction (node2 -->
node1) or use duplex="true" on your existing network connectors. Not sure
what you mean when you say restarting the brokers fixes what you were
seeing.


On Fri, Jan 11, 2013 at 8:43 PM, swplotner <swplotner@amherst.edu> wrote:

> Hi,
>
> Using 5.7.0 I find that the problem exists in the following way:
>
> 2 brokers connected via network.
>
> Broker A
>         has consumer connected to a /queue/foo.test
>
> Broker B
>         has a producer connected to /queue/foo.test
>
> the producer is producing message for /queue/foo.test and the consumer will
> receive them just fine. The producer is configured to stuff messages into
> the queue one after the other, the consumer on purpose consumes messages
> slowly.
>
> Once we have several hundred messages in /queue/foo.test we abort the
> producer and consumer.
>
> Looking at queue sizes on both brokers, broker A has a large number of
> messages and broker B has some number of messages or none.
>
> Take the consumer that was previously talking via broker A and connect him
> to broker B. That consumer will now only see the messages that are in
> broker
> B and will NOT receive ANY of the messages stuck in broker A.
>
> The only way I can get out of this problem is to restart both brokers and
> all messages are then process correctly.
>
> I have spent quite a bit of time on this problem and if there is only one
> broker this is not a problem - the moment you have a network of 2 brokers
> this problem exists.
>
> Here are my network connectors, one for topics and one for queues:
>
>         <networkConnectors>
>             <networkConnector name="net-node1-node2-queues"
>                 uri="static:(ssl://activemq-node2.amherst.edu:61615)"
>                 networkTTL="3"
>                 dynamicOnly="true"
>                 prefetchSize="1"
>                 duplex="false"
>                 userName="${netlink.username}"
>                 password="${netlink.password}"
>                 conduitSubscriptions="false"
>                 >
>                 <dynamicallyIncludedDestinations>
>                    <queue physicalName=">"/>
>                 </dynamicallyIncludedDestinations>
>             </networkConnector>
>
>             <networkConnector name="net-node1-node2-topics"
>                 uri="static:(ssl://activemq-node2.amherst.edu:61615)"
>                 networkTTL="3"
>                 dynamicOnly="true"
>                 prefetchSize="1"
>                 duplex="false"
>                 userName="${netlink.username}"
>                 password="${netlink.password}"
>                 conduitSubscriptions="false"
>                 >
>                 <dynamicallyIncludedDestinations>
>                     <topic physicalName=">"/>
>                 </dynamicallyIncludedDestinations>
>             </networkConnector>
>         </networkConnectors>
>
>
>
>
> --
> View this message in context:
> http://activemq.2283324.n4.nabble.com/Stuck-messages-Dispatch-issues-tp2367852p4661679.html
> Sent from the ActiveMQ - User mailing list archive at Nabble.com.
>


-- 
*Christian Posta*
http://www.christianposta.com/blog
twitter: @christianposta

--f46d044305cecc6df704d3189c7d--