diff options
| author | David Wragg <dpw@lshift.net> | 2010-05-30 23:31:40 +0100 |
|---|---|---|
| committer | David Wragg <dpw@lshift.net> | 2010-05-30 23:31:40 +0100 |
| commit | 66a0a987914626fc0ea86067a0ea1dd7a2bebdd2 (patch) | |
| tree | 0e400acdd2e7f35ed47b94d51308b142e82dbeac /examples/amqp_listen.c | |
| parent | 7e8fbea4c9212774c101e33218d26a0dc992dc03 (diff) | |
| download | rabbitmq-c-github-ask-66a0a987914626fc0ea86067a0ea1dd7a2bebdd2.tar.gz | |
Make error codes returned by librabbitmq functions opaque
Windows doesn't generally use POSIX error codes, which poses a problem
for librabbitmq's approach of using those error codes in its API. So
make the librabbitmq error codes opaque: They are still be integers,
but client code is not supposed to assume anything about them, except
that they can be passed to a new amqp_error_string() function which
returns the corresponding error message
Internally, the error codes are either taken from a set of
librabbitmq-specific values, or correspond to an OS-specific (POSIX or
win32) error code, with a simple encoding to indicate which is which.
Diffstat (limited to 'examples/amqp_listen.c')
| -rw-r--r-- | examples/amqp_listen.c | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/examples/amqp_listen.c b/examples/amqp_listen.c index c1401ee..412dcd5 100644 --- a/examples/amqp_listen.c +++ b/examples/amqp_listen.c @@ -125,7 +125,7 @@ int main(int argc, char const * const *argv) { amqp_maybe_release_buffers(conn); result = amqp_simple_wait_frame(conn, &frame); printf("Result %d\n", result); - if (result <= 0) + if (result < 0) break; printf("Frame type %d, channel %d\n", frame.frame_type, frame.channel); @@ -143,7 +143,7 @@ int main(int argc, char const * const *argv) { (int) d->routing_key.len, (char *) d->routing_key.bytes); result = amqp_simple_wait_frame(conn, &frame); - if (result <= 0) + if (result < 0) break; if (frame.frame_type != AMQP_FRAME_HEADER) { @@ -162,7 +162,7 @@ int main(int argc, char const * const *argv) { while (body_received < body_target) { result = amqp_simple_wait_frame(conn, &frame); - if (result <= 0) + if (result < 0) break; if (frame.frame_type != AMQP_FRAME_BODY) { |