Classes Files

Wombat::MamaSubscription::SubscriptionNativeMethods

Public Functions

  Name
int mamaSubscription_activate(IntPtr subscription)
int mamaSubscription_deactivate(IntPtr subscription)
int mamaSubscription_getPreIntitialCacheSize(IntPtr subscription, ref int cacheSize)
int mamaSubscription_getReceivedInitial(IntPtr nativeHandle, ref int receivedInitial)
int mamaSubscription_getSource(IntPtr subscription, ref IntPtr symbol)
int mamaSubscription_setPreIntitialCacheSize(IntPtr subscription, int cacheSize)
int mamaSubscription_setRecoverGaps(IntPtr nativeHandle, int recoverGaps)
int mamaSubscription_setRequiresInitial(IntPtr nativeHandle, int requiresInitial)
int mamaSubscription_setRetries(IntPtr nativeHandle, int retries)
int mamaSubscription_setServiceLevel(IntPtr nativeHandle, int serviceLevel, int serviceLevelOpt)
int mamaSubscription_setSubscriptionType(IntPtr nativeHandle, int type)
int mamaSubscription_setTimeout(IntPtr nativeHandle, double timeout)
int mamaSubscription_setup(IntPtr subscription, IntPtr queue, ref MamaBasicSubscription.NativeMethods.SubscriptionCallbacks callbacks, IntPtr source, string symbol, IntPtr closure)
int mamaSubscription_setup2(IntPtr subscription, IntPtr transport, IntPtr queue, ref MamaBasicSubscription.NativeMethods.SubscriptionCallbacks callbacks, string sourceName, string symbol, IntPtr closure)

Public Functions Documentation

function mamaSubscription_activate

int mamaSubscription_activate(
    IntPtr subscription
)

function mamaSubscription_deactivate

int mamaSubscription_deactivate(
    IntPtr subscription
)

function mamaSubscription_getPreIntitialCacheSize

int mamaSubscription_getPreIntitialCacheSize(
    IntPtr subscription,
    ref int cacheSize
)

function mamaSubscription_getReceivedInitial

int mamaSubscription_getReceivedInitial(
    IntPtr nativeHandle,
    ref int receivedInitial
)

function mamaSubscription_getSource

int mamaSubscription_getSource(
    IntPtr subscription,
    ref IntPtr symbol
)

function mamaSubscription_setPreIntitialCacheSize

int mamaSubscription_setPreIntitialCacheSize(
    IntPtr subscription,
    int cacheSize
)

function mamaSubscription_setRecoverGaps

int mamaSubscription_setRecoverGaps(
    IntPtr nativeHandle,
    int recoverGaps
)

function mamaSubscription_setRequiresInitial

int mamaSubscription_setRequiresInitial(
    IntPtr nativeHandle,
    int requiresInitial
)

function mamaSubscription_setRetries

int mamaSubscription_setRetries(
    IntPtr nativeHandle,
    int retries
)

function mamaSubscription_setServiceLevel

int mamaSubscription_setServiceLevel(
    IntPtr nativeHandle,
    int serviceLevel,
    int serviceLevelOpt
)

function mamaSubscription_setSubscriptionType

int mamaSubscription_setSubscriptionType(
    IntPtr nativeHandle,
    int type
)

function mamaSubscription_setTimeout

int mamaSubscription_setTimeout(
    IntPtr nativeHandle,
    double timeout
)

function mamaSubscription_setup

int mamaSubscription_setup(
    IntPtr subscription,
    IntPtr queue,
    ref MamaBasicSubscription.NativeMethods.SubscriptionCallbacks callbacks,
    IntPtr source,
    string symbol,
    IntPtr closure
)

function mamaSubscription_setup2

int mamaSubscription_setup2(
    IntPtr subscription,
    IntPtr transport,
    IntPtr queue,
    ref MamaBasicSubscription.NativeMethods.SubscriptionCallbacks callbacks,
    string sourceName,
    string symbol,
    IntPtr closure
)

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