import pika
import simplejson as json

cwuser = 'BrutalSuperman_bsip'
cwpass = 'jKUmtkYyP2MwZljr5YxEWv7S3EBVM0aF'

credentials = pika.PlainCredentials(cwuser, cwpass)

parameters = pika.URLParameters(
    'amqps://{}:{}@api.chtwrs.com:5673/'.format(
        cwuser, cwpass))
parameters.socket_timeout = 5
connection = pika.BlockingConnection(parameters)
channel = connection.channel()

data = '''{
    "action": "grantToken", "payload": {
    "userId": 158822967}}'''


getInfo = json.dumps(json.loads(data))
#print(getInfo)
success = channel.basic_publish(exchange="BrutalSuperman_bsip_ex",
                                routing_key="BrutalSuperman_bsip_o",
                                body=getInfo)

if success:
    method_frame, header_frame, body = channel.basic_get("BrutalSuperman_bsip_i")
    if method_frame:
        print(json.loads(body))
        k = json.loads(body)
        if k['result'] == "NoOffersFoundByPrice":
            print('-')
        else:
            print('ok')
        channel.basic_ack(method_frame.delivery_tag)
        connection.close()
else:
    print('Failed to publish message')