python.sendEI_SPB_Lib.MSG Class Reference

Inheritance diagram for python.sendEI_SPB_Lib.MSG:

Collaboration diagram for python.sendEI_SPB_Lib.MSG:

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

Public Attributes
	brokers
	user
	passcode
	queue
	verbose
	dummy
	conn

Detailed Description

Definition at line 20 of file sendEI_SPB_Lib.py.

Constructor & Destructor Documentation

__init__()

def 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()

def 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()

def 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()

def 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()

def 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

Definition at line 24 of file sendEI_SPB_Lib.py.

conn

python.sendEI_SPB_Lib.MSG.conn

Definition at line 31 of file sendEI_SPB_Lib.py.

dummy

python.sendEI_SPB_Lib.MSG.dummy

Definition at line 29 of file sendEI_SPB_Lib.py.

passcode

python.sendEI_SPB_Lib.MSG.passcode

Definition at line 26 of file sendEI_SPB_Lib.py.

queue

python.sendEI_SPB_Lib.MSG.queue

Definition at line 27 of file sendEI_SPB_Lib.py.

user

python.sendEI_SPB_Lib.MSG.user

Definition at line 25 of file sendEI_SPB_Lib.py.

verbose

python.sendEI_SPB_Lib.MSG.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