Should be fixed for new and old versions of kombu.
I was using kombu.connection.Connection which in at least 1.1.2 is == connection.BrokerConnection, but 1.0.4 is missing that. Reverted to using kombu.connection.BrokerConnection and it seems to work in 1.0.4 and 1.2.1 now.
Should be fixed for new and old versions of kombu.
I was using kombu.connectio n.Connection which in at least 1.1.2 is == connection. BrokerConnectio n, but 1.0.4 is missing that. Reverted to using kombu.connectio n.BrokerConnect ion and it seems to work in 1.0.4 and 1.2.1 now.