'current_sid',
'message_count',
],
};
use strict;
use warnings;
use URI;
use JSON;
use Net::NATS::Connection;
use Net::NATS::Message;
use Net::NATS::ServerInfo;
use Net::NATS::Co
or return;
$self->connection($connection);
}
my $connect = 'CONNECT ' . to_json($connect_info, { convert_blessed => 1});
$self->connection->send($connect);
return 1;
}
', $line);
}
sub handle_info {
my $self = shift;
my (@args) = @_;
my $hash = decode_json($args[0]);
return Net::NATS::ServerInfo->new(%$hash);
}
sub parse_msg {
my $self = shift