Skip to content

Mongodb transport #430

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
merged 25 commits into from
May 3, 2018
Merged

Mongodb transport #430

Show file tree
Hide file tree
Changes from 1 commit
Commits
Show all changes
25 commits
Select commit Hold shift + click to select a range
07ed3ba
Mongo db transport
turboboy88 Apr 26, 2018
4346e9f
client
turboboy88 Apr 27, 2018
83d4b85
smfony transport
turboboy88 Apr 27, 2018
2e8f931
fix
turboboy88 Apr 27, 2018
7e9f62d
develop
turboboy88 Apr 27, 2018
9cbbce8
develop
turboboy88 May 2, 2018
947e00f
Update .travis.yml
makasim May 3, 2018
c17e79f
Merge branch 'master' into mongodb_transport
makasim May 3, 2018
a7ea2f1
update enqueue/dev docker image
makasim May 3, 2018
e924c23
debug travis.
makasim May 3, 2018
e8de54a
use $HOME
makasim May 3, 2018
f76e48d
add group
makasim May 3, 2018
aa3178f
add license, readme, phpunit cfg
makasim May 3, 2018
f460e6c
mongolib ^1.2, ext-mongodb ^1.3
makasim May 3, 2018
41f2b47
require php7.0
makasim May 3, 2018
a9fd835
[doc][skip ci] add docs.
makasim May 3, 2018
368b608
[symfony] add mongodb to default transport and dsn_to_function
makasim May 3, 2018
0f8d1dc
run mongodb tests.
makasim May 3, 2018
41254f9
fix tests.
makasim May 3, 2018
f011a8b
fix tests.
makasim May 3, 2018
b128a65
fix tests
makasim May 3, 2018
e15e92f
fix test.
makasim May 3, 2018
3b8c997
Add mongodb transport.
makasim May 3, 2018
1b23270
mongodb transport, fixes
makasim May 3, 2018
c407d24
revert sf version check
makasim May 3, 2018
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Prev Previous commit
Next Next commit
develop
  • Loading branch information
@turboboy88
turboboy88 committed May 2, 2018
commit 9cbbce8167bf6ebde02bb07fbbf26015636f9ff8
2 changes: 0 additions & 2 deletions pkg/mongodb/MongodbMessage.php
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -66,8 +66,6 @@ public function __construct($body = '', array $properties = [], array $headers =
$this->properties = $properties;
$this->headers = $headers;
$this->redelivered = false;
$this->priority = 0;
$this->deliveryDelay = null;
}

/**
Expand Down
2 changes: 1 addition & 1 deletion pkg/mongodb/MongodbProducer.php
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -52,7 +52,7 @@ public function send(PsrDestination $destination, PsrMessage $message)
InvalidDestinationException::assertDestinationInstanceOf($destination, MongodbDestination::class);
InvalidMessageException::assertMessageInstanceOf($message, MongodbMessage::class);

if (null !== $this->priority && 0 === $message->getPriority()) {
if (null !== $this->priority && null === $message->getPriority()) {
$message->setPriority($this->priority);
}
if (null !== $this->deliveryDelay && null === $message->getDeliveryDelay()) {
Expand Down