autobahn.wamp.request


Module Contents

Classes

Publication

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

Subscription

Object representing a handler subscription.

Handler

Object representing an event handler attached to a subscription.

Registration

Object representing a registration.

Endpoint

Object representing an procedure endpoint attached to a registration.

PublishRequest

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

SubscribeRequest

Object representing an outstanding request to subscribe to a topic.

UnsubscribeRequest

Object representing an outstanding request to unsubscribe a subscription.

CallRequest

Object representing an outstanding request to call a procedure.

InvocationRequest

Object representing an outstanding request to invoke an endpoint.

RegisterRequest

Object representing an outstanding request to register a procedure.

UnregisterRequest

Object representing an outstanding request to unregister a registration.

class autobahn.wamp.request.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']
__str__()[source]

Return str(self).

class autobahn.wamp.request.Subscription(subscription_id, topic, session, handler)[source]

Bases: object

Object representing a handler subscription.

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

Unsubscribe this subscription.

__str__()[source]

Return str(self).

class autobahn.wamp.request.Handler(fn, obj=None, details_arg=None)[source]

Bases: object

Object representing an event handler attached to a subscription.

__slots__ = ['fn', 'obj', 'details_arg']
class autobahn.wamp.request.Registration(session, registration_id, procedure, endpoint)[source]

Bases: object

Object representing a registration.

__slots__ = ['id', 'active', 'session', 'procedure', 'endpoint']
unregister()[source]
__str__()[source]

Return str(self).

class autobahn.wamp.request.Endpoint(fn, obj=None, details_arg=None)[source]

Bases: object

Object representing an procedure endpoint attached to a registration.

__slots__ = ['fn', 'obj', 'details_arg']
class autobahn.wamp.request.PublishRequest(request_id, on_reply, was_encrypted)[source]

Bases: Request

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

__slots__ = was_encrypted
class autobahn.wamp.request.SubscribeRequest(request_id, topic, on_reply, handler)[source]

Bases: Request

Object representing an outstanding request to subscribe to a topic.

__slots__ = ['handler', 'topic']
class autobahn.wamp.request.UnsubscribeRequest(request_id, on_reply, subscription_id)[source]

Bases: Request

Object representing an outstanding request to unsubscribe a subscription.

__slots__ = ['subscription_id']
class autobahn.wamp.request.CallRequest(request_id, procedure, on_reply, options)[source]

Bases: Request

Object representing an outstanding request to call a procedure.

__slots__ = ['procedure', 'options']
class autobahn.wamp.request.InvocationRequest(request_id, on_reply)[source]

Bases: Request

Object representing an outstanding request to invoke an endpoint.

class autobahn.wamp.request.RegisterRequest(request_id, on_reply, procedure, endpoint)[source]

Bases: Request

Object representing an outstanding request to register a procedure.

__slots__ = ['procedure', 'endpoint']
class autobahn.wamp.request.UnregisterRequest(request_id, on_reply, registration_id)[source]

Bases: Request

Object representing an outstanding request to unregister a registration.

__slots__ = ['registration_id']