sub connect {
my ( $self );
my $hostname = 'localhost';
my $port = '61613';
my $port = '616132';
my $config = C4::Context->config('message_broker');
my $credentials = {
login => 'guest',
-