stomp_messenger.h

Go to the documentation of this file.

#ifndef STOMP_H_
#define STOMP_H_

#if defined(__DEBIAN_DISTRO__) || defined(__UBUNTU_DISTRO__)
#include <apr-1.0/apr_general.h>
#include <apr-1.0/apr_network_io.h>
#include <apr-1.0/apr_hash.h>
#include <apr-1.0/apr_uri.h>
#else
#include <apr-1/apr_general.h>
#include <apr-1/apr_network_io.h>
#include <apr-1/apr_hash.h>
#include <apr-1/apr_uri.h>
#endif // defined(__DEBIAN_DISTRO__) || defined(__UBUNTU_DISTRO__)



#include "stomp_status.h"
#include "stomp_connection.h"
#include "stomp_engine.h"
#include "stomp_frame.h"
#include "stomp_io.h"
#include "stomp_headers.h"
#include "stomp_ex_properties.h"
#include "stomp_message.h"

typedef apr_uri_t stomp_uri_t;

typedef struct stomp_messenger_t_ {
    stomp_connection *connection;
    // TODO: not exactly the ideal place for this (nor the ideal design), but
    // will remain in this place until I come up with a better solution
    stomp_exchange_properties_t *exchange_properties;
    stomp_status_t status;
    apr_pool_t *pool;
    stomp_uri_t uri;
} stomp_messenger_t;


stomp_messenger_t *stomp_messenger_init();


void stomp_messenger_destroy(stomp_messenger_t **messenger);


void stomp_messenger_set_timeout(stomp_messenger_t *messenger, 
                                              int32_t timeout);


stomp_status_code_t stomp_set_endpoint(stomp_messenger_t *messenger, 
        const char *uri);


stomp_status_code_t stomp_connect(stomp_messenger_t *messenger, 
                                  stomp_connection_header_t *header,
                                  int32_t timeout);


stomp_status_code_t stomp_disconnect(stomp_messenger_t *messenger, 
                                  stomp_disconnection_header_t *header);



stomp_status_code_t stomp_subscribe(stomp_messenger_t *messenger, 
                                  stomp_subscription_header_t *header);


stomp_status_code_t stomp_unsubscribe(stomp_messenger_t *messenger, 
                                  stomp_subscription_header_t *header);


stomp_status_code_t stomp_ack(stomp_messenger_t *messenger, 
                                  stomp_ack_header_t *header);


stomp_status_code_t stomp_nack(stomp_messenger_t *messenger, 
                                  stomp_ack_header_t *header);


stomp_status_code_t stomp_begin(stomp_messenger_t *messenger, 
                                  stomp_transaction_header_t *header);


stomp_status_code_t stomp_commit(stomp_messenger_t *messenger, 
                                  stomp_transaction_header_t *header);


stomp_status_code_t stomp_abort(stomp_messenger_t *messenger, 
                                  stomp_transaction_header_t *header);


stomp_status_code_t stomp_send(stomp_messenger_t *messenger, 
                                  stomp_send_header_t *header, 
                                  stomp_message_t *message);


stomp_status_code_t stomp_receive(stomp_messenger_t *messenger, 
                                  stomp_receive_header_t *header,
                                  stomp_message_t *message);

#endif /* STOMP_H_ */