diogo/symfony
Archived
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

minor #31346 [Messenger] Lowercased method calls on \Redis (chalasr)

Browse Source 
This PR was merged into the 4.3-dev branch.

Discussion
----------

[Messenger] Lowercased method calls on \Redis

| Q             | A
| ------------- | ---
| Branch?       | master
| Bug fix?      | no
| New feature?  | no
| BC breaks?    | no
| Deprecations? | no
| Tests pass?   | yes
| Fixed tickets | https://github.com/symfony/symfony/pull/31298#discussion_r279312710
| License       | MIT
| Doc PR        | n/a

64e71b5307/php_redis.h (L231-L244)

Commits
-------

2d41976b26 [Messenger] Lowercased method calls on \Redis
This commit is contained in:
Fabien Potencier 2019-05-02 07:45:21 +02:00
commit 446480e2f7
1 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
src/Symfony/Component/Messenger/Transport/RedisExt/Connection.php
View File

@ -79,7 +79,7 @@ class Connection
$e = null;
try {
$messages = $this->connection->xReadGroup(
$messages = $this->connection->xreadgroup(
$this->group,
$this->consumer,
[$this->stream => $messageId],
@ -119,7 +119,7 @@ class Connection
{
$e = null;
try {
$acknowledged = $this->connection->xAck($this->stream, $this->group, [$id]);
$acknowledged = $this->connection->xack($this->stream, $this->group, [$id]);
} catch (\RedisException $e) {
}
@ -132,7 +132,7 @@ class Connection
{
$e = null;
try {
$deleted = $this->connection->xDel($this->stream, [$id]);
$deleted = $this->connection->xdel($this->stream, [$id]);
} catch (\RedisException $e) {
}
@ -145,7 +145,7 @@ class Connection
{
$e = null;
try {
$added = $this->connection->xAdd($this->stream, '*', ['message' => json_encode(
$added = $this->connection->xadd($this->stream, '*', ['message' => json_encode(
['body' => $body, 'headers' => $headers]
)]);
} catch (\RedisException $e) {
@ -159,7 +159,7 @@ class Connection
public function setup(): void
{
try {
$this->connection->xGroup('CREATE', $this->stream, $this->group, 0, true);
$this->connection->xgroup('CREATE', $this->stream, $this->group, 0, true);
} catch (\RedisException $e) {
throw new TransportException($e->getMessage(), 0, $e);
}