Skip to content
  • This project
    • Loading...
  • Sign in

Максим Макеев / py_niokr

Go to a project
Toggle navigation
Toggle navigation pinning
  • Projects
  • Groups
  • Snippets
  • Help
  • Project
  • Activity
  • Repository
  • Pipelines
  • Graphs
  • Issues 0
  • Merge Requests 0
  • Wiki
  • Network
  • Create a new issue
  • Builds
  • Commits
  • Issue Boards
  • Files
  • Commits
  • Network
  • Compare
  • Branches
  • Tags
Switch branch/tag
  • py_niokr
  • MQ_TEST.py
  • Максим Макеев's avatar
    add all files · 44f2f095
    44f2f095 Browse Files
    Максим Макеев authored 2021-04-06 18:25:37 +0300
MQ_TEST.py 354 Bytes
Raw Blame History Permalink
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19
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)