Package qpid :: Package messaging :: Module driver :: Class Engine

[frames] | no frames]

classobj Engine

Instance Methods

__init__(self, connection)

source code

status(self)

source code

write(self, data)

source code

close(self, e=None)

source code

assign_id(self, op)

source code

pending(self)

source code

read(self, n)

source code

peek(self)

source code

write_op(self, op)

source code

do_header(self, hdr)

source code

do_connection_start(self, start)

source code

do_connection_secure(self, secure)

source code

do_connection_tune(self, tune)

source code

do_connection_open_ok(self, open_ok)

source code

do_connection_heartbeat(self, hrt)

source code

do_connection_close(self, close)

source code

do_connection_close_ok(self, close_ok)

source code

do_session_attached(self, atc)

source code

do_session_command_point(self, cp)

source code

do_session_completed(self, sc)

source code

session_known_completed(self, kcmp)

source code

do_session_flush(self, sf)

source code

do_session_request_timeout(self, rt)

source code

do_execution_result(self, er)

source code

do_execution_exception(self, ex)

source code

dispatch(self)

source code

open(self)

source code

disconnect(self)

source code

attach(self, ssn)

source code

get_sst(self, op)

source code

do_session_detached(self, dtc)

source code

do_session_detach(self, dtc)

source code

link(self, lnk, dir, addr)

source code

parse_address(self, lnk, dir, addr)

source code

validate_options(self, lnk, dir)

source code

resolve_declare(self, sst, lnk, dir, action)

source code

resolve(self, sst, name, action, force=False, node_type=None, delete=False)

source code

declare(self, sst, lnk, action, create_node)

source code

delete(self, sst, name, action, node_type=None)

source code

process(self, ssn)

source code

grant(self, rcv)

source code

process_receiver(self, rcv)

source code

send(self, snd, msg)

source code

do_message_transfer(self, xfr)

source code