pika issue #34

unicode_error.py

#!/usr/bin/env python
# -*- coding: utf-8 -*-
import os
import sys

# Fix import paths
base_dir = os.path.join(os.path.dirname(os.path.realpath(__file__)))
sys.path.append(base_dir)

import pika

from pika.adapters.blocking_connection import BlockingConnection


def main():
    "Example which exhibits the failure case"
    cparams = pika.ConnectionParameters(
        host='127.0.0.1',
        port=5672,
        virtual_host='/',
        credentials=pika.PlainCredentials('guest', 'guest'))
    connection = BlockingConnection(cparams)
    channel = connection.channel()
    test_exchange = u'foo£'
    try:
        result = channel.exchange_declare(exchange=test_exchange, auto_delete=True)
        print 'exchange_declare: %r' % result
    except UnicodeDecodeError:
        import traceback
        traceback.print_exc()
        print
        print 'caught a UnicodeDecodeError, converting'
        if isinstance(test_exchange, unicode):
            test_exchange = test_exchange.encode('utf-8')
        channel = connection.channel()
        result = channel.exchange_declare(exchange=test_exchange, auto_delete=True)
        print 'exchange_declare (2): %r' % result
        print 'Exiting...'


if __name__ == '__main__':
    main()