Import: we now skip messages when user is null

This commit is contained in:
Nicolas Lœuillet 2017-02-20 09:16:02 +01:00
parent 48be826ea9
commit b45b6b6707
No known key found for this signature in database
GPG key ID: BDC1EFB5CA0145F2
3 changed files with 6 additions and 3 deletions

View file

@ -46,7 +46,8 @@ abstract class AbstractConsumer
if (null === $user) {
$this->logger->warning('Unable to retrieve user', ['entry' => $storedEntry]);
return false;
// return true to skip message
return true;
}
$this->import->setUser($user);

View file

@ -183,7 +183,9 @@ JSON;
$message = new AMQPMessage($body);
$consumer->execute($message);
$res = $consumer->execute($message);
$this->assertTrue($res);
}
public function testMessageWithEntryProcessed()

View file

@ -182,7 +182,7 @@ JSON;
$res = $consumer->manage($body);
$this->assertFalse($res);
$this->assertTrue($res);
}
public function testMessageWithEntryProcessed()