Invocation

class Invocation(invocation_service, request, partition_id=-1, address=None, connection=None)

Bases: object

sent_connection = None
timer = None
has_connection()
has_partition_id()
has_address()
set_response(response)
set_exception(exception, traceback=None)
set_timeout(timeout)
on_timeout()
class ListenerInvocation(invocation_service, request, event_handler, response_decoder=None, **kwargs)

Bases: hazelcast.invocation.Invocation

registration_id = None
class ListenerService(client)

Bases: object

logger = <logging.Logger object>
start_listening(request, event_handler, decode_add_listener, key=None)
stop_listening(registration_id, encode_remove_listener)
re_register_listener(invocation)
class InvocationService(client)

Bases: object

logger = <logging.Logger object>
invoke_on_connection(message, connection, ignore_heartbeat=False)
invoke_on_partition(message, partition_id, invocation_timeout=None)
invoke_on_random_target(message)
invoke_on_target(message, address)
invoke_smart(invocation, ignore_heartbeat=False)
invoke_non_smart(invocation, ignore_heartbeat=False)
cleanup_connection(connection, cause)
on_connect(f, invocation, ignore_heartbeat)