Package qpid :: Package messaging :: Module driver :: Class Engine
[frames] | no frames]

Class Engine

source code

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) source code
 
declare(self, sst, lnk, action) source code
 
delete(self, sst, name, action) 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