#include <Redis_Provider.h>
using std::chrono::milliseconds;


RedisProvider::RedisProvider(){
	setKey("DAQ_key");
	this->stream = rediscpp::make_stream("localhost", "6379");

}

RedisProvider::RedisProvider(std::string ip, int port, std::string key){
	setKey(key);
	this->stream = rediscpp::make_stream(ip, port);
}


int RedisProvider::write(BasePacket &packet){
	return 1;
}

int RedisProvider::write(BasePacket &packet, std::string key){
	return 1;
}

int RedisProvider::open(){
	return 1;
}

int RedisProvider::close(){
	return 1;
}