Do it the way I did it with a my variable outside to hold your handler. Then you will get one per child (well i do anyway)

--

Clive

On 13 Oct 2017, at 19:07, Alfonso Pinto <alfonso.pinto@gmail.com> wrote:

Hi Clive,

Thanks for the answer. I found 2 things:

-  $client->set_identity = $plugin->config->{identity} . "-$$"; should be  $client->set_identity($plugin->config->{identity} . "-$$");

- Using builders for the properties doesn't work, I've to use BUILD as you suggested.

Now I've this:

package Dancer2::Plugin::ZMQ;

use Dancer2::Plugin;

our $version = '0.01';

use ZMQ::FFI;

use ZMQ::FFI::Constants qw(ZMQ_REQ);

has _context => (is => 'rw');

has _client => (is => 'rw', plugin_keyword => 'zmq');

sub BUILD {

    my $plugin = shift;

    my $args = shift;

    $plugin->_context(ZMQ::FFI->new());

    $plugin->_client($plugin->_context->socket(ZMQ_REQ));

    $plugin->_client->set_identity($plugin->config->{identity} . "-$$");

    $plugin->_client->connect($plugin->config->{host});

}

1;

This works if you run the dancer app as a standalone process. If I run it with Starman that initialises several workers, it doesn't work as it tries to share the same instance between all the workers (you can't share ZMQ context between processes/threads).

Is there any way to create one instance per process?

Regards,

Alfonso.

On Fri, Oct 13, 2017 at 4:32 PM, Clive Eisen <clive@hildebrand.co.uk> wrote:

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.pinto@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

_______________________________________________
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