Skip to content

Commit b022232

Browse files
committed
Add method from queue-interop 0.6 that defines ttl, priority and delviery delay.
1 parent 8c23607 commit b022232

File tree

1 file changed

+48
-0
lines changed

1 file changed

+48
-0
lines changed

RedisProducer.php

Lines changed: 48 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -36,4 +36,52 @@ public function send(PsrDestination $destination, PsrMessage $message)
3636

3737
$this->redis->lpush($destination->getName(), json_encode($message));
3838
}
39+
40+
/**
41+
* {@inheritdoc}
42+
*/
43+
public function setDeliveryDelay($deliveryDelay)
44+
{
45+
throw new \LogicException('Not implemented');
46+
}
47+
48+
/**
49+
* {@inheritdoc}
50+
*/
51+
public function getDeliveryDelay()
52+
{
53+
return null;
54+
}
55+
56+
/**
57+
* {@inheritdoc}
58+
*/
59+
public function setPriority($priority)
60+
{
61+
throw new \LogicException('Not implemented');
62+
}
63+
64+
/**
65+
* {@inheritdoc}
66+
*/
67+
public function getPriority()
68+
{
69+
return null;
70+
}
71+
72+
/**
73+
* {@inheritdoc}
74+
*/
75+
public function setTimeToLive($timeToLive)
76+
{
77+
throw new \LogicException('Not implemented');
78+
}
79+
80+
/**
81+
* {@inheritdoc}
82+
*/
83+
public function getTimeToLive()
84+
{
85+
return null;
86+
}
3987
}

0 commit comments

Comments
 (0)