summaryrefslogtreecommitdiff
path: root/include/rabbitmq-c/amqp.h
diff options
context:
space:
mode:
Diffstat (limited to 'include/rabbitmq-c/amqp.h')
-rw-r--r--include/rabbitmq-c/amqp.h221
1 files changed, 75 insertions, 146 deletions
diff --git a/include/rabbitmq-c/amqp.h b/include/rabbitmq-c/amqp.h
index 8b0a772..d7b4163 100644
--- a/include/rabbitmq-c/amqp.h
+++ b/include/rabbitmq-c/amqp.h
@@ -34,6 +34,8 @@
* ***** END LICENSE BLOCK *****
*/
+#include <rabbitmq-c/export.h>
+
#ifndef RABBITMQ_C_RABBITMQ_C_H
#define RABBITMQ_C_RABBITMQ_C_H
@@ -49,86 +51,14 @@
/*
* \internal
- * Important API decorators:
- * AMQP_PUBLIC_FUNCTION - a public API function
- * AMQP_PUBLIC_VARIABLE - a public API external variable
- * AMQP_CALL - calling convension (used on Win32)
+ * AMQP_CALL - calling convension (used on Win32)
*/
-
-#if defined(_WIN32) && defined(_MSC_VER)
-#if defined(AMQP_BUILD) && !defined(AMQP_STATIC)
-#define AMQP_PUBLIC_FUNCTION __declspec(dllexport)
-#define AMQP_PUBLIC_VARIABLE __declspec(dllexport) extern
-#else
-#define AMQP_PUBLIC_FUNCTION
-#if !defined(AMQP_STATIC)
-#define AMQP_PUBLIC_VARIABLE __declspec(dllimport) extern
-#else
-#define AMQP_PUBLIC_VARIABLE extern
-#endif
-#endif
+#ifdef _WIN32
#define AMQP_CALL __cdecl
-
-#elif defined(_WIN32) && defined(__BORLANDC__)
-#if defined(AMQP_BUILD) && !defined(AMQP_STATIC)
-#define AMQP_PUBLIC_FUNCTION __declspec(dllexport)
-#define AMQP_PUBLIC_VARIABLE __declspec(dllexport) extern
-#else
-#define AMQP_PUBLIC_FUNCTION
-#if !defined(AMQP_STATIC)
-#define AMQP_PUBLIC_VARIABLE __declspec(dllimport) extern
#else
-#define AMQP_PUBLIC_VARIABLE extern
-#endif
-#endif
-#define AMQP_CALL __cdecl
-
-#elif defined(_WIN32) && defined(__MINGW32__)
-#if defined(AMQP_BUILD) && !defined(AMQP_STATIC)
-#define AMQP_PUBLIC_FUNCTION __declspec(dllexport)
-#define AMQP_PUBLIC_VARIABLE __declspec(dllexport) extern
-#else
-#define AMQP_PUBLIC_FUNCTION
-#if !defined(AMQP_STATIC)
-#define AMQP_PUBLIC_VARIABLE __declspec(dllimport) extern
-#else
-#define AMQP_PUBLIC_VARIABLE extern
-#endif
-#endif
-#define AMQP_CALL __cdecl
-
-#elif defined(_WIN32) && defined(__CYGWIN__)
-#if defined(AMQP_BUILD) && !defined(AMQP_STATIC)
-#define AMQP_PUBLIC_FUNCTION __declspec(dllexport)
-#define AMQP_PUBLIC_VARIABLE __declspec(dllexport)
-#else
-#define AMQP_PUBLIC_FUNCTION
-#if !defined(AMQP_STATIC)
-#define AMQP_PUBLIC_VARIABLE __declspec(dllimport) extern
-#else
-#define AMQP_PUBLIC_VARIABLE extern
-#endif
-#endif
-#define AMQP_CALL __cdecl
-
-#elif defined(__GNUC__) && __GNUC__ >= 4
-#define AMQP_PUBLIC_FUNCTION __attribute__((visibility("default")))
-#define AMQP_PUBLIC_VARIABLE __attribute__((visibility("default"))) extern
-#define AMQP_CALL
-#else
-#define AMQP_PUBLIC_FUNCTION
-#define AMQP_PUBLIC_VARIABLE extern
#define AMQP_CALL
#endif
-#if __GNUC__ > 3 || (__GNUC__ == 3 && __GNUC_MINOR__ >= 1)
-#define AMQP_DEPRECATED(function) function __attribute__((__deprecated__))
-#elif defined(_MSC_VER)
-#define AMQP_DEPRECATED(function) __declspec(deprecated) function
-#else
-#define AMQP_DEPRECATED(function)
-#endif
-
/* Define ssize_t on Win32/64 platforms
See: http://lists.cs.uiuc.edu/pipermail/llvmdev/2010-April/030649.html for
details
@@ -297,7 +227,7 @@ AMQP_BEGIN_DECLS
*
* \since v0.4.0
*/
-AMQP_PUBLIC_FUNCTION
+AMQP_EXPORT
uint32_t AMQP_CALL amqp_version_number(void);
/**
@@ -311,7 +241,7 @@ uint32_t AMQP_CALL amqp_version_number(void);
*
* \since v0.1
*/
-AMQP_PUBLIC_FUNCTION
+AMQP_EXPORT
char const *AMQP_CALL amqp_version(void);
/**
@@ -796,21 +726,21 @@ AMQP_BEGIN_DECLS
*
* \since v0.2
*/
-AMQP_PUBLIC_VARIABLE const amqp_bytes_t amqp_empty_bytes;
+AMQP_EXPORT extern const amqp_bytes_t amqp_empty_bytes;
/**
* Empty table structure
*
* \since v0.2
*/
-AMQP_PUBLIC_VARIABLE const amqp_table_t amqp_empty_table;
+AMQP_EXPORT extern const amqp_table_t amqp_empty_table;
/**
* Empty table array structure
*
* \since v0.2
*/
-AMQP_PUBLIC_VARIABLE const amqp_array_t amqp_empty_array;
+AMQP_EXPORT extern const amqp_array_t amqp_empty_array;
/* Compatibility macros for the above, to avoid the need to update
code written against earlier versions of librabbitmq. */
@@ -869,7 +799,7 @@ AMQP_PUBLIC_VARIABLE const amqp_array_t amqp_empty_array;
*
* \since v0.1
*/
-AMQP_PUBLIC_FUNCTION
+AMQP_EXPORT
void AMQP_CALL init_amqp_pool(amqp_pool_t *pool, size_t pagesize);
/**
@@ -892,7 +822,7 @@ void AMQP_CALL init_amqp_pool(amqp_pool_t *pool, size_t pagesize);
* \since v0.1
*
*/
-AMQP_PUBLIC_FUNCTION
+AMQP_EXPORT
void AMQP_CALL recycle_amqp_pool(amqp_pool_t *pool);
/**
@@ -904,7 +834,7 @@ void AMQP_CALL recycle_amqp_pool(amqp_pool_t *pool);
*
* \since v0.1
*/
-AMQP_PUBLIC_FUNCTION
+AMQP_EXPORT
void AMQP_CALL empty_amqp_pool(amqp_pool_t *pool);
/**
@@ -923,7 +853,7 @@ void AMQP_CALL empty_amqp_pool(amqp_pool_t *pool);
*
* \since v0.1
*/
-AMQP_PUBLIC_FUNCTION
+AMQP_EXPORT
void *AMQP_CALL amqp_pool_alloc(amqp_pool_t *pool, size_t amount);
/**
@@ -945,7 +875,7 @@ void *AMQP_CALL amqp_pool_alloc(amqp_pool_t *pool, size_t amount);
*
* \since v0.1
*/
-AMQP_PUBLIC_FUNCTION
+AMQP_EXPORT
void AMQP_CALL amqp_pool_alloc_bytes(amqp_pool_t *pool, size_t amount,
amqp_bytes_t *output);
@@ -967,7 +897,7 @@ void AMQP_CALL amqp_pool_alloc_bytes(amqp_pool_t *pool, size_t amount,
*
* \since v0.1
*/
-AMQP_PUBLIC_FUNCTION
+AMQP_EXPORT
amqp_bytes_t AMQP_CALL amqp_cstring_bytes(char const *cstr);
/**
@@ -986,7 +916,7 @@ amqp_bytes_t AMQP_CALL amqp_cstring_bytes(char const *cstr);
*
* \since v0.1
*/
-AMQP_PUBLIC_FUNCTION
+AMQP_EXPORT
amqp_bytes_t AMQP_CALL amqp_bytes_malloc_dup(amqp_bytes_t src);
/**
@@ -1003,7 +933,7 @@ amqp_bytes_t AMQP_CALL amqp_bytes_malloc_dup(amqp_bytes_t src);
*
* \since v0.1
*/
-AMQP_PUBLIC_FUNCTION
+AMQP_EXPORT
amqp_bytes_t AMQP_CALL amqp_bytes_malloc(size_t amount);
/**
@@ -1020,7 +950,7 @@ amqp_bytes_t AMQP_CALL amqp_bytes_malloc(size_t amount);
*
* \since v0.1
*/
-AMQP_PUBLIC_FUNCTION
+AMQP_EXPORT
void AMQP_CALL amqp_bytes_free(amqp_bytes_t bytes);
/**
@@ -1035,7 +965,7 @@ void AMQP_CALL amqp_bytes_free(amqp_bytes_t bytes);
*
* \since v0.1
*/
-AMQP_PUBLIC_FUNCTION
+AMQP_EXPORT
amqp_connection_state_t AMQP_CALL amqp_new_connection(void);
/**
@@ -1055,7 +985,7 @@ amqp_connection_state_t AMQP_CALL amqp_new_connection(void);
*
* \since v0.1
*/
-AMQP_PUBLIC_FUNCTION
+AMQP_EXPORT
int AMQP_CALL amqp_get_sockfd(amqp_connection_state_t state);
/**
@@ -1075,8 +1005,8 @@ int AMQP_CALL amqp_get_sockfd(amqp_connection_state_t state);
*
* \since v0.1
*/
-AMQP_DEPRECATED(AMQP_PUBLIC_FUNCTION void AMQP_CALL
- amqp_set_sockfd(amqp_connection_state_t state, int sockfd));
+AMQP_DEPRECATED_EXPORT void AMQP_CALL
+ amqp_set_sockfd(amqp_connection_state_t state, int sockfd);
/**
* Tune client side parameters
@@ -1110,7 +1040,7 @@ AMQP_DEPRECATED(AMQP_PUBLIC_FUNCTION void AMQP_CALL
*
* \since v0.1
*/
-AMQP_PUBLIC_FUNCTION
+AMQP_EXPORT
int AMQP_CALL amqp_tune_connection(amqp_connection_state_t state,
int channel_max, int frame_max,
int heartbeat);
@@ -1126,7 +1056,7 @@ int AMQP_CALL amqp_tune_connection(amqp_connection_state_t state,
*
* \since v0.1
*/
-AMQP_PUBLIC_FUNCTION
+AMQP_EXPORT
int AMQP_CALL amqp_get_channel_max(amqp_connection_state_t state);
/**
@@ -1140,7 +1070,7 @@ int AMQP_CALL amqp_get_channel_max(amqp_connection_state_t state);
*
* \since v0.6
*/
-AMQP_PUBLIC_FUNCTION
+AMQP_EXPORT
int AMQP_CALL amqp_get_frame_max(amqp_connection_state_t state);
/**
@@ -1154,7 +1084,7 @@ int AMQP_CALL amqp_get_frame_max(amqp_connection_state_t state);
*
* \since v0.6
*/
-AMQP_PUBLIC_FUNCTION
+AMQP_EXPORT
int AMQP_CALL amqp_get_heartbeat(amqp_connection_state_t state);
/**
@@ -1174,7 +1104,7 @@ int AMQP_CALL amqp_get_heartbeat(amqp_connection_state_t state);
*
* \since v0.1
*/
-AMQP_PUBLIC_FUNCTION
+AMQP_EXPORT
int AMQP_CALL amqp_destroy_connection(amqp_connection_state_t state);
/**
@@ -1219,7 +1149,7 @@ int AMQP_CALL amqp_destroy_connection(amqp_connection_state_t state);
*
* \since v0.1
*/
-AMQP_PUBLIC_FUNCTION
+AMQP_EXPORT
int AMQP_CALL amqp_handle_input(amqp_connection_state_t state,
amqp_bytes_t received_data,
amqp_frame_t *decoded_frame);
@@ -1241,7 +1171,7 @@ int AMQP_CALL amqp_handle_input(amqp_connection_state_t state,
*
* \since v0.1
*/
-AMQP_PUBLIC_FUNCTION
+AMQP_EXPORT
amqp_boolean_t AMQP_CALL amqp_release_buffers_ok(amqp_connection_state_t state);
/**
@@ -1268,7 +1198,7 @@ amqp_boolean_t AMQP_CALL amqp_release_buffers_ok(amqp_connection_state_t state);
*
* \since v0.1
*/
-AMQP_PUBLIC_FUNCTION
+AMQP_EXPORT
void AMQP_CALL amqp_release_buffers(amqp_connection_state_t state);
/**
@@ -1288,7 +1218,7 @@ void AMQP_CALL amqp_release_buffers(amqp_connection_state_t state);
*
* \since v0.1
*/
-AMQP_PUBLIC_FUNCTION
+AMQP_EXPORT
void AMQP_CALL amqp_maybe_release_buffers(amqp_connection_state_t state);
/**
@@ -1311,7 +1241,7 @@ void AMQP_CALL amqp_maybe_release_buffers(amqp_connection_state_t state);
*
* \since v0.4.0
*/
-AMQP_PUBLIC_FUNCTION
+AMQP_EXPORT
void AMQP_CALL amqp_maybe_release_buffers_on_channel(
amqp_connection_state_t state, amqp_channel_t channel);
@@ -1336,7 +1266,7 @@ void AMQP_CALL amqp_maybe_release_buffers_on_channel(
*
* \since v0.1
*/
-AMQP_PUBLIC_FUNCTION
+AMQP_EXPORT
int AMQP_CALL amqp_send_frame(amqp_connection_state_t state,
amqp_frame_t const *frame);
@@ -1352,7 +1282,7 @@ int AMQP_CALL amqp_send_frame(amqp_connection_state_t state,
*
* \since v0.1
*/
-AMQP_PUBLIC_FUNCTION
+AMQP_EXPORT
int AMQP_CALL amqp_table_entry_cmp(void const *entry1, void const *entry2);
/**
@@ -1382,7 +1312,7 @@ int AMQP_CALL amqp_table_entry_cmp(void const *entry1, void const *entry2);
*
* \since v0.1
*/
-AMQP_PUBLIC_FUNCTION
+AMQP_EXPORT
int AMQP_CALL amqp_open_socket(char const *hostname, int portnumber);
/**
@@ -1406,7 +1336,7 @@ int AMQP_CALL amqp_open_socket(char const *hostname, int portnumber);
*
* \since v0.1
*/
-AMQP_PUBLIC_FUNCTION
+AMQP_EXPORT
int AMQP_CALL amqp_send_header(amqp_connection_state_t state);
/**
@@ -1425,7 +1355,7 @@ int AMQP_CALL amqp_send_header(amqp_connection_state_t state);
*
* \since v0.1
*/
-AMQP_PUBLIC_FUNCTION
+AMQP_EXPORT
amqp_boolean_t AMQP_CALL amqp_frames_enqueued(amqp_connection_state_t state);
/**
@@ -1479,7 +1409,7 @@ amqp_boolean_t AMQP_CALL amqp_frames_enqueued(amqp_connection_state_t state);
*
* \since v0.1
*/
-AMQP_PUBLIC_FUNCTION
+AMQP_EXPORT
int AMQP_CALL amqp_simple_wait_frame(amqp_connection_state_t state,
amqp_frame_t *decoded_frame);
@@ -1546,7 +1476,7 @@ int AMQP_CALL amqp_simple_wait_frame(amqp_connection_state_t state,
*
* \since v0.4.0
*/
-AMQP_PUBLIC_FUNCTION
+AMQP_EXPORT
int AMQP_CALL amqp_simple_wait_frame_noblock(amqp_connection_state_t state,
amqp_frame_t *decoded_frame,
const struct timeval *tv);
@@ -1592,7 +1522,7 @@ int AMQP_CALL amqp_simple_wait_frame_noblock(amqp_connection_state_t state,
* \since v0.1
*/
-AMQP_PUBLIC_FUNCTION
+AMQP_EXPORT
int AMQP_CALL amqp_simple_wait_method(amqp_connection_state_t state,
amqp_channel_t expected_channel,
amqp_method_number_t expected_method,
@@ -1624,7 +1554,7 @@ int AMQP_CALL amqp_simple_wait_method(amqp_connection_state_t state,
*
* \since v0.1
*/
-AMQP_PUBLIC_FUNCTION
+AMQP_EXPORT
int AMQP_CALL amqp_send_method(amqp_connection_state_t state,
amqp_channel_t channel, amqp_method_number_t id,
void *decoded);
@@ -1661,7 +1591,7 @@ int AMQP_CALL amqp_send_method(amqp_connection_state_t state,
*
* \since v0.1
*/
-AMQP_PUBLIC_FUNCTION
+AMQP_EXPORT
amqp_rpc_reply_t AMQP_CALL amqp_simple_rpc(
amqp_connection_state_t state, amqp_channel_t channel,
amqp_method_number_t request_id, amqp_method_number_t *expected_reply_ids,
@@ -1681,7 +1611,7 @@ amqp_rpc_reply_t AMQP_CALL amqp_simple_rpc(
*
* \since v0.1
*/
-AMQP_PUBLIC_FUNCTION
+AMQP_EXPORT
void *AMQP_CALL amqp_simple_rpc_decoded(amqp_connection_state_t state,
amqp_channel_t channel,
amqp_method_number_t request_id,
@@ -1727,7 +1657,7 @@ void *AMQP_CALL amqp_simple_rpc_decoded(amqp_connection_state_t state,
*
* \since v0.1
*/
-AMQP_PUBLIC_FUNCTION
+AMQP_EXPORT
amqp_rpc_reply_t AMQP_CALL amqp_get_rpc_reply(amqp_connection_state_t state);
/**
@@ -1787,7 +1717,7 @@ amqp_rpc_reply_t AMQP_CALL amqp_get_rpc_reply(amqp_connection_state_t state);
*
* \since v0.1
*/
-AMQP_PUBLIC_FUNCTION
+AMQP_EXPORT
amqp_rpc_reply_t AMQP_CALL amqp_login(amqp_connection_state_t state,
char const *vhost, int channel_max,
int frame_max, int heartbeat,
@@ -1853,7 +1783,7 @@ amqp_rpc_reply_t AMQP_CALL amqp_login(amqp_connection_state_t state,
*
* \since v0.4.0
*/
-AMQP_PUBLIC_FUNCTION
+AMQP_EXPORT
amqp_rpc_reply_t AMQP_CALL amqp_login_with_properties(
amqp_connection_state_t state, char const *vhost, int channel_max,
int frame_max, int heartbeat, const amqp_table_t *properties,
@@ -1906,7 +1836,7 @@ struct amqp_basic_properties_t_;
*
* \since v0.1
*/
-AMQP_PUBLIC_FUNCTION
+AMQP_EXPORT
int AMQP_CALL amqp_basic_publish(
amqp_connection_state_t state, amqp_channel_t channel,
amqp_bytes_t exchange, amqp_bytes_t routing_key, amqp_boolean_t mandatory,
@@ -1924,7 +1854,7 @@ int AMQP_CALL amqp_basic_publish(
*
* \since v0.1
*/
-AMQP_PUBLIC_FUNCTION
+AMQP_EXPORT
amqp_rpc_reply_t AMQP_CALL amqp_channel_close(amqp_connection_state_t state,
amqp_channel_t channel, int code);
@@ -1942,7 +1872,7 @@ amqp_rpc_reply_t AMQP_CALL amqp_channel_close(amqp_connection_state_t state,
*
* \since v0.1
*/
-AMQP_PUBLIC_FUNCTION
+AMQP_EXPORT
amqp_rpc_reply_t AMQP_CALL amqp_connection_close(amqp_connection_state_t state,
int code);
@@ -1962,7 +1892,7 @@ amqp_rpc_reply_t AMQP_CALL amqp_connection_close(amqp_connection_state_t state,
*
* \since v0.1
*/
-AMQP_PUBLIC_FUNCTION
+AMQP_EXPORT
int AMQP_CALL amqp_basic_ack(amqp_connection_state_t state,
amqp_channel_t channel, uint64_t delivery_tag,
amqp_boolean_t multiple);
@@ -1983,7 +1913,7 @@ int AMQP_CALL amqp_basic_ack(amqp_connection_state_t state,
*
* \since v0.1
*/
-AMQP_PUBLIC_FUNCTION
+AMQP_EXPORT
amqp_rpc_reply_t AMQP_CALL amqp_basic_get(amqp_connection_state_t state,
amqp_channel_t channel,
amqp_bytes_t queue,
@@ -2005,7 +1935,7 @@ amqp_rpc_reply_t AMQP_CALL amqp_basic_get(amqp_connection_state_t state,
*
* \since v0.1
*/
-AMQP_PUBLIC_FUNCTION
+AMQP_EXPORT
int AMQP_CALL amqp_basic_reject(amqp_connection_state_t state,
amqp_channel_t channel, uint64_t delivery_tag,
amqp_boolean_t requeue);
@@ -2029,7 +1959,7 @@ int AMQP_CALL amqp_basic_reject(amqp_connection_state_t state,
*
* \since v0.5.0
*/
-AMQP_PUBLIC_FUNCTION
+AMQP_EXPORT
int AMQP_CALL amqp_basic_nack(amqp_connection_state_t state,
amqp_channel_t channel, uint64_t delivery_tag,
amqp_boolean_t multiple, amqp_boolean_t requeue);
@@ -2045,7 +1975,7 @@ int AMQP_CALL amqp_basic_nack(amqp_connection_state_t state,
*
* \since v0.1
*/
-AMQP_PUBLIC_FUNCTION
+AMQP_EXPORT
amqp_boolean_t AMQP_CALL amqp_data_in_buffer(amqp_connection_state_t state);
/**
@@ -2063,8 +1993,7 @@ amqp_boolean_t AMQP_CALL amqp_data_in_buffer(amqp_connection_state_t state);
*
* \since v0.1
*/
-AMQP_DEPRECATED(
- AMQP_PUBLIC_FUNCTION char *AMQP_CALL amqp_error_string(int err));
+AMQP_DEPRECATED_EXPORT char *AMQP_CALL amqp_error_string(int err);
/**
* Get the error string for the given error code.
@@ -2077,7 +2006,7 @@ AMQP_DEPRECATED(
*
* \since v0.4.0
*/
-AMQP_PUBLIC_FUNCTION
+AMQP_EXPORT
const char *AMQP_CALL amqp_error_string2(int err);
/**
@@ -2100,7 +2029,7 @@ const char *AMQP_CALL amqp_error_string2(int err);
*
* \since v0.1
*/
-AMQP_PUBLIC_FUNCTION
+AMQP_EXPORT
int AMQP_CALL amqp_decode_table(amqp_bytes_t encoded, amqp_pool_t *pool,
amqp_table_t *output, size_t *offset);
@@ -2123,7 +2052,7 @@ int AMQP_CALL amqp_decode_table(amqp_bytes_t encoded, amqp_pool_t *pool,
*
* \since v0.1
*/
-AMQP_PUBLIC_FUNCTION
+AMQP_EXPORT
int AMQP_CALL amqp_encode_table(amqp_bytes_t encoded, amqp_table_t *input,
size_t *offset);
@@ -2145,7 +2074,7 @@ int AMQP_CALL amqp_encode_table(amqp_bytes_t encoded, amqp_table_t *input,
*
* \since v0.4.0
*/
-AMQP_PUBLIC_FUNCTION
+AMQP_EXPORT
int AMQP_CALL amqp_table_clone(const amqp_table_t *original,
amqp_table_t *clone, amqp_pool_t *pool);
@@ -2179,7 +2108,7 @@ typedef struct amqp_message_t_ {
*
* \since v0.4.0
*/
-AMQP_PUBLIC_FUNCTION
+AMQP_EXPORT
amqp_rpc_reply_t AMQP_CALL amqp_read_message(amqp_connection_state_t state,
amqp_channel_t channel,
amqp_message_t *message,
@@ -2192,7 +2121,7 @@ amqp_rpc_reply_t AMQP_CALL amqp_read_message(amqp_connection_state_t state,
*
* \since v0.4.0
*/
-AMQP_PUBLIC_FUNCTION
+AMQP_EXPORT
void AMQP_CALL amqp_destroy_message(amqp_message_t *message);
/**
@@ -2243,7 +2172,7 @@ typedef struct amqp_envelope_t_ {
*
* \since v0.4.0
*/
-AMQP_PUBLIC_FUNCTION
+AMQP_EXPORT
amqp_rpc_reply_t AMQP_CALL amqp_consume_message(amqp_connection_state_t state,
amqp_envelope_t *envelope,
const struct timeval *timeout,
@@ -2257,7 +2186,7 @@ amqp_rpc_reply_t AMQP_CALL amqp_consume_message(amqp_connection_state_t state,
*
* \since v0.4.0
*/
-AMQP_PUBLIC_FUNCTION
+AMQP_EXPORT
void AMQP_CALL amqp_destroy_envelope(amqp_envelope_t *envelope);
/**
@@ -2292,7 +2221,7 @@ struct amqp_connection_info {
*
* \since v0.2
*/
-AMQP_PUBLIC_FUNCTION
+AMQP_EXPORT
void AMQP_CALL
amqp_default_connection_info(struct amqp_connection_info *parsed);
@@ -2322,7 +2251,7 @@ void AMQP_CALL
*
* \since v0.2
*/
-AMQP_PUBLIC_FUNCTION
+AMQP_EXPORT
int AMQP_CALL amqp_parse_url(char *url, struct amqp_connection_info *parsed);
/* socket API */
@@ -2343,7 +2272,7 @@ int AMQP_CALL amqp_parse_url(char *url, struct amqp_connection_info *parsed);
*
* \since v0.4.0
*/
-AMQP_PUBLIC_FUNCTION
+AMQP_EXPORT
int AMQP_CALL amqp_socket_open(amqp_socket_t *self, const char *host, int port);
/**
@@ -2364,7 +2293,7 @@ int AMQP_CALL amqp_socket_open(amqp_socket_t *self, const char *host, int port);
*
* \since v0.4.0
*/
-AMQP_PUBLIC_FUNCTION
+AMQP_EXPORT
int AMQP_CALL amqp_socket_open_noblock(amqp_socket_t *self, const char *host,
int port, const struct timeval *timeout);
@@ -2382,7 +2311,7 @@ int AMQP_CALL amqp_socket_open_noblock(amqp_socket_t *self, const char *host,
*
* \since v0.4.0
*/
-AMQP_PUBLIC_FUNCTION
+AMQP_EXPORT
int AMQP_CALL amqp_socket_get_sockfd(amqp_socket_t *self);
/**
@@ -2393,7 +2322,7 @@ int AMQP_CALL amqp_socket_get_sockfd(amqp_socket_t *self);
*
* \since v0.4.0
*/
-AMQP_PUBLIC_FUNCTION
+AMQP_EXPORT
amqp_socket_t *AMQP_CALL amqp_get_socket(amqp_connection_state_t state);
/**
@@ -2406,7 +2335,7 @@ amqp_socket_t *AMQP_CALL amqp_get_socket(amqp_connection_state_t state);
*
* \since v0.5.0
*/
-AMQP_PUBLIC_FUNCTION
+AMQP_EXPORT
amqp_table_t *AMQP_CALL
amqp_get_server_properties(amqp_connection_state_t state);
@@ -2422,7 +2351,7 @@ amqp_table_t *AMQP_CALL
*
* \since v0.7.0
*/
-AMQP_PUBLIC_FUNCTION
+AMQP_EXPORT
amqp_table_t *AMQP_CALL
amqp_get_client_properties(amqp_connection_state_t state);
@@ -2445,7 +2374,7 @@ amqp_table_t *AMQP_CALL
*
* \since v0.9.0
*/
-AMQP_PUBLIC_FUNCTION
+AMQP_EXPORT
struct timeval *AMQP_CALL
amqp_get_handshake_timeout(amqp_connection_state_t state);
@@ -2472,7 +2401,7 @@ struct timeval *AMQP_CALL
*
* \since v0.9.0
*/
-AMQP_PUBLIC_FUNCTION
+AMQP_EXPORT
int AMQP_CALL amqp_set_handshake_timeout(amqp_connection_state_t state,
const struct timeval *timeout);
@@ -2501,7 +2430,7 @@ int AMQP_CALL amqp_set_handshake_timeout(amqp_connection_state_t state,
*
* \since v0.9.0
*/
-AMQP_PUBLIC_FUNCTION
+AMQP_EXPORT
struct timeval *AMQP_CALL amqp_get_rpc_timeout(amqp_connection_state_t state);
/**
@@ -2530,7 +2459,7 @@ struct timeval *AMQP_CALL amqp_get_rpc_timeout(amqp_connection_state_t state);
*
* \since v0.9.0
*/
-AMQP_PUBLIC_FUNCTION
+AMQP_EXPORT
int AMQP_CALL amqp_set_rpc_timeout(amqp_connection_state_t state,
const struct timeval *timeout);