View | Details | Raw Unified | Return to bug 32242
Collapse All | Expand All

(-)a/Koha/BackgroundJob.pm (-2 / +3 lines)
Lines 16-21 package Koha::BackgroundJob; Link Here
16
# along with Koha; if not, see <http://www.gnu.org/licenses>.
16
# along with Koha; if not, see <http://www.gnu.org/licenses>.
17
17
18
use Modern::Perl;
18
use Modern::Perl;
19
use Encode qw();
19
use JSON;
20
use JSON;
20
use Carp qw( croak );
21
use Carp qw( croak );
21
use Net::Stomp;
22
use Net::Stomp;
Lines 137-143 sub enqueue { Link Here
137
        # Also, here we just want the Koha instance's name, but it's not in the config...
138
        # Also, here we just want the Koha instance's name, but it's not in the config...
138
        # Picking a random id (memcached_namespace) from the config
139
        # Picking a random id (memcached_namespace) from the config
139
        my $namespace = C4::Context->config('memcached_namespace');
140
        my $namespace = C4::Context->config('memcached_namespace');
140
        $conn->send_with_receipt( { destination => sprintf("/queue/%s-%s", $namespace, $job_queue), body => $json_args } )
141
        my $encoded_args = Encode::encode_utf8( $json_args ); # FIXME We should better leave this to Net::Stomp?
142
        $conn->send_with_receipt( { destination => sprintf("/queue/%s-%s", $namespace, $job_queue), body => $encoded_args } )
141
          or Koha::Exceptions::Exception->throw('Job has not been enqueued');
143
          or Koha::Exceptions::Exception->throw('Job has not been enqueued');
142
    } catch {
144
    } catch {
143
        $self->status('failed')->store;
145
        $self->status('failed')->store;
144
- 

Return to bug 32242