autobahn.wamp.request

Classes

CallRequest

Object representing an outstanding request to call a procedure.

Endpoint

Object representing an procedure endpoint attached to a registration.

Handler

Object representing an event handler attached to a subscription.

InvocationRequest

Object representing an outstanding request to invoke an endpoint.

Publication

Object representing a publication (feedback from publishing an event when doing

PublishRequest

Object representing an outstanding request to publish (acknowledged) an event.

RegisterRequest

Object representing an outstanding request to register a procedure.

Registration

Object representing a registration.

SubscribeRequest

Object representing an outstanding request to subscribe to a topic.

Subscription

Object representing a handler subscription.

UnregisterRequest

Object representing an outstanding request to unregister a registration.

UnsubscribeRequest

Object representing an outstanding request to unsubscribe a subscription.

Module Contents

class CallRequest(request_id, procedure, on_reply, options)[source]

Bases: Request

Object representing an outstanding request to call a procedure.

__slots__ = ('procedure', 'options')[source]
options[source]
procedure[source]
class Endpoint(fn, obj=None, details_arg=None)[source]

Bases: object

Object representing an procedure endpoint attached to a registration.

__slots__ = ('fn', 'obj', 'details_arg')[source]
details_arg = None[source]
fn[source]
obj = None[source]
class Handler(fn, obj=None, details_arg=None)[source]

Bases: object

Object representing an event handler attached to a subscription.

__slots__ = ('fn', 'obj', 'details_arg')[source]
details_arg = None[source]
fn[source]
obj = None[source]
class InvocationRequest(request_id, on_reply)[source]

Bases: Request

Object representing an outstanding request to invoke an endpoint.

class Publication(publication_id, was_encrypted)[source]

Bases: object

Object representing a publication (feedback from publishing an event when doing an acknowledged publish).

__slots__ = ('id', 'was_encrypted')[source]
__str__()[source]
id[source]
was_encrypted[source]
class PublishRequest(request_id, on_reply, was_encrypted)[source]

Bases: Request

Object representing an outstanding request to publish (acknowledged) an event.

__slots__ = 'was_encrypted'[source]
was_encrypted[source]
class RegisterRequest(request_id, on_reply, procedure, endpoint)[source]

Bases: Request

Object representing an outstanding request to register a procedure.

__slots__ = ('procedure', 'endpoint')[source]
endpoint[source]
procedure[source]
class Registration(session, registration_id, procedure, endpoint)[source]

Bases: object

Object representing a registration.

__slots__ = ('id', 'active', 'session', 'procedure', 'endpoint')[source]
__str__()[source]
active = True[source]
endpoint[source]
id[source]
procedure[source]
session[source]
unregister()[source]
class SubscribeRequest(request_id, topic, on_reply, handler)[source]

Bases: Request

Object representing an outstanding request to subscribe to a topic.

__slots__ = ('handler', 'topic')[source]
handler[source]
topic[source]
class Subscription(subscription_id, topic, session, handler)[source]

Bases: object

Object representing a handler subscription.

__slots__ = ('id', 'topic', 'active', 'session', 'handler')[source]
__str__()[source]
active = True[source]
handler[source]
id[source]
session[source]
topic[source]
unsubscribe()[source]

Unsubscribe this subscription.

class UnregisterRequest(request_id, on_reply, registration_id)[source]

Bases: Request

Object representing an outstanding request to unregister a registration.

__slots__ = ('registration_id',)[source]
registration_id[source]
class UnsubscribeRequest(request_id, on_reply, subscription_id)[source]

Bases: Request

Object representing an outstanding request to unsubscribe a subscription.

__slots__ = ('subscription_id',)[source]
subscription_id[source]