removed symlinks from repository because not all systems (hello windows) understand them
This commit is contained in:
parent
df6b8ae743
commit
3a4de6194c
|
|
@ -1 +0,0 @@
|
||||||
../include
|
|
||||||
|
|
@ -7,8 +7,63 @@
|
||||||
* @documentation private
|
* @documentation private
|
||||||
*/
|
*/
|
||||||
|
|
||||||
// include the generic amqp functions
|
// c and c++ dependencies
|
||||||
#include "../amqpcpp.h"
|
#include <stdlib.h>
|
||||||
|
#include <string.h>
|
||||||
|
#include <stdint.h>
|
||||||
|
#include <string>
|
||||||
|
#include <set>
|
||||||
|
#include <memory>
|
||||||
|
#include <limits>
|
||||||
|
#include <ostream>
|
||||||
|
#include <math.h>
|
||||||
|
#include <map>
|
||||||
|
#include <vector>
|
||||||
|
#include <queue>
|
||||||
|
|
||||||
|
// forward declarations
|
||||||
|
#include "../include/classes.h"
|
||||||
|
|
||||||
|
// utility classes
|
||||||
|
#include "../include/endian.h"
|
||||||
|
#include "../include/buffer.h"
|
||||||
|
#include "../include/bytebuffer.h"
|
||||||
|
#include "../include/receivedframe.h"
|
||||||
|
#include "../include/outbuffer.h"
|
||||||
|
#include "../include/watchable.h"
|
||||||
|
#include "../include/monitor.h"
|
||||||
|
|
||||||
|
// amqp types
|
||||||
|
#include "../include/field.h"
|
||||||
|
#include "../include/numericfield.h"
|
||||||
|
#include "../include/decimalfield.h"
|
||||||
|
#include "../include/stringfield.h"
|
||||||
|
#include "../include/booleanset.h"
|
||||||
|
#include "../include/fieldproxy.h"
|
||||||
|
#include "../include/table.h"
|
||||||
|
#include "../include/array.h"
|
||||||
|
|
||||||
|
// envelope for publishing and consuming
|
||||||
|
#include "../include/metadata.h"
|
||||||
|
#include "../include/envelope.h"
|
||||||
|
#include "../include/message.h"
|
||||||
|
|
||||||
|
// mid level includes
|
||||||
|
#include "../include/exchangetype.h"
|
||||||
|
#include "../include/flags.h"
|
||||||
|
#include "../include/callbacks.h"
|
||||||
|
#include "../include/deferred.h"
|
||||||
|
#include "../include/deferredconsumer.h"
|
||||||
|
#include "../include/deferredqueue.h"
|
||||||
|
#include "../include/deferreddelete.h"
|
||||||
|
#include "../include/deferredcancel.h"
|
||||||
|
#include "../include/deferredget.h"
|
||||||
|
#include "../include/channelimpl.h"
|
||||||
|
#include "../include/channel.h"
|
||||||
|
#include "../include/login.h"
|
||||||
|
#include "../include/connectionhandler.h"
|
||||||
|
#include "../include/connectionimpl.h"
|
||||||
|
#include "../include/connection.h"
|
||||||
|
|
||||||
// classes that are very commonly used
|
// classes that are very commonly used
|
||||||
#include "exception.h"
|
#include "exception.h"
|
||||||
|
|
|
||||||
|
|
@ -76,7 +76,7 @@ void MyConnection::onConnected(Network::TcpSocket *socket)
|
||||||
if (_connection) return;
|
if (_connection) return;
|
||||||
|
|
||||||
// create amqp connection, and a new channel
|
// create amqp connection, and a new channel
|
||||||
_connection = std::make_shared<AMQP::Connection>(this, AMQP::Login("guest1", "guest2"), "/");
|
_connection = std::make_shared<AMQP::Connection>(this, AMQP::Login("guest", "guest"), "/");
|
||||||
_channel = std::make_shared<AMQP::Channel>(_connection.get());
|
_channel = std::make_shared<AMQP::Channel>(_connection.get());
|
||||||
|
|
||||||
// install a handler when channel is in error
|
// install a handler when channel is in error
|
||||||
|
|
@ -102,7 +102,7 @@ void MyConnection::onConnected(Network::TcpSocket *socket)
|
||||||
});
|
});
|
||||||
|
|
||||||
// declare an exchange
|
// declare an exchange
|
||||||
_channel->declareExchange("my_exchange", AMQP::direct).onSuccess([]() {
|
_channel->declareExchange().onSuccess([]() {
|
||||||
std::cout << "exchange declared" << std::endl;
|
std::cout << "exchange declared" << std::endl;
|
||||||
});
|
});
|
||||||
|
|
||||||
|
|
|
||||||
Loading…
Reference in New Issue