Classes Files

Wombat::MamaBasicSubscriptionCallback

Public Functions

  Name
virtual ~MamaBasicSubscriptionCallback()
virtual void onCreate(MamaBasicSubscription * subscription) =0
virtual void onError(MamaBasicSubscription * subscription, const MamaStatus & status, const char * topic) =0
virtual void onMsg(MamaBasicSubscription * subscription, MamaMsg & msg) =0
virtual void onDestroy(MamaBasicSubscription * subscription, void * closure)

Public Functions Documentation

function ~MamaBasicSubscriptionCallback

inline virtual ~MamaBasicSubscriptionCallback()

function onCreate

virtual void onCreate(
    MamaBasicSubscription * subscription
) =0

Parameters:

  • subscription The subscription.

Method invoked when subscription creation is complete, and before any calls to onMsg. Since subscriptions are created asynchronous by throttle, this callback provides the subscription instance after the throttle processes the creation request.

function onError

virtual void onError(
    MamaBasicSubscription * subscription,
    const MamaStatus & status,
    const char * topic
) =0

Parameters:

  • subscription The subscription.
  • status The wombat error code.
  • topic The topic for NOT_ENTITLED

Invoked if an error occurs during prior to subscription creation or if the subscription receives a message for an unentitled topic.

If the status is MamaMsgStatus.NOT_ENTITTLED the topic parameter is the specific unentitled topic. If the subscription topic contains wildcards, the subscription may still receive messages for other entitled topics.

function onMsg

virtual void onMsg(
    MamaBasicSubscription * subscription,
    MamaMsg & msg
) =0

Parameters:

  • subscription the [MamaSubscription](classWombat_1_1MamaSubscription.html).
  • msg The TibrvMsg.

Invoked when a message arrives.

function onDestroy

inline virtual void onDestroy(
    MamaBasicSubscription * subscription,
    void * closure
)

Parameters:

  • subscription The The Mama Basic Subscription.
  • closure The closure passed to the create function.

This method is invoked when a subscription has been completely destroyed, the client can have confidence that no further events will be placed on the queue for this subscription.


Updated on 2023-03-31 at 15:29:25 +0100