資源簡介
ativemq異步消息服務器用C開發的客戶端源碼,來自apache官網的例子。本在linux 上編譯通過測試。

代碼片段和文件信息
/**
?*
?*?Licensed?to?the?Apache?Software?Foundation?(ASF)?under?one?or?more
?*?contributor?license?agreements.??See?the?NOTICE?file?distributed?with
?*?this?work?for?additional?information?regarding?copyright?ownership.
?*?The?ASF?licenses?this?file?to?You?under?the?Apache?License?Version?2.0
?*?(the?“License“);?you?may?not?use?this?file?except?in?compliance?with
?*?the?License.??You?may?obtain?a?copy?of?the?License?at
?*
?*?http://www.apache.org/licenses/LICENSE-2.0
?*
?*?Unless?required?by?applicable?law?or?agreed?to?in?writing?software
?*?distributed?under?the?License?is?distributed?on?an?“AS?IS“?BASIS
?*?WITHOUT?WARRANTIES?OR?CONDITIONS?OF?ANY?KIND?either?express?or?implied.
?*?See?the?License?for?the?specific?language?governing?permissions?and
?*?limitations?under?the?License.
?*/
#include?
#include?“amqcs.h“
int?die(int?exitCode?const?char?*message?apr_status_t?reason)?{
????char?msgbuf[80];
apr_strerror(reason?msgbuf?sizeof(msgbuf));
fprintf(stderr?“%s:?%s?(%d)\n“?message?msgbuf?reason);
exit(exitCode);
return?reason;
}
static?void?terminate(void)
{
???apr_terminate();
}
int?main(int?argc?char?*argv[])
{
???apr_status_t?rc;
???amqcs_connection?*connection;
???apr_pool_t?*pool;
???amqcs_connect_options?connect_options;
???
???memset(&connect_options?0?sizeof(connect_options));
???strcpy(connect_options.hostname?“127.0.0.1“);
connect_options.port?=?61616;
???
???setbuf(stdout?NULL);//取消輸出緩存
???
???rc?=?apr_initialize();
if(?rc!=APR_SUCCESS?)?
return?rc;???
???atexit(terminate);
??//atexit注冊終止函數(即main執行結束后調用的函數)?
???rc?=?apr_pool_create(&pool?NULL);
rc==APR_SUCCESS?||?die(-2?“Could?not?allocate?pool“?rc);
???
???fprintf(stdout?“Connecting......“);
???rc=amqcs_connect(?&connection?&connect_options?pool);
rc==APR_SUCCESS?||?die(-2?“Could?not?connect“?rc);
???fprintf(stdout?“OK\n“);
??????
???fprintf(stdout?“Sending?message.“);
???{
??????char?*buffer?=?“Hello?World!“;
??????ow_ActiveMQQueue?*dest;
??ow_ActiveMQTextMessage?*message?=?ow_ActiveMQTextMessage_create(pool);
??????message->content?=?ow_byte_array_create_with_data(poolsizeof(buffer)buffer);
??????dest?=?ow_ActiveMQQueue_create(pool);
??????dest->physicalName?=?ow_string_create_from_cstring(pool“TEST.QUEUE“);?????????
??????rc?=?amqcs_send(connection?(ow_ActiveMQDestination*)dest?(ow_ActiveMQMessage*)message?140pool);
??????rc==APR_SUCCESS?||?die(-2?“Could?not?send?message“?rc);
???}??
???fprintf(stdout?“OK\n“);
???
???fprintf(stdout?“Disconnecting...“);
rc=amqcs_disconnect(&connection);?
rc==APR_SUCCESS?||?die(-2?“Could?not?disconnect“?rc);
???fprintf(stdout?“OK\n“);
???
???apr_pool_destroy(pool);
???
???return?0;
}
?屬性????????????大小?????日期????時間???名稱
-----------?---------??----------?-----??----
?????文件???????2722??2011-11-29?11:28??src\examples\main.c
?????文件???????8585??2011-11-28?18:49??src\libactivemq\amqcs.c
?????文件???????1647??2011-11-28?18:49??src\libactivemq\amqcs.h
?????文件???????8077??2011-11-28?18:50??src\libopenwire\ow.c
?????文件??????10713??2011-11-28?18:50??src\libopenwire\ow.h
?????文件???????8520??2011-11-28?18:50??src\libopenwire\ow_buffer.c
?????文件?????126321??2011-11-28?18:50??src\libopenwire\ow_commands_v1.c
?????文件??????25554??2011-11-28?18:50??src\libopenwire\ow_commands_v1.h
?????文件?????128978??2011-11-28?18:50??src\libopenwire\ow_commands_v2.c
?????文件??????27956??2011-11-28?18:50??src\libopenwire\ow_commands_v2.h
?????文件???????4313??2011-11-28?18:50??src\libopenwire\ow_command_types_v1.h
?????文件??????14329??2011-11-28?18:50??src\libopenwire\ow_marshal.c
?????文件????????162??2011-11-30?16:20??src\Makefile
?????文件?????245760??2011-11-29?11:20??src\prj\activemq_c.IAB
?????文件???????2728??2011-11-29?11:20??src\prj\activemq_c.IAD
?????文件??????61440??2011-11-29?11:20??src\prj\activemq_c.IMB
?????文件????????928??2011-11-29?11:20??src\prj\activemq_c.IMD
?????文件?????????48??2011-11-29?11:28??src\prj\activemq_c.PFI
?????文件????????776??2011-11-29?11:28??src\prj\activemq_c.PO
?????文件???????4256??2011-11-29?11:19??src\prj\activemq_c.PR
?????文件??????24800??2011-11-29?11:20??src\prj\activemq_c.PRI
?????文件?????416924??2011-11-29?11:20??src\prj\activemq_c.PS
?????文件??????67556??2011-12-01?14:20??src\prj\activemq_c.WK3
?????目錄??????????0??2011-12-01?14:25??src\examples
?????目錄??????????0??2011-12-01?14:25??src\libactivemq
?????目錄??????????0??2011-12-01?14:25??src\libopenwire
?????目錄??????????0??2011-12-01?14:25??src\prj
?????目錄??????????0??2011-12-01?14:25??src
-----------?---------??----------?-----??----
??????????????1193093????????????????????28
............此處省略1個文件信息
評論
共有 條評論