Skip to content
Snippets Groups Projects
Commit c48bfcab authored by François Agneray's avatar François Agneray
Browse files

Fixed: Rmq close connection

parent ff311e77
No related branches found
No related tags found
1 merge request!72Develop
Pipeline #9061 passed
Pipeline: anis-next

#9062

    ...@@ -127,15 +127,21 @@ final class StartTaskCreateArchiveAction extends AbstractAction ...@@ -127,15 +127,21 @@ final class StartTaskCreateArchiveAction extends AbstractAction
    // Publish message in the archive queue // Publish message in the archive queue
    $channel = $this->rmq->channel(); $channel = $this->rmq->channel();
    $channel->queue_declare('archive', false, false, false, false); $channel->queue_declare('archive', false, false, false, false);
    $msg = new AMQPMessage(json_encode(array( $content = json_encode(array(
    'archive_id' => $archiveId, 'archive_id' => $archiveId,
    'dataset_name' => $datasetName, 'dataset_name' => $datasetName,
    'query' => $request->getUri()->getQuery(), 'query' => $request->getUri()->getQuery(),
    'param_a' => $queryParams['a'], 'param_a' => $queryParams['a'],
    'token' => $token 'token' => $token
    ))); ));
    $msg = new AMQPMessage($content);
    $channel->basic_publish($msg, '', 'archive'); $channel->basic_publish($msg, '', 'archive');
    // Close connection
    $connection = $channel->getConnection();
    $channel->close();
    $connection->close();
    // Just returns the future archive name // Just returns the future archive name
    $payload = json_encode(array('archive_name' => $archiveName, 'archive_id' => $archiveId)); $payload = json_encode(array('archive_name' => $archiveName, 'archive_id' => $archiveId));
    $response->getBody()->write($payload); $response->getBody()->write($payload);
    ......
    0% Loading or .
    You are about to add 0 people to the discussion. Proceed with caution.
    Finish editing this message first!
    Please register or to comment