python.sendEI_SPB_Lib.MSG Class Reference

Inheritance diagram for python.sendEI_SPB_Lib.MSG:

Collaboration diagram for python.sendEI_SPB_Lib.MSG:

Public Types
typedef HLT::TypeInformation::for_each_type_c< typenameEDMLIST::map, my_functor, my_result<>, my_arg< HLT::TypeInformation::get_cont, CONTAINER > >::type	result

Public Member Functions
	__init__ (self, opt)
	isConnected (self)
	connect (self)
	close (self)
	sendMSG (self, msg)

Public Attributes
	brokers = opt.endpoint
	user = opt.user
	passcode = opt.passcode
	queue = opt.queue
	verbose = opt.verbose
	dummy = opt.dummy
	conn = None

Detailed Description

Definition at line 20 of file sendEI_SPB_Lib.py.

Member Typedef Documentation

result

typedef HLT::TypeInformation::for_each_type_c<typenameEDMLIST::map,my_functor,my_result<>,my_arg<HLT::TypeInformation::get_cont,CONTAINER>>::type master_search< typenameEDMLIST::map, HLT::TypeInformation::get_cont, CONTAINER >::result

inherited

Definition at line 90 of file EDM_MasterSearch.h.

Constructor & Destructor Documentation

__init__()

python.sendEI_SPB_Lib.MSG.__init__	(		self,
			opt )

Definition at line 22 of file sendEI_SPB_Lib.py.

    def __init__(self, opt):
 
        self.brokers = opt.endpoint
        self.user = opt.user
        self.passcode = opt.passcode
        self.queue = opt.queue
        self.verbose = opt.verbose
        self.dummy = opt.dummy
 
        self.conn = None
 

Member Function Documentation

close()

python.sendEI_SPB_Lib.MSG.close

(

self

)

Definition at line 66 of file sendEI_SPB_Lib.py.

    def close(self):
        if self.conn is not None:
            self.conn.disconnect()
        self.conn = None
 

connect()

python.sendEI_SPB_Lib.MSG.connect

(

self

)

Definition at line 39 of file sendEI_SPB_Lib.py.

    def connect(self):
 
        # prepare for connection
        self.conn = None
 
        if self.dummy:
            return
 
        log.debug("Broker IPs and ports to connect:")
        for broker in self.brokers:
            log.debug("   {:15s}   {}".format(*broker))
 
        # connect
        conn = stomp.Connection(self.brokers)
        conn.set_listener('', MyListener())
        try:
            if self.user is not None and self.passcode is not None:
                log.debug("Conecting broker using user and password")
                conn.connect(self.user, self.passcode, wait=True)
            else:
                conn.connect(wait=True)
        except stomp.exception.ConnectFailedException:
            # pass error to caller
            raise
 
        self.conn = conn
 

isConnected()

python.sendEI_SPB_Lib.MSG.isConnected

(

self

)

Definition at line 33 of file sendEI_SPB_Lib.py.

    def isConnected(self):
        if self.conn is None:
            return False
        else:
            return True
 

sendMSG()

python.sendEI_SPB_Lib.MSG.sendMSG	(		self,
			msg )

Definition at line 71 of file sendEI_SPB_Lib.py.

    def sendMSG(self, msg):
 
        log.debug("Sending message. Len: {}".format(len(msg)))
 
        # NON_PERSISTENT = "1"
        PERSISTENT = "2"
 
        if not self.dummy:
            self.conn.send(self.queue, msg,
                           JMSDeliveryMode=PERSISTENT,
                           JMSExpiration=0)
        if self.verbose > 2:
            print(msg, file=sys.stderr)
 
 
# ----------------------
# listener
# ----------------------

Member Data Documentation

brokers

python.sendEI_SPB_Lib.MSG.brokers = opt.endpoint

Definition at line 24 of file sendEI_SPB_Lib.py.

conn

python.sendEI_SPB_Lib.MSG.conn = None

Definition at line 31 of file sendEI_SPB_Lib.py.

dummy

python.sendEI_SPB_Lib.MSG.dummy = opt.dummy

Definition at line 29 of file sendEI_SPB_Lib.py.

passcode

python.sendEI_SPB_Lib.MSG.passcode = opt.passcode

Definition at line 26 of file sendEI_SPB_Lib.py.

queue

python.sendEI_SPB_Lib.MSG.queue = opt.queue

Definition at line 27 of file sendEI_SPB_Lib.py.

user

python.sendEI_SPB_Lib.MSG.user = opt.user

Definition at line 25 of file sendEI_SPB_Lib.py.

verbose

python.sendEI_SPB_Lib.MSG.verbose = opt.verbose

Definition at line 28 of file sendEI_SPB_Lib.py.

---

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

• sendEI_SPB_Lib.py