3 use base qw(Gearman::Driver::Worker);
7 use Data::Dump qw(dump);
12 require RPC::XML::Client;
14 $RPC::XML::ENCODING = "utf-8"; # FIXME really used?
19 my ( $self, $orig, $job_name ) = @_;
20 warn "# process_name $orig $job_name\n";
21 return "$orig ($job_name)";
25 my ( $self, $job, $workload ) = @_;
26 warn "# begin ", dump( $workload );
29 sub username : Job : MinProcesses(1) : MaxProcesses(5) : Encode {
30 my ( $self, $job, $workload ) = @_;
31 warn "# username ",dump($workload);
32 my $cli = RPC::XML::Client->new($self->config('crmxml'));
33 my $resp = $cli->send_request('search',RPC::XML::array->new(
34 USERNAME => '%' . $workload . '%'
36 return ref $resp ? $resp->value->[0] : { error => $resp };
40 my ( $self, $result ) = @_;
41 my $json = JSON::XS::encode_json($result);
42 warn "## ", dump $json;