![]() |
Home | Documentation |
mq.h File Reference
updated Thu Aug 24 2017 by Robert van Engelen
|
#include "stdsoap2.h"

Classes | |
| struct | soap_mq_data |
| Plugin data. More... | |
| struct | soap_mq_msg |
| Queued inbound message (in linked list). More... | |
| struct | soap_mq_queue |
| Message queue. More... | |
Macros | |
| #define | SOAP_MQ_ID "MQ-0.9" |
Functions | |
| SOAP_FMAC1 int SOAP_FMAC2 | soap_mq (struct soap *soap, struct soap_plugin *plugin, void *arg) |
| SOAP_FMAC1 struct soap_mq_queue *SOAP_FMAC2 | soap_mq_queue (struct soap *) |
| Create a new queue structure allocated in the current context. Will be deallocated with soap_end(soap). Use soap_mq_get() to receive a message from the current socket to add to the queue. More... | |
| SOAP_FMAC1 struct soap_mq_msg *SOAP_FMAC2 | soap_mq_get (struct soap *soap, struct soap_mq_queue *) |
| Receive message from socket and queue it at the end of the queue. More... | |
| SOAP_FMAC1 struct soap_mq_msg *SOAP_FMAC2 | soap_mq_begin (struct soap_mq_queue *) |
| Get first message in queue. Use msg->soap to invoke service from the queued message, as in soap_serve(&msg->soap). More... | |
| SOAP_FMAC1 struct soap_mq_msg *SOAP_FMAC2 | soap_mq_next (struct soap_mq_msg *) |
| Get next message in queue. Use msg->soap to invoke service from the queued message, as in soap_serve(&msg->soap). More... | |
| SOAP_FMAC1 void SOAP_FMAC2 | soap_mq_del (struct soap_mq_queue *, struct soap_mq_msg *) |
| Delete message from queue, e.g. after processing it. Delete entire queue when msg==NULL. Note: structures will be deallocated with deallocation with soap_end(). More... | |
Variables | |
| const char | soap_mq_id [] |
| #define SOAP_MQ_ID "MQ-0.9" |
| SOAP_FMAC1 int SOAP_FMAC2 soap_mq | ( | struct soap * | soap, |
| struct soap_plugin * | p, | ||
| void * | arg | ||
| ) |
plugin registry function, invoked by soap_register_plugin
| struct soap_mq_msg * soap_mq_begin | ( | struct soap_mq_queue * | mq | ) |
Get first message in queue. Use msg->soap to invoke service from the queued message, as in soap_serve(&msg->soap).
| mq | pointer to the message queue structure created by soap_mq_queue() |
| void soap_mq_del | ( | struct soap_mq_queue * | mq, |
| struct soap_mq_msg * | msg | ||
| ) |
Delete message from queue, e.g. after processing it. Delete entire queue when msg==NULL. Note: structures will be deallocated with deallocation with soap_end().
| mq | pointer to the queue structure |
| msg | pointer to a message in the queue, when NULL delete entire queue |
| struct soap_mq_msg * soap_mq_get | ( | struct soap * | soap, |
| struct soap_mq_queue * | mq | ||
| ) |
Receive message from socket and queue it at the end of the queue.
| soap | current context |
| mq | pointer to the message queue structure created by soap_mq_queue() |
| struct soap_mq_msg * soap_mq_next | ( | struct soap_mq_msg * | msg | ) |
Get next message in queue. Use msg->soap to invoke service from the queued message, as in soap_serve(&msg->soap).
| msg | pointer to current message in the queue |
| struct soap_mq_queue * soap_mq_queue | ( | struct soap * | soap | ) |
Create a new queue structure allocated in the current context. Will be deallocated with soap_end(soap). Use soap_mq_get() to receive a message from the current socket to add to the queue.
| soap | current context |
| const char soap_mq_id[] |