Commit df6fa6d5 authored by Bc. Pavol Beňko's avatar Bc. Pavol Beňko
Browse files

uprava listenera zo set na publish

parent 5bf208a7
......@@ -38,7 +38,7 @@ public class JedisListener extends JedisPubSub{
log.log(Level.INFO, "New message for module AmountOfTransferredData received", AmountOfTransferredData.getInstance().getModuleName());
if(Config.AmountOfTransferredData==true){
jedis.set("AmountOfTransferredDataTableSIG", "OK");
jedis.publish("AmountOfTransferredDataTableSIG", "OK");
AmountOfTransferredData.getInstance().getPoolRequest().add(new PoolRequest.Request(channel, message));
System.out.println("Prijata sprava z webu: "+message);
......@@ -54,7 +54,7 @@ public class JedisListener extends JedisPubSub{
log.log(Level.INFO, "New message for module AmountOfTransferredData received", AmountOfTransferredData.getInstance().getModuleName());
if(Config.AmountOfTransferredData==true){
jedis.set("AmountOfTransferredDataSIG", "OK");
jedis.publish("AmountOfTransferredDataSIG", "OK");
AmountOfTransferredData.getInstance().getPoolRequest().add(new PoolRequest.Request(channel, message));
System.out.println("Prijata sprava z webu: "+message);
......@@ -69,7 +69,7 @@ public class JedisListener extends JedisPubSub{
case "BandwidthHistoryTrend": {
log.log(Level.INFO, "New message for module BandwidthHistoryTrend received", BandwidthHistoryTrend.getInstance().getModuleName());
if(Config.BandwidthHistoryTrend==true){
jedis.set("BandwidthHistoryTrendSIG", "OK");
jedis.publish("BandwidthHistoryTrendSIG", "OK");
BandwidthHistoryTrend.getInstance().getPoolRequest().add(new PoolRequest.Request(channel, message));
System.out.println("Prijata sprava z webu: "+message);
......@@ -83,7 +83,7 @@ public class JedisListener extends JedisPubSub{
case "AverageDownloadUploadPacket": {
log.log(Level.INFO, "New message for module AverageOfTransferredDataPacket received", AverageDownloadUploadPacket.getInstance().getModuleName());
if(Config.AverageOfTransferredDataPacket==true){
jedis.set("AverageDownloadUploadPacketSIG", "OK");
jedis.publish("AverageDownloadUploadPacketSIG", "OK");
AverageDownloadUploadPacket.getInstance().getPoolRequest().add(new PoolRequest.Request(channel, message));
System.out.println("Prijata sprava z webu: "+message);
......@@ -97,7 +97,7 @@ public class JedisListener extends JedisPubSub{
case "MaximumDownloadUpload": {
log.log(Level.INFO, "New message for module MaximumDownloadUpload received", MaximumDownloadUpload.getInstance().getModuleName());
if(Config.MaximumDownloadUpload==true){
jedis.set("MaximumDownloadUploadSIG", "OK");
jedis.publish("MaximumDownloadUploadSIG", "OK");
MaximumDownloadUpload.getInstance().getPoolRequest().add(new PoolRequest.Request(channel, message));
System.out.println("Prijata sprava z webu: "+message);
......@@ -111,7 +111,7 @@ public class JedisListener extends JedisPubSub{
case "AmountOfTransferredDataPacket": {
log.log(Level.INFO, "New message for module AmountOfTransferredDataPacket received", AmountOfTransferredDataPacket.getInstance().getModuleName());
if(Config.AmountOfTransferredDataPacket==true){
jedis.set("AmountOfTransferredDataPacketSIG", "OK");
jedis.publish("AmountOfTransferredDataPacketSIG", "OK");
AmountOfTransferredDataPacket.getInstance().getPoolRequest().add(new PoolRequest.Request(channel, message));
System.out.println("Prijata sprava z webu: "+message);
......@@ -125,7 +125,7 @@ public class JedisListener extends JedisPubSub{
case "BandwidthHistoryTrendPacket": {
log.log(Level.INFO, "New message for module BandwidthHistoryTrendPacket received", BandwidthHistoryTrendPacket.getInstance().getModuleName());
if(Config.BandwidthHistoryTrendPacket==true){
jedis.set("BandwidthHistoryTrendPacketSIG", "OK");
jedis.publish("BandwidthHistoryTrendPacketSIG", "OK");
BandwidthHistoryTrendPacket.getInstance().getPoolRequest().add(new PoolRequest.Request(channel, message));
System.out.println("Prijata sprava z webu: "+message);
......@@ -139,7 +139,7 @@ public class JedisListener extends JedisPubSub{
case "AverageMiniTable": {
log.log(Level.INFO, "New message for module AverageMiniTable received", AverageMiniTable.getInstance().getModuleName());
if(Config.AverageMiniTable==true){
jedis.set("AverageMiniTableSIG", "OK");
jedis.publish("AverageMiniTableSIG", "OK");
AverageMiniTable.getInstance().getPoolRequest().add(new PoolRequest.Request(channel, message));
System.out.println("Prijata sprava z webu: "+message);
......@@ -153,7 +153,7 @@ public class JedisListener extends JedisPubSub{
case "HistoryTrendFlows": {
log.log(Level.INFO, "New message for module HistoryTrendFlows received", HistoryTrendFlows.getInstance().getModuleName());
if(Config.HistoryTrendFlows==true){
jedis.set("HistoryTrendFlowsSIG", "OK");
jedis.publish("HistoryTrendFlowsSIG", "OK");
HistoryTrendFlows.getInstance().getPoolRequest().add(new PoolRequest.Request(channel, message));
System.out.println("Prijata sprava z webu: "+message);
......@@ -168,7 +168,7 @@ public class JedisListener extends JedisPubSub{
case "AverageDownloadUpload": {
log.log(Level.INFO, "New message for module AverageOfTransferredData received", AverageDownloadUpload.getInstance().getModuleName());
if(Config.AverageOfTransferredData==true){
jedis.set("AverageDownloadUploadSIG", "OK");
jedis.publish("AverageDownloadUploadSIG", "OK");
AverageDownloadUpload.getInstance().getPoolRequest().add(new PoolRequest.Request(channel, message));
System.out.println("Prijata sprava z webu: "+message);
......@@ -182,7 +182,7 @@ public class JedisListener extends JedisPubSub{
case "HistoryTable": {
log.log(Level.INFO, "New message for module HistoryTable received", HistoryTable.getInstance().getModuleName());
if(Config.HistoryTable==true){
jedis.set("HistoryTableSIG", "OK");
jedis.publish("HistoryTableSIG", "OK");
HistoryTable.getInstance().getPoolRequest().add(new PoolRequest.Request(channel, message));
System.out.println("Prijata sprava z webu: "+message);
......@@ -197,7 +197,7 @@ public class JedisListener extends JedisPubSub{
case "AmountMiniTable": {
log.log(Level.INFO, "New message for module AmountMiniTable received", AmountMiniTable.getInstance().getModuleName());
if(Config.AmountMiniTable==true){
jedis.set("AmountMiniTableSIG", "OK");
jedis.publish("AmountMiniTableSIG", "OK");
AmountMiniTable.getInstance().getPoolRequest().add(new PoolRequest.Request(channel, message));
System.out.println("Prijata sprava z webu: "+message);
......@@ -211,7 +211,7 @@ public class JedisListener extends JedisPubSub{
case "NumberOfFlows": {
log.log(Level.INFO, "New message for module NumberOfFlows received", NumberOfFlows.getInstance().getModuleName());
if(Config.NumberOfFlows==true){
jedis.set("NumberOfFlowsSIG", "OK");
jedis.publish("NumberOfFlowsSIG", "OK");
NumberOfFlows.getInstance().getPoolRequest().add(new PoolRequest.Request(channel, message));
System.out.println("Prijata sprava z webu: "+message);
......@@ -225,7 +225,7 @@ public class JedisListener extends JedisPubSub{
case "PingTime": {
log.log(Level.INFO, "New message for module PingTime received", PingTime.getInstance().getModuleName());
if(Config.PingTime==true){
jedis.set("PingTimeSIG", "OK");
jedis.publish("PingTimeSIG", "OK");
PingTime.getInstance().getPoolRequest().add(new PoolRequest.Request(channel, message));
System.out.println("Prijata sprava z webu: "+message);
......@@ -240,7 +240,7 @@ public class JedisListener extends JedisPubSub{
case "TopDownloader": {
log.log(Level.INFO, "New message for module TopDownloader received", TopDownloader.getInstance().getModuleName());
if(Config.TopDownloader==true){
jedis.set("TopDownloaderSIG", "OK");
jedis.publish("TopDownloaderSIG", "OK");
TopDownloader.getInstance().getPoolRequest().add(new PoolRequest.Request(channel, message));
System.out.println("Prijata sprava z webu: "+message);
......@@ -255,7 +255,7 @@ public class JedisListener extends JedisPubSub{
case "TopUploader": {
log.log(Level.INFO, "New message for module TopUploader received", TopUploader.getInstance().getModuleName());
if(Config.TopUploader==true){
jedis.set("TopUploaderSIG", "OK");
jedis.publish("TopUploaderSIG", "OK");
TopUploader.getInstance().getPoolRequest().add(new PoolRequest.Request(channel, message));
System.out.println("Prijata sprava z webu: "+message);
......
Markdown is supported
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment