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)