riaps.run.qryPort module

Query port class Created on Oct 10, 2016

@author: riaps

class riaps.run.qryPort.QryPort(parentComponent, portName, portSpec)

Bases: DuplexConnPort

Query port is to access a server. Has a request and a response message type, and uses a DEALER socket.

closeSocket()

Close down the port. Abstract, subclasses must implement this method.

getInfo()

Retrieve relevant information about this port

getSocket()

Return the socket of port

inSocket()

Return True because the socket is used of input

recv()

Receive a bytes through this port

recv_pyobj()

Receive an object through this port

reset()

Reset the port object. Subclasses can override this method.

Reset is to be used when a send or receive operation fails and the port needs to be re-initialized.

send(msg)

Send bytes through this port

send_pyobj(msg)

Send an object through this port

setup()

Set up the port

setupSocket(owner)

Set up the socket of the port. Return a tuple suitable for querying the discovery service for the publishers