python.messaging_listen.ATLASDQMListener Class Reference

Inheritance diagram for python.messaging_listen.ATLASDQMListener:

Collaboration diagram for python.messaging_listen.ATLASDQMListener:

Public Member Functions
def	__init__ (self, listener, dest='/topic/atlas.dqm.progress', selector=None)
def	__enter__ (self)
def	__enter61__ (self)
def	__exit__ (self, eType, eValue, eTrace)

Public Attributes
	listener
	dest
	selector
	conns

Detailed Description

Definition at line 13 of file messaging_listen.py.

Constructor & Destructor Documentation

__init__()

def python.messaging_listen.ATLASDQMListener.__init__	(		self,
			listener,
			dest = '/topic/atlas.dqm.progress',
			selector = None
	)

Definition at line 14 of file messaging_listen.py.

    def __init__(self, listener, dest='/topic/atlas.dqm.progress', 
                  selector=None):
        self.listener = listener
        self.dest = dest
        self.selector = selector
 

Member Function Documentation

__enter61__()

def python.messaging_listen.ATLASDQMListener.__enter61__

(

self

)

Definition at line 27 of file messaging_listen.py.

    def __enter61__(self):
        serverlist=[_[4] for _ in socket.getaddrinfo(MSGSERVER, MSGPORT,
                                                     socket.AF_INET, 
                                                     socket.SOCK_STREAM)]
        
        from . import stompconfig
        self.conns = []
        if hasattr(self.listener, 'conn'):
            self.listener.conn=[]
        for svr in serverlist:
            auth = stompconfig.config()
            cfg = {}
            cfg['heartbeats'] = (0,0)
            cfg['reconnect_attempts_max'] = 3
            conn=stomp.Connection([svr], **cfg)
            conn.set_listener('somename',self.listener)
            if hasattr(self.listener, 'conn'):
                self.listener.conn.append(conn)
            conn.connect(wait=True, **auth)
            hdr = {}
            if self.selector is not None: hdr['selector'] = self.selector
            if hasattr(self.listener, 'ack_mode'):
                ack_mode=self.listener.ack_mode
            else:
                ack_mode='auto'
            conn.subscribe(destination=self.dest, ack=ack_mode, headers = hdr, id=len(self.conns))
            self.conns.append(conn)
        return self
 

__enter__()

def python.messaging_listen.ATLASDQMListener.__enter__

(

self

)

Definition at line 20 of file messaging_listen.py.

    def __enter__(self):
        if stomp.__version__ >= (6,1,0):
            return self.__enter61__()
        else:
            logging.critical("Unable to find stomp.py >= 6.1.0, can't proceed")
            raise ValueError("Version of stomp.py is too old")
 

__exit__()

def python.messaging_listen.ATLASDQMListener.__exit__	(		self,
			eType,
			eValue,
			eTrace
	)

Definition at line 56 of file messaging_listen.py.

    def __exit__(self, eType, eValue, eTrace):
        for conn in self.conns:
            try:
                conn.disconnect()
            except Exception as e:
                print('Exception closing connections:' + repr(e))
                pass
        return False

Member Data Documentation

conns

python.messaging_listen.ATLASDQMListener.conns

Definition at line 33 of file messaging_listen.py.

dest

python.messaging_listen.ATLASDQMListener.dest

Definition at line 16 of file messaging_listen.py.

listener

python.messaging_listen.ATLASDQMListener.listener

Definition at line 15 of file messaging_listen.py.

selector

python.messaging_listen.ATLASDQMListener.selector

Definition at line 17 of file messaging_listen.py.

---

The documentation for this class was generated from the following file:

• messaging_listen.py