trandangtri / sqs-queue-bundle Goto Github PK

While configuring the bundle, a worker MUST be defined in queue configuration. It should be possible to use the bundle just for publishing messages without the worker.

Consider the use-case:
App A, B, and C populate the queue for a microservice app D. The apps A, B, and C do not need/have the worker; only the publisher. In order to use this bundle in publisher apps, they have to create a fake queue worker.

In case the worker is run as a CLI command and an exception is thrown, the $error property storing the message can never be reset leading to false reports in case in case you use, say LoggerInterface::error() to report it.

Add a method to reset the $error property, like a setter or make the property's visibility to protected.
At the moment, the only way to "reset" it, is to use reflection and set the property to accessible.

Reference
https://symfony.com/doc/current/service_container.html#choose-a-specific-service

Hi:

can we add, KmsMasterKeyId and KmsDataKeyReusePeriodSeconds supports? doc is here, https://docs.aws.amazon.com/AWSSimpleQueueService/latest/APIReference/API_SetQueueAttributes.html?

Currently, this bundle supports to enable Redrive policy to use Dead Letter Queue, but that part is missing in documentation.

For FIFO queues the MessageGroupId param is required, but I don't see any method to set it.

I'm getting this error because of that

The request must contain the parameter MessageGroupId.

I'd like to check the ApproximateReceiveCount attribute but its not available since you only specify SentTimestamp.

Perhaps if you don't want to change it to All, allow some configuration to be made?

Hi,
Currently i need this feature http://docs.aws.amazon.com/aws-sdk-php/v3/api/api-sqs-2012-11-05.html#sendmessagebatch in project, it is really helpful if your bundle can support this

Hi,
I'm having difficulty finding a way to log the exception messages that may occur while processing the message:

    try {
        $result = $this->execute($message);
    } catch (\Exception $e) {
        return false;
    }

Maybe remove the try/catch and let the developer catch his own exceptions?

Thanks.

PHP version: 7.1.15
Debug logs:
PHP Fatal error: Cannot redeclare static Symfony\Bundle\FrameworkBundle\Test\KernelTestCase::$container as non static TriTran\SqsQueueBundle\Tests\app\KernelTestCase::$container in /app-vendor/tritran/sqs-queue-bundle/Tests/app/KernelTestCase.php on line 16 PHP Stack trace: PHP 1. {main}() /usr/local/bin/phpunit:0 PHP 2. PHPUnit\TextUI\Command::main() /usr/local/bin/phpunit:574 PHP 3. PHPUnit\TextUI\Command->run() phar:///usr/local/bin/phpunit/phpunit/TextUI/Command.php:153 PHP 4. PHPUnit\TextUI\Command->handleArguments() phar:///usr/local/bin/phpunit/phpunit/TextUI/Command.php:169 PHP 5. PHPUnit\Util\Configuration->getTestSuiteConfiguration() phar:///usr/local/bin/phpunit/phpunit/TextUI/Command.php:849 PHP 6. PHPUnit\Util\Configuration->getTestSuite() phar:///usr/local/bin/phpunit/phpunit/Util/Configuration.php:924 PHP 7. PHPUnit\Framework\TestSuite->addTestFiles() phar:///usr/local/bin/phpunit/phpunit/Util/Configuration.php:1022 PHP 8. PHPUnit\Framework\TestSuite->addTestFile() phar:///usr/local/bin/phpunit/phpunit/Framework/TestSuite.php:418 PHP 9. PHPUnit\Util\FileLoader::checkAndLoad() phar:///usr/local/bin/phpunit/phpunit/Framework/TestSuite.php:340 PHP 10. PHPUnit\Util\FileLoader::load() phar:///usr/local/bin/phpunit/phpunit/Util/FileLoader.php:49 PHP 11. include_once() phar:///usr/local/bin/phpunit/phpunit/Util/FileLoader.php:63 PHP 12. spl_autoload_call() /app-vendor/tritran/sqs-queue-bundle/Tests/Functional/Command/QueueAttCommandTest.php:13 PHP 13. Composer\Autoload\ClassLoader->loadClass() /app-vendor/tritran/sqs-queue-bundle/Tests/Functional/Command/QueueAttCommandTest.php:13 PHP 14. Composer\Autoload\includeFile() /app-vendor/tritran/sqs-queue-bundle/vendor/composer/ClassLoader.php:322 PHP 15. include() /app-vendor/tritran/sqs-queue-bundle/vendor/composer/ClassLoader.php:444

AWS version:
"aws/aws-sdk-php-symfony": "~2.0"
Logs:
Found 1 error while validating the input provided for the CreateQueue operation: [Attributes][ContentBasedDeduplication] must be a string or an object that implements __toString(). Found /app-vendor/aws/aws-sdk -php/src/functions.php:252: bool(false)
Solution: set 'ContentBasedDeduplication' => 'false' in TriTran\SqsQueueBundle\Service\QueueManager

Hi,

I am trying to send an email from worker but the email is not send. Swiftmailer is working correctly, because i can send emails from other commands.