8 from .
import stompconfig
13 conn=stomp.Connection([(
'atlas-mb.cern.ch', 61013)])
14 print(
'panic: started connection')
16 conn.connect(wait=
True, **stompconfig.config())
17 print(
'panic: connected')
19 header={
'MsgClass':
'DQ',
26 body=json.dumps({
'msg': msg,
27 'command': sys.argv[0],
28 'arguments': sys.argv[1:],
29 'traceback': traceback.format_stack()[:-1],
32 'usrtime': time.strftime(
'%Y-%m-%d %H:%H:%M %Z', time.localtime()),
34 conn.send(body=body, headers=header, destination=DEST, ack=
'auto')
35 print(
'panic: sent message')