I do a very similar thing for a custom redis plugin I wrote
You have to declare the object outside the BUILD and set it inside
eg
package Dredis;
use Redis::Fast;
use Dancer2::Plugin;
my $redii;
sub BUILD {
my ($plugin) = @_;
<snip lots of setup stuff>
$redii->{$r}{$i} = Redis::Fast->new( %opts );
}
Then use $redi-> in the get/set methods
eg
sub dredis {
my( $called, $plugin, $method, @args ) = @_;
return $redii->{$called}->$method(@args);
}
1;
--
Clive Eisen
GPG: 75056DD0
> On 13 Oct 2017, at 14:29, Alfonso Pinto <alfonso.pi...@gmail.com> wrote:
>
> Dear all,
>
> I'm trying to write a Dancer2::Plugin to maintain ZMQ socket and send some
> information to a backend when a request is received.
>
> This is the plugin :
> package Dancer2::Plugin::ZMQ;
>
>
>
> use Dancer2::Plugin;
>
>
>
> use ZMQ::FFI;
>
> use ZMQ::FFI::Constants qw(ZMQ_REQ);
>
>
>
> has host => (is => 'ro');
>
> has identity => (is => 'ro');
>
>
>
> has _context => (is => 'ro', lazy_build => 1);
>
> sub _build_context {
>
> my $plugin = shift;
>
> return ZMQ::FFI->new();
>
> }
>
>
>
> has client => (is => 'ro', lazy_build => 1, plugin_keyword => 'zmq');
>
> sub _build_client {
>
> my $plugin = shift;
>
>
>
> my $client = $plugin->_context->socket(ZMQ_REQ);
>
> $client->set_identity = $plugin->config->{identity} . "-$$";
>
> $client->connect($plugin->config->{host});
>
> return $client;
>
> }
>
>
>
> 1;
>
>
> This is my config.yml:
>
> plugins:
> ZMQ:
> identity: "api-gw"
> host: "tcp://proxy:6660"
>
>
> And this is how I use it in one route:
>
> post '/' => sub {
> my $message = body_parameters->get('message');
> zmq->send(message =>$message);
> my $reply = zmq->recv();
> return {"reply" => $reply};
> };
>
>
> The issue is that I get this error:
> Router exception: Can't call method "send" on an undefined
>
> I don't understand why it's not keeping the client instantiated. What is
> wrong withmy approach? What I don't want is to create a socket for each
> request received.
>
> And before someone asks, the backend is working and replying. A simple script
> like this one works in my setup:
>
> use v5.10;
> use ZMQ::FFI qw(ZMQ_REQ);
>
> my $endpoint = "tcp://proxy:6660";
> my $ctx = ZMQ::FFI->new();
>
> my $s1 = $ctx->socket(ZMQ_REQ);
> $s1->connect($endpoint);
>
> $s1->send('ohhai');
> print $s1->recv();
>
> Thanks in advance.
> Regards,
> Alfonso
> _______________________________________________
> dancer-users mailing list
> dancer-users@dancer.pm
> http://lists.preshweb.co.uk/mailman/listinfo/dancer-users
_______________________________________________
dancer-users mailing list
dancer-users@dancer.pm
http://lists.preshweb.co.uk/mailman/listinfo/dancer-users
