Download the PHP package brightecapital/sqs without Composer
On this page you can find all versions of the php package brightecapital/sqs. It is possible to download/install these versions without Composer. Possible dependencies are resolved automatically.
Table of contents
Download brightecapital/sqs
More information about brightecapital/sqs
Files in brightecapital/sqs
Download brightecapital/sqs
More information about brightecapital/sqs
Files in brightecapital/sqs
Vendor brightecapital
Package sqs
Short Description AWS SQS Transport (fork and improve from enqueue/sqs)
License MIT
Homepage https://github.com/brightecapital/
Package sqs
Short Description AWS SQS Transport (fork and improve from enqueue/sqs)
License MIT
Homepage https://github.com/brightecapital/
Please rate this library. Is it a good library?
Informations about the package sqs
Brighte Sqs
Description
This project was forked from enqueue/sqs and made the following improvements:
- Move all classes to src
- Rename Tests to tests
- Move examples to tests
- Change namespace to Brighte\Sqs
SqsProducer->send():
public function send(Destination $destination, Message $message): void
{
InvalidDestinationException::assertDestinationInstanceOf($destination, SqsDestination::class);
InvalidMessageException::assertMessageInstanceOf($message, SqsMessage::class);
$body = $message->getBody();
if (empty($body)) {
throw new InvalidMessageException('The message body must be a non-empty string.');
}
$arguments = [
'@region' => $destination->getRegion(),
'MessageBody' => $body,
'QueueUrl' => $this->context->getQueueUrl($destination),
];
if (null !== $this->deliveryDelay) {
$arguments['DelaySeconds'] = (int) $this->deliveryDelay / 1000;
}
if ($message->getDelaySeconds()) {
$arguments['DelaySeconds'] = $message->getDelaySeconds();
}
if ($message->getMessageDeduplicationId()) {
$arguments['MessageDeduplicationId'] = $message->getMessageDeduplicationId();
}
if ($message->getMessageGroupId()) {
$arguments['MessageGroupId'] = $message->getMessageGroupId();
}
if ($message->getHeaders()) {
$arguments['MessageAttributes']['Headers'] = [
'DataType' => 'String',
'StringValue' => json_encode([$message->getHeaders()]),
];
}
if ($message->getProperties()) {
foreach ($message->getProperties() as $name => $value) {
$arguments['MessageAttributes'][$name] = ['DataType' => 'String', 'StringValue' => $value];
}
}
$result = $this->context->getSqsClient()->sendMessage($arguments);
if (false == $result->hasKey('MessageId')) {
throw new \RuntimeException('Message was not sent');
}
$message->setMessageId($result['MessageId']);
}
SqsConsumer->covertMessage():
protected function convertMessage(array $sqsMessage): SqsMessage
{
$message = $this->context->createMessage();
$message->setBody($sqsMessage['Body']);
$message->setReceiptHandle($sqsMessage['ReceiptHandle']);
if (isset($sqsMessage['Attributes'])) {
$message->setAttributes($sqsMessage['Attributes']);
if (isset($sqsMessage['Attributes']['MessageDeduplicationId'])) {
$message->setMessageDeduplicationId($sqsMessage['Attributes']['MessageDeduplicationId']);
}
if (isset($sqsMessage['Attributes']['MessageGroupId'])) {
$message->setMessageGroupId($sqsMessage['Attributes']['MessageGroupId']);
}
}
if (isset($sqsMessage['Attributes']['ApproximateReceiveCount'])) {
$message->setRedelivered(((int) $sqsMessage['Attributes']['ApproximateReceiveCount']) > 1);
}
if (isset($sqsMessage['MessageAttributes'])) {
foreach ($sqsMessage['MessageAttributes'] as $name => $attribute) {
if ($name == 'Headers') {
$headers = json_decode($attribute['StringValue'], true);
$message->setHeaders($headers);
} else {
$message->setProperty($name, $attribute['StringValue']);
}
}
}
if (isset($sqsMessage['MessageId'])) {
$message->setMessageId($sqsMessage['MessageId']);
}
return $message;
}
All versions of sqs with dependencies
PHP Build Version
Package Version
Requires
php Version
^7.1.3
queue-interop/queue-interop Version ^0.7|^0.8
enqueue/dsn Version ^0.9
aws/aws-sdk-php Version ~3.26
queue-interop/queue-interop Version ^0.7|^0.8
enqueue/dsn Version ^0.9
aws/aws-sdk-php Version ~3.26
The package brightecapital/sqs contains the following files
Loading the files please wait ...