All Notable changes will be documented in this file. This project adheres to Semantic Versioning.
1.1.0 - 2015-05-10
- Refactoring of response parsing for greater flexibility.
- Added new
Disque\Connection\Manager
class to manage connections to nodes. GETJOB
can now influence which node we are connected to. By means of$disque->getConnectionManager()->setMinimumJobsToChangeNode()
we can specify that if a certain node produces that many jobs, then we should instead connect to the node producing those jobs (as suggested by Disque itself).- Added
Disque\Queue\Queue
andDisque\Queue\Job
class to offer a higher level API that simplifies queueing and fetching jobs - Added method
queue()
toDisque\Client
to create / fetch a queue which is an instance ofDisque\Queue\Queue
- Added
schedule()
method toDisque\Queue
that allows to easily schedule jobs to be processed at a certain time.
Disque\Connection\Connection
is now namedDisque\Connection\Socket
.- The method
setConnectionImplementation
has been moved toDisque\Connection\Manager
, and renamed tosetConnectionClass
. So from a disque instance you can change it via:$disque->getConnectionManager()->setConnectionClass($class)
- Moved exceptions around:
Disque\Exception\InvalidCommandArgumentException
toDisque\Command\Argument\InvalidArgumentException
Disque\Exception\InvalidCommandException
toDisque\Command\InvalidCommandException
Disque\Exception\InvalidCommandOptionException
toDisque\Command\Argument\InvalidOptionException
Disque\Exception\InvalidCommandResponseException
toDisque\Command\Response\InvalidResponseException
Disque\Exception\Connection\Exception\ConnectionException
toDisque\Connection\ConnectionException
Disque\Exception\Connection\Exception\ResponseException
toDisque\Connection\ResponseException
Disque\Exception\DisqueException
toDisque\DisqueException
- Fixed issue where when a
timeout
was using when callinggetJob()
, and the call timed out because there were no jobs available, an non-array would be returned. No on that case it will return an empty array. - Fixed issue where if no options were provided to
addJob()
, yet all three parameters were specified, anInvalidCommandArgumentException
was thrown.
1.0.0 - 2015-05-04
- Added support for commands
HELLO
,INFO
,SHOW
,ADDJOB
,DELJOB
,GETJOB
,ACKJOB
,FASTACK
,ENQUEUE
,DEQUEUE
,QLEN
,QPEEK
. - Added built-in connection to Disque.
- Added support for Predis connections, and allowing adding new connection
methods via
ConnectionInterface
.