import logging
import pika
from pika.exceptions import ConnectionClosed
import time

logging.basicConfig(level=logging.DEBUG)

creds = pika.PlainCredentials(username='user', password='pass')
#params = pika.ConnectionParameters(host='localhost', virtual_host='vhost', credentials=creds, heartbeat=5)
params = pika.URLParameters('amqp://user:pass@localhost/vhost?heartbeat=5')
connection = pika.BlockingConnection(params)
channel = connection.channel()

while True:
    print(time.strftime('%c', time.localtime()))
    try:
        channel.basic_publish('', 'test-queue', 'hello')
    except ConnectionClosed as e:
        print(e)
        connection = pika.BlockingConnection(params)
        channel = connection.channel()
    except Exception as e:
        print(e)
        exit(1)
    connect_close = connection.is_closed
    connect_open = connection.is_open
    channel_close = channel.is_closed
    channel_open = channel.is_open
    print("connection is_closed ", connect_close)
    print("connection is_open ", connect_open)
    print("channel is_closed ", channel_close)
    print("channel is_open ", channel_open)
    print("")
    time.sleep(15)