blob: 8f1c44f36f368a7f7972301caccb86a1679371dc [file] [log] [blame]
#ifndef __ROCKETMQ_ONS_CPP_FULL_H
#define __ROCKETMQ_ONS_CPP_FULL_H
#include <graal_isolate_dynamic.h>
#if defined(__cplusplus)
extern "C" {
#endif
typedef int (*create_producer_fn_t)(graal_isolatethread_t*, factory_property*);
typedef int (*create_transaction_producer_fn_t)(graal_isolatethread_t*, factory_property*, void*, void *);
typedef int (*create_consumer_fn_t)(graal_isolatethread_t*, factory_property*);
typedef int (*create_order_consumer_fn_t)(graal_isolatethread_t*, factory_property*);
typedef void (*subscribe_fn_t)(graal_isolatethread_t*, int, subscription*);
typedef void (*subscribe_order_listener_fn_t)(graal_isolatethread_t*, int, subscription*);
typedef void (*start_instance_fn_t)(graal_isolatethread_t*, int);
typedef void (*destroy_instance_fn_t)(graal_isolatethread_t*, int);
typedef int (*create_order_producer_fn_t)(graal_isolatethread_t*, factory_property*);
typedef void (*send_message_fn_t)(graal_isolatethread_t*, int, message*, send_result*);
typedef void (*send_message_oneway_fn_t)(graal_isolatethread_t*, int, message*, send_result*);
typedef void (*send_message_async_fn_t)(graal_isolatethread_t*, int, message*, send_result*, callback_func*);
typedef void (*send_message_transaction_fn_t)(graal_isolatethread_t*, int, message*, send_result*, void*, void *);
typedef void (*send_order_message_fn_t)(graal_isolatethread_t*, int, message*, send_result*, char*);
typedef int (*run_main_fn_t)(int paramArgc, char** paramArgv);
#if defined(__cplusplus)
}
#endif
#endif