Module Expr Str Import alias Import alias ImportFrom alias alias ImportFrom alias alias ClassDef bases NameLoad body Assign NameStore Str Assign NameStore Str FunctionDef arguments args NameParam NameParam defaults NameLoad body If CompareIs NameLoad NameLoad body Assign NameStore Call NameLoad Str Num Assign AttributeStore NameLoad attr NameLoad decorator_list FunctionDef arguments args NameParam defaults body Assign NameStore Yield Call AttributeLoad Call NameLoad AttributeLoad NameLoad attr attr Assign NameStore Dict Str Str Str Num Expr Call AttributeLoad NameLoad attr AttributeLoad NameLoad attr AttributeLoad NameLoad attr NameLoad keyword AttributeLoad NameLoad attr decorator_list AttributeLoad NameLoad attr FunctionDef arguments args NameParam NameParam NameParam defaults body Expr Str Assign NameStore Call AttributeLoad NameLoad attr SubscriptLoad NameLoad Index Str Print BinOpMod Str SubscriptLoad NameLoad Index Str decorator_list decorator_list If CompareEq NameLoad Str body Expr Call AttributeLoad NameLoad attr keyword AttributeLoad NameLoad attr Expr Call AttributeLoad Call NameLoad attr Expr Call AttributeLoad NameLoad attr
N/A N/A 
Copyright 2011 Mozes, Inc.

   Licensed under the Apache License, Version 2.0 (the "License");
   you may not use this file except in compliance with the License.
   You may obtain a copy of the License at

       http://www.apache.org/licenses/LICENSE-2.0

   Unless required by applicable law or agreed to in writing, software
   distributed under the License is distributed on an "AS IS" BASIS,
   WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either expressed or implied.
   See the License for the specific language governing permissions and
   limitations under the License.
 N/A logging N/A simplejson twisted.internet reactor defer stompest.async StompConfig StompCreator Consumer N/A object N/A N/A QUEUE /queue/testOut N/A ERROR_QUEUE /queue/testConsumerError __init__ N/A N/A self config N/A None N/A N/A N/A config None N/A N/A config N/A StompConfig localhost 61613 N/A N/A self config config N/A run N/A N/A self N/A N/A N/A stomp N/A N/A N/A N/A StompCreator N/A self config getConnection N/A headers N/A ack activemq.prefetchSize client-individual 100 N/A N/A N/A stomp subscribe N/A self QUEUE N/A self consume headers errorDestination N/A self ERROR_QUEUE N/A N/A defer inlineCallbacks consume N/A N/A self stomp frame N/A N/A N/A 
        NOTE: you can return a Deferred here
         N/A data N/A N/A simplejson loads N/A frame N/A body N/A N/A Received msg with count %s N/A data N/A count N/A N/A N/A N/A __name__ __main__ N/A N/A N/A N/A logging basicConfig level N/A logging DEBUG N/A N/A N/A N/A Consumer run N/A N/A N/A reactor run