From users-return-4728-apmail-qpid-users-archive=qpid.apache.org@qpid.apache.org Fri Aug 19 00:34:25 2011 Return-Path: X-Original-To: apmail-qpid-users-archive@www.apache.org Delivered-To: apmail-qpid-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 C2E3B8006 for ; Fri, 19 Aug 2011 00:34:25 +0000 (UTC) Received: (qmail 45998 invoked by uid 500); 19 Aug 2011 00:34:25 -0000 Delivered-To: apmail-qpid-users-archive@qpid.apache.org Received: (qmail 45918 invoked by uid 500); 19 Aug 2011 00:34:25 -0000 Mailing-List: contact users-help@qpid.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: users@qpid.apache.org Delivered-To: mailing list users@qpid.apache.org Received: (qmail 45908 invoked by uid 99); 19 Aug 2011 00:34:24 -0000 Received: from athena.apache.org (HELO athena.apache.org) (140.211.11.136) by apache.org (qpsmtpd/0.29) with ESMTP; Fri, 19 Aug 2011 00:34:24 +0000 X-ASF-Spam-Status: No, hits=1.5 required=5.0 tests=FREEMAIL_FROM,HTML_MESSAGE,RCVD_IN_DNSWL_LOW,SPF_PASS,T_TO_NO_BRKTS_FREEMAIL X-Spam-Check-By: apache.org Received-SPF: pass (athena.apache.org: domain of dmehrtash@gmail.com designates 209.85.216.170 as permitted sender) Received: from [209.85.216.170] (HELO mail-qy0-f170.google.com) (209.85.216.170) by apache.org (qpsmtpd/0.29) with ESMTP; Fri, 19 Aug 2011 00:34:19 +0000 Received: by qyl38 with SMTP id 38so2238460qyl.15 for ; Thu, 18 Aug 2011 17:33:58 -0700 (PDT) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=gmail.com; s=gamma; h=mime-version:in-reply-to:references:date:message-id:subject:from:to :content-type; bh=2VyogO9ty2LvbjDIdr/NIjp3Sspvm0WdZlWWAvVA0jE=; b=ljk1RTyaoVSkPbM0iIYiUq3XyDt+wYI6iYmEVjmLCLSHotKluV0Xgani4X7+Z64ECf txC5UI28b+iWlqlkwnEeLtyQ/UwuEa53sq3ecs9/5acws5geoRo/jNY59yWio8vHcYyy hDJWQ1+nZK7Isqu5LA7O+aNp6Ef3Sfgc16BFo= MIME-Version: 1.0 Received: by 10.224.210.197 with SMTP id gl5mr1226166qab.303.1313714038552; Thu, 18 Aug 2011 17:33:58 -0700 (PDT) Received: by 10.229.88.11 with HTTP; Thu, 18 Aug 2011 17:33:58 -0700 (PDT) In-Reply-To: <319287915.213936.1313712312587.JavaMail.root@mail-1.01.com> References: <319287915.213936.1313712312587.JavaMail.root@mail-1.01.com> Date: Thu, 18 Aug 2011 17:33:58 -0700 Message-ID: Subject: Re: Can't get federated brokers to work in From: Daryoush Mehrtash To: users@qpid.apache.org Content-Type: multipart/alternative; boundary=20cf3005dde09ab86e04aad0e2b4 --20cf3005dde09ab86e04aad0e2b4 Content-Type: text/plain; charset=ISO-8859-1 I am running the latest c++ build on Ubuntu 10.04.02 daryoush On Thu, Aug 18, 2011 at 5:05 PM, Steve Huston wrote: > What platform is this on? > > Federation won't work correctly on Windows yet. > > -Steve > > ----- Original Message ----- > From: "Daryoush Mehrtash" > To: users@qpid.apache.org > Sent: Thursday, August 18, 2011 6:33:18 PM > Subject: Can't get federated brokers to work in > > I am trying to get two qpid c++ Brokers in a federation but can't get them > to work. I am trying to get the client (python) "spout" and "drain" to > be > connected on two different brokers and have a queue route between them. > Following instruction on: > https://cwiki.apache.org/qpid/using-broker-federation.html > > I do the following > > 1) start up two brokers on two different machines > 2) ON the source machine where "spout" will be running do: > > qpid-config -a SOURCE_BROKER add queue public > > 3)ON destination machine where "drain" will be running do: > > qpid-route queue add DEST_BROKER SOURCE_BROKER amq.fanout public > > 4)Run spout on the source machine > ./spout -a SOURCE_BROKER public > > 5) try to run the "drain" on destination machine > ./drain -a DEST_BROKER public > > When I try to run drain I get error message: > > Traceback (most recent call last): > > File "./drain", line 81, in > > rcv = ssn.receiver(addr) > > File "", line 6, in receiver > > File > > > "/home/ijet/BGB/ext/qpid_python_client/qpid-0.10/python/qpid/messaging/endpoints.py", > > line 606, in receiver > > raise e > > qpid.messaging.exceptions.NotFound: no such queue: public > > > > I can see that the route is setup > > Static Routes: DEST_BROKER(ex=amq.fanout) <= SRC_BROKER(queue=public) > > > If I connect the drain to the source broker it sees the messages. If I do > create the queue at the destination broker, the drain doesn't throw the > exception, but it wont see any of the messages on the source broker. > > > Is there something else I need to do to get the brokers to talk to each > other? > > Thanks > > Daryoush > > --------------------------------------------------------------------- > Apache Qpid - AMQP Messaging Implementation > Project: http://qpid.apache.org > Use/Interact: mailto:users-subscribe@qpid.apache.org > > --20cf3005dde09ab86e04aad0e2b4--