#ifndef __ROCKETMQ_ONS_CPP_FULL_H
#define __ROCKETMQ_ONS_CPP_FULL_H

#include <graal_isolate.h>


#if defined(__cplusplus)
extern "C" {
#endif

int create_producer(graal_isolatethread_t*, factory_property*);

int create_transaction_producer(graal_isolatethread_t*, factory_property*, void*, void *);

int create_consumer(graal_isolatethread_t*, factory_property*);

int create_order_consumer(graal_isolatethread_t*, factory_property*);

void subscribe(graal_isolatethread_t*, int, subscription*);

void subscribe_order_listener(graal_isolatethread_t*, int, subscription*);

void start_instance(graal_isolatethread_t*, int);

void destroy_instance(graal_isolatethread_t*, int);

int create_order_producer(graal_isolatethread_t*, factory_property*);

void send_message(graal_isolatethread_t*, int, message*, send_result*);

void send_message_oneway(graal_isolatethread_t*, int, message*, send_result*);

void send_message_async(graal_isolatethread_t*, int, message*, send_result*, callback_func*);

void send_message_transaction(graal_isolatethread_t*, int, message*, send_result*, void*, void *);

void send_order_message(graal_isolatethread_t*, int, message*, send_result*, char*);

int run_main(int paramArgc, char** paramArgv);

#if defined(__cplusplus)
}
#endif
#endif