qamqp/src/qamqp/amqp_p.h

52 lines
1.0 KiB
C
Raw Normal View History

#ifndef qamqp_amqp_p_h__
#define qamqp_amqp_p_h__
#include <QSharedPointer>
#include "amqp_global.h"
#include "amqp_network.h"
#include "amqp_connection.h"
#include "amqp_authenticator.h"
namespace QAMQP
{
class ClientPrivate
{
P_DECLARE_PUBLIC(QAMQP::Client)
public:
ClientPrivate(Client * q ) ;
~ClientPrivate();
2012-05-28 18:01:49 +08:00
void init(QObject * parent);
void init(QObject * parent, const QUrl & connectionString);
void printConnect() const;
void connect();
void disconnect();
void parseCnnString( const QUrl & connectionString);
void sockConnect();
void login();
void setAuth(Authenticator* auth);
Exchange * createExchange(int channelNumber, const QString &name);
Queue * createQueue(int channelNumber, const QString &name);
quint32 port;
QString host;
QString virtualHost;
QPointer<QAMQP::Network> network_;
QPointer<QAMQP::Connection> connection_;
QSharedPointer<Authenticator> auth_;
2012-05-23 18:23:20 +08:00
bool isSSl() const;
2012-05-23 18:49:56 +08:00
Client * const pq_ptr;
};
2012-05-28 18:01:49 +08:00
}
#endif // amqp_p_h__