m_conn->onDataRead.connect(boost::bind(&SwiftenPlugin::_handleDataRead, this, _1));

			m_conn->connect(Swift::HostAddressPort(Swift::HostAddress(host), port));

#if HAVE_SWIFTEN_3

			serializer = new Swift::XMPPSerializer(&collection, Swift::ClientStreamType, false);

#else

			serializer = new Swift::XMPPSerializer(&collection, Swift::ClientStreamType);

#endif

			m_xmppParser = new Swift::XMPPParser(this, &m_collection2, m_factories->getXMLParserFactory());

			m_xmppParser->parse("<stream:stream xmlns='jabber:client' xmlns:stream='http://etherx.jabber.org/streams' to='localhost' version='1.0'>");

			LOG4CXX_INFO(logger, "Starting the plugin.");

		}

		// NetworkPlugin uses this method to send the data to networkplugin server

		void sendData(const std::string &string) {

			m_conn->write(Swift::createSafeByteArray(string));

		}

		// This method has to call handleDataRead with all received data from network plugin server

		void _handleDataRead(boost::shared_ptr<Swift::SafeByteArray> data) {

			if (m_firstPing) {

				m_firstPing = false;

				NetworkPlugin::PluginConfig cfg;

				cfg.setRawXML(true);

				sendConfig(cfg);

			}

			std::string d(data->begin(), data->end());

			handleDataRead(d);

		}

		void handleStreamStart(const Swift::ProtocolHeader&) {}

#if HAVE_SWIFTEN_3

		void handleElement(boost::shared_ptr<Swift::ToplevelElement> element) {

#else

		void handleElement(boost::shared_ptr<Swift::Element> element) {

#endif

			boost::shared_ptr<Swift::Stanza> stanza = boost::dynamic_pointer_cast<Swift::Stanza>(element);

			if (!stanza) {

				return;

			}

			std::string user = stanza->getFrom().toBare();

			boost::shared_ptr<Swift::Client> client = m_users[user];

			if (!client)

				return;

			stanza->setFrom(client->getJID());