<HTML>
<HEAD>
<TITLE>Synchronous publish with C client</TITLE>
</HEAD>
<BODY>
<FONT FACE="Calibri, Verdana, Helvetica, Arial"><SPAN STYLE='font-size:11pt'>I know that publish is asynchronous, but from other threads I’ve read I thought that selecting the channel for a transaction, calling publish and then calling commit could be used to accomplish it. I’ve tried doing this in my C code and have been unable to get it to work. I’m using the amq.direct exchange and sending to a nonexistent queue using the mandatory and immediate flags. It appears as though the message is being silently dropped by the server though. I’m running rabbitmQ version 2.2. Here is the code I’m using. Please let me know of any errors there might be in my logic or code. All I get is<BR>
<BR>
[*] Sending some message<BR>
<BR>
outputted when I run this. I would expect to see the ‘Error committingtx’ print if the queue does not exist though.<BR>
<BR>
int main(int argc, char *argv[])<BR>
{<BR>
int rc;<BR>
int sockfd;<BR>
uint16_t channel = 1;<BR>
amqp_rpc_reply_t reply;<BR>
<BR>
amqp_connection_state_t conn = amqp_new_connection();<BR>
//Connect<BR>
sockfd = amqp_open_socket("localhost", 5672);<BR>
if (sockfd < 0)<BR>
{<BR>
printf("Error connecting to localhost:5672\n");<BR>
return 1;<BR>
}<BR>
amqp_set_sockfd(conn, sockfd);<BR>
amqp_login(conn, "/" /* vhost */, 0 /* channel_max */,<BR>
131072 /* frame_max */, 0 /* heartbeat */,<BR>
AMQP_SASL_METHOD_PLAIN, "guest", "guest");<BR>
<BR>
//Create a channel<BR>
amqp_channel_open(conn, channel);<BR>
<BR>
//Set up tx<BR>
amqp_tx_select(conn, channel);<BR>
reply = amqp_get_rpc_reply(conn);<BR>
if (reply.reply_type != AMQP_RESPONSE_NORMAL)<BR>
{<BR>
printf("Error selecting tx\n");<BR>
return 1;<BR>
}<BR>
<BR>
//Send message<BR>
const char *message = "some message";<BR>
printf("[*] Sending %s\n", message);<BR>
amqp_basic_properties_t props;<BR>
memset(&props, 0x00, sizeof(props));<BR>
props.delivery_mode = 2; //persistent<BR>
<BR>
rc = amqp_basic_publish(conn, channel, amqp_cstring_bytes("amq.direct"),<BR>
amqp_cstring_bytes("nonexistent_queue"), 1 /*mandatory*/,<BR>
1 /*immediate*/, &props, amqp_cstring_bytes(message));<BR>
if (rc != 0)<BR>
{<BR>
char *errstr = amqp_error_string(-rc);<BR>
printf("Error publishing: %s\n", errstr);<BR>
free(errstr);<BR>
}<BR>
<BR>
//Now send commit and see if it worked<BR>
amqp_tx_commit(conn, channel);<BR>
reply = amqp_get_rpc_reply(conn);<BR>
if (reply.reply_type != AMQP_RESPONSE_NORMAL)<BR>
{<BR>
printf("Error committing tx\n");<BR>
return 1;<BR>
}<BR>
<BR>
reply = amqp_channel_close(conn, channel, AMQP_REPLY_SUCCESS);<BR>
if (reply.reply_type != AMQP_RESPONSE_NORMAL)<BR>
{<BR>
printf("Error closing channel\n");<BR>
}<BR>
amqp_connection_close(conn, AMQP_REPLY_SUCCESS);<BR>
amqp_destroy_connection(conn);<BR>
<BR>
return 0;<BR>
}<BR>
<BR>
Cheers,<BR>
Shane<BR>
</SPAN></FONT>
<pre>
***************
This e-mail and any files transmitted with it may contain confidential and/or proprietary information. It is intended solely for the use of the individual or entity who is the intended recipient. Unauthorized use of this information is prohibited. If you have received this in error, please contact the sender by replying to this message and delete this material from any system it may be on.
***************
</pre></BODY>
</HTML>