import time
import logging
import pika
import json
import datetime
import pytz

from threading import Thread
from queue import Queue, Empty
from ocm_fwk.ocm_mq import OcmMqBase, OcmMqBlockingPublisher

import config as cfg

pub = OcmMqBlockingPublisher(cfg)
pub.publish("rk_1", 123)
pub.publish("rk_1", 666)
pub.publish("rk_1", 999)