X-Git-Url: http://gb7djk.dxcluster.net/gitweb/gitweb.cgi?a=blobdiff_plain;f=perl%2Fcluster.pl;h=0fe3b575a98588be279dac7e658f24170219a8e3;hb=a90885c5c10b837b05ef1ebf718fd88e428a3c91;hp=620c7e77c90a7500a5a8ee5b6d7904cd6ab090ef;hpb=e5c28b46a0f70c78747672091a8edd749aa8488c;p=spider.git

diff --git a/perl/cluster.pl b/perl/cluster.pl
index 620c7e77..0fe3b575 100755
--- a/perl/cluster.pl
+++ b/perl/cluster.pl
@@ -102,6 +102,7 @@ use RouteDB;
 use DXXml;
 use DXSql;
 use IsoTime;
+use BPQMsg;
 
 use Data::Dumper;
 use IO::File;
@@ -260,6 +261,7 @@ sub cease
 
 	# disconnect AGW
 	AGWMsg::finish();
+	BPQMsg::finish();
 
 	# disconnect UDP customers
 	UDPMsg::finish();
@@ -411,6 +413,9 @@ foreach my $l (@main::listen) {
 dbg("AGW Listener") if $AGWMsg::enable;
 AGWrestart();
 
+dbg("BPQ Listener") if $BPQMsg::enable;
+BPQMsg::init(\&new_channel);
+
 dbg("UDP Listener") if $UDPMsg::enable;
 UDPMsg::init(\&new_channel);
 
@@ -538,6 +543,7 @@ for (;;) {
 		DXUser::process();
 		DXDupe::process();
 		AGWMsg::process();
+		BPQMsg::process();
 
 		if (defined &Local::process) {
 			eval {