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 <cl...@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.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
>
>
_______________________________________________
dancer-users mailing list
dancer-users@dancer.pm
http://lists.preshweb.co.uk/mailman/listinfo/dancer-users
