Mailing-List: contact users-help@qpid.apache.org; run by ezmlm
Precedence: bulk
Reply-To: users@qpid.apache.org
Received-SPF: neutral (nike.apache.org: 216.139.236.26 is neither permitted
 nor denied by domain of techguy911@gmail.com)
Date: Thu, 12 Jan 2012 10:39:25 -0800 (PST)
From: techguy911 <techguy911@gmail.com>
To: users@qpid.apache.org
Message-ID: <1326393565371-7181185.post@n2.nabble.com>
Subject: Headers message filtering
MIME-Version: 1.0
Content-Type: text/plain; charset=us-ascii
Content-Transfer-Encoding: 7bit

I'm trying to filter by message properties using a headers exchange but no
luck.  To help with troubleshooting, I broke the problem down to standard
QPID command lines.

#Create the exchange
qpid-config add exchange headers myexchange
#Bind to a queue with a property filter
qpid-config bind myexchange myqueue mykey all matchkey=matchvalue

#In terminal A, setup a non-filtered test drain
./drain -f myexchange

#In terminal B, setup a drain on the bound queue
./drain -f myqueue

#In terminal C, setup an auto-generated queue bound to the exchange
./drain -f "generated; {create:always, node: {type: queue,
x-declare:{auto-delete:'False', exchange:myexchange, type:headers},
x-bindings:[{queue:generated, exchange:myexchange,
arguments:{'x-match':matchkey,'type':'matchvalue'}}]}}"

#In terminal D, send the message
./spout --content "testcontent" --property "matchkey=matchvalue" myexchange

I see messages coming across on Terminal A
Message(properties={matchkey:matchvalue,
spout-id:eef6a0ea-a21b-42db-8dac-7deafd40fceb:0, x-amqp-0-10.routing-key:},
content='testcontent')

Nothing on B or C.  


--
View this message in context: http://qpid.2158936.n2.nabble.com/Headers-message-filtering-tp7181185p7181185.html
Sent from the Apache Qpid users mailing list archive at Nabble.com.

---------------------------------------------------------------------
Apache Qpid - AMQP Messaging Implementation
Project:      http://qpid.apache.org
Use/Interact: mailto:users-subscribe@qpid.apache.org