Classes

Coverage Distribution

Complexity

Insufficient Coverage

Class Coverage
Symfony\Component\Messenger\Bridge\AmazonSqs\Tests\Fixtures\DummyMessage0%
Symfony\Component\Messenger\Bridge\Redis\Tests\Transport\ConnectionTest0%
Symfony\Component\Messenger\Bridge\Doctrine\Tests\Transport\DoctrineIntegrationTest0%
Symfony\Component\Messenger\Bridge\Doctrine\Tests\Transport\DoctrineReceiverTest0%
Symfony\Component\Messenger\Bridge\Doctrine\Tests\Transport\DoctrineSenderTest0%
Symfony\Component\Messenger\Bridge\Doctrine\Tests\Transport\DoctrineTransportFactoryTest0%
Symfony\Component\Messenger\Bridge\Doctrine\Tests\Transport\DoctrineTransportTest0%
Symfony\Component\Messenger\Bridge\Doctrine\Tests\Transport\PostgreSqlConnectionTest0%
Symfony\Component\Messenger\Bridge\Doctrine\Transport\Connection0%
Symfony\Component\Messenger\Bridge\Doctrine\Transport\DoctrineReceiver0%
Symfony\Component\Messenger\Bridge\AmazonSqs\Tests\Transport\AmazonSqsIntegrationTest0%
Symfony\Component\Messenger\Bridge\Doctrine\Transport\DoctrineTransport0%
Symfony\Component\Messenger\Bridge\Doctrine\Transport\DoctrineTransportFactory0%
Symfony\Component\Messenger\Bridge\Doctrine\Transport\PostgreSqlConnection0%
Symfony\Component\Messenger\Bridge\Redis\Tests\Fixtures\DummyMessage0%
Symfony\Component\Messenger\Bridge\Redis\Tests\Transport\RedisExtIntegrationTest0%
Symfony\Component\Messenger\Bridge\Doctrine\Tests\Fixtures\DummyMessage0%
Symfony\Component\Messenger\Bridge\Redis\Tests\Transport\RedisReceiverTest0%
Symfony\Component\Messenger\Bridge\Redis\Tests\Transport\RedisSenderTest0%
Symfony\Component\Messenger\Bridge\Redis\Tests\Transport\RedisTransportFactoryTest0%
Symfony\Component\Messenger\Bridge\Redis\Tests\Transport\RedisTransportTest0%
Symfony\Component\Messenger\Bridge\Redis\Transport\Connection0%
Symfony\Component\Messenger\Bridge\Redis\Transport\RedisReceiver0%
Symfony\Component\Messenger\Bridge\Redis\Transport\RedisSender0%
Symfony\Component\Messenger\Bridge\Redis\Transport\RedisTransport0%
Symfony\Component\Messenger\Bridge\Redis\Transport\RedisTransportFactory0%
Symfony\Component\Messenger\EventListener\DispatchPcntlSignalListener0%
Symfony\Component\Messenger\EventListener\StopWorkerOnSigtermSignalListener0%
Symfony\Component\Messenger\Middleware\RejectRedeliveredMessageMiddleware0%
Symfony\Component\Messenger\Transport\TransportFactory0%
Symfony\Component\Messenger\Bridge\Doctrine\Tests\Transport\ConnectionTest0%
Symfony\Component\Messenger\Bridge\Doctrine\Transport\DoctrineSender0%
Symfony\Component\Messenger\Bridge\Amqp\Transport\Connection0%
Symfony\Component\Messenger\Bridge\Amqp\Tests\Transport\AmqpExtIntegrationTest0%
Symfony\Component\Messenger\Bridge\AmazonSqs\Tests\Transport\AmazonSqsReceiverTest0%
Symfony\Component\Messenger\Bridge\AmazonSqs\Tests\Transport\AmazonSqsSenderTest0%
Symfony\Component\Messenger\Bridge\AmazonSqs\Tests\Transport\AmazonSqsTransportFactoryTest0%
Symfony\Component\Messenger\Bridge\AmazonSqs\Tests\Transport\AmazonSqsTransportTest0%
Symfony\Component\Messenger\Bridge\Amqp\Transport\AmqpTransportFactory0%
Symfony\Component\Messenger\Bridge\AmazonSqs\Transport\AmazonSqsFifoStamp0%
Symfony\Component\Messenger\Bridge\AmazonSqs\Transport\AmazonSqsReceivedStamp0%
Symfony\Component\Messenger\Bridge\AmazonSqs\Transport\AmazonSqsReceiver0%
Symfony\Component\Messenger\Bridge\AmazonSqs\Transport\AmazonSqsSender0%
Symfony\Component\Messenger\Bridge\AmazonSqs\Transport\AmazonSqsTransport0%
Symfony\Component\Messenger\Bridge\AmazonSqs\Transport\AmazonSqsTransportFactory0%
Symfony\Component\Messenger\Bridge\AmazonSqs\Transport\Connection0%
Symfony\Component\Messenger\Bridge\Amqp\Tests\Fixtures\DummyMessage0%
Symfony\Component\Messenger\Bridge\AmazonSqs\Tests\Transport\ConnectionTest0%
Symfony\Component\Messenger\Bridge\Amqp\Tests\Transport\AmqpReceivedStampTest0%
Symfony\Component\Messenger\Bridge\Amqp\Tests\Transport\AmqpReceiverTest0%
Symfony\Component\Messenger\Bridge\Amqp\Transport\AmqpSender0%
Symfony\Component\Messenger\Bridge\Amqp\Transport\AmqpStamp0%
Symfony\Component\Messenger\Bridge\Amqp\Transport\AmqpReceivedStamp0%
Symfony\Component\Messenger\Bridge\Amqp\Transport\AmqpFactory0%
Symfony\Component\Messenger\Bridge\Amqp\Tests\Transport\TestAmqpFactory0%
Symfony\Component\Messenger\Bridge\Amqp\Transport\AmqpTransport0%
Symfony\Component\Messenger\Bridge\Amqp\Tests\Transport\ConnectionTest0%
Symfony\Component\Messenger\Bridge\Amqp\Tests\Transport\AmqpTransportTest0%
Symfony\Component\Messenger\Bridge\Amqp\Tests\Transport\AmqpTransportFactoryTest0%
Symfony\Component\Messenger\Bridge\Amqp\Tests\Transport\AmqpStampTest0%
Symfony\Component\Messenger\Bridge\Amqp\Tests\Transport\AmqpSenderTest0%
Symfony\Component\Messenger\Bridge\Amqp\Transport\AmqpReceiver0%
Symfony\Component\Messenger\Transport\Sync\SyncTransport60%
Symfony\Component\Messenger\Event\SendMessageToTransportsEvent60%
Symfony\Component\Messenger\Command\ConsumeMessagesCommand61%
Symfony\Component\Messenger\Exception\ValidationFailedException66%
Symfony\Component\Messenger\Event\WorkerStoppedEvent66%
Symfony\Component\Messenger\Event\WorkerStartedEvent66%
Symfony\Component\Messenger\Event\WorkerMessageReceivedEvent66%
Symfony\Component\Messenger\Bridge\Redis\Transport\RedisReceivedStamp66%
Symfony\Component\Messenger\Bridge\Doctrine\Transport\DoctrineReceivedStamp66%
Symfony\Component\Messenger\Command\FailedMessagesRetryCommand67%
Symfony\Component\Messenger\DataCollector\MessengerDataCollector67%
Symfony\Component\Messenger\Middleware\StackMiddleware72%
Symfony\Component\Messenger\Transport\Sync\SyncTransportFactory75%
Symfony\Component\Messenger\TraceableMessageBus75%
Symfony\Component\Messenger\EventListener\StopWorkerOnMemoryLimitListener78%
Symfony\Component\Messenger\Middleware\DispatchAfterCurrentBusMiddleware79%
Symfony\Component\Messenger\Exception\DelayedMessageHandlingException81%
Symfony\Component\Messenger\Command\AbstractFailedMessagesCommand82%
Symfony\Component\Messenger\Retry\MultiplierRetryStrategy83%
Symfony\Component\Messenger\EventListener\StopWorkerOnFailureLimitListener85%
Symfony\Component\Messenger\EventListener\StopWorkerOnRestartSignalListener86%
Symfony\Component\Messenger\EventListener\SendFailedMessageToFailureTransportListener86%
Symfony\Component\Messenger\Worker87%
Symfony\Component\Messenger\EventListener\SendFailedMessageForRetryListener89%

Project Risks

Class CRAP
Symfony\Component\Messenger\Bridge\Redis\Transport\Connection7140
Symfony\Component\Messenger\Bridge\Amqp\Transport\Connection5402
Symfony\Component\Messenger\Bridge\Doctrine\Transport\Connection4692
Symfony\Component\Messenger\Bridge\AmazonSqs\Transport\Connection3782
Symfony\Component\Messenger\Bridge\Redis\Tests\Transport\ConnectionTest1056
Symfony\Component\Messenger\Bridge\Doctrine\Tests\Transport\ConnectionTest702
Symfony\Component\Messenger\Bridge\Doctrine\Transport\DoctrineReceiver506
Symfony\Component\Messenger\Bridge\Doctrine\Transport\PostgreSqlConnection342
Symfony\Component\Messenger\Bridge\Amqp\Tests\Transport\AmqpExtIntegrationTest306
Symfony\Component\Messenger\Bridge\Amqp\Transport\AmqpReceiver306
Symfony\Component\Messenger\Bridge\Doctrine\Tests\Transport\DoctrineIntegrationTest182
Symfony\Component\Messenger\Bridge\AmazonSqs\Transport\AmazonSqsReceiver182
Symfony\Component\Messenger\Bridge\Redis\Tests\Transport\RedisExtIntegrationTest156
Symfony\Component\Messenger\Bridge\AmazonSqs\Transport\AmazonSqsTransport132
Symfony\Component\Messenger\Transport\TransportFactory132
Symfony\Component\Messenger\Bridge\Doctrine\Tests\Transport\DoctrineReceiverTest90
Symfony\Component\Messenger\Command\ConsumeMessagesCommand84
Symfony\Component\Messenger\Bridge\Redis\Transport\RedisReceiver72
Symfony\Component\Messenger\Bridge\AmazonSqs\Tests\Transport\AmazonSqsIntegrationTest72
Symfony\Component\Messenger\Bridge\Amqp\Transport\AmqpSender72
Symfony\Component\Messenger\Bridge\Doctrine\Transport\DoctrineTransportFactory72
Symfony\Component\Messenger\Bridge\Doctrine\Tests\Transport\DoctrineTransportTest42
Symfony\Component\Messenger\Command\FailedMessagesRetryCommand36
Symfony\Component\Messenger\Middleware\RejectRedeliveredMessageMiddleware30
Symfony\Component\Messenger\Bridge\AmazonSqs\Transport\AmazonSqsSender30
Symfony\Component\Messenger\Bridge\Redis\Tests\Transport\RedisTransportTest30
Symfony\Component\Messenger\Bridge\AmazonSqs\Tests\Transport\AmazonSqsTransportTest30
Symfony\Component\Messenger\Bridge\Amqp\Tests\Transport\AmqpTransportTest30
Symfony\Component\Messenger\DataCollector\MessengerDataCollector24
Symfony\Component\Messenger\Command\AbstractFailedMessagesCommand23
Symfony\Component\Messenger\TraceableMessageBus22
Symfony\Component\Messenger\EventListener\SendFailedMessageForRetryListener22
Symfony\Component\Messenger\Bridge\Redis\Tests\Transport\RedisTransportFactoryTest20
Symfony\Component\Messenger\Bridge\Doctrine\Transport\DoctrineSender20
Symfony\Component\Messenger\Worker19
Symfony\Component\Messenger\Transport\Sync\SyncTransport12
Symfony\Component\Messenger\EventListener\DispatchPcntlSignalListener12
Symfony\Component\Messenger\EventListener\StopWorkerOnSigtermSignalListener12
Symfony\Component\Messenger\Bridge\Redis\Transport\RedisSender12
Symfony\Component\Messenger\Middleware\StackMiddleware9
Symfony\Component\Messenger\Middleware\DispatchAfterCurrentBusMiddleware8
Symfony\Component\Messenger\Retry\MultiplierRetryStrategy8
Symfony\Component\Messenger\EventListener\StopWorkerOnFailureLimitListener8
Symfony\Component\Messenger\EventListener\StopWorkerOnRestartSignalListener8
Symfony\Component\Messenger\EventListener\SendFailedMessageToFailureTransportListener8
Symfony\Component\Messenger\EventListener\StopWorkerOnMemoryLimitListener6
Symfony\Component\Messenger\Exception\DelayedMessageHandlingException3
Symfony\Component\Messenger\Event\WorkerMessageReceivedEvent2

Methods

Coverage Distribution

Complexity

Insufficient Coverage

Method Coverage
__construct0%
getMessageCount0%
reject0%
ack0%
get0%
__construct0%
send0%
__construct0%
createEnvelopeFromData0%
findDoctrineReceivedStamp0%
find0%
all0%
reject0%
all0%
ack0%
get0%
__construct0%
getId0%
updateSchema0%
decodeEnvelopeHeaders0%
addTableToSchema0%
getSchema0%
executeStatement0%
executeQuery0%
getMessageCount0%
find0%
createAvailableMessagesQueryBuilder0%
reset0%
testFromDsn0%
testFromInvalidDsn0%
setUpBeforeClass0%
getMessage0%
__construct0%
unlisten0%
getTriggerSql0%
getExtraSetupSqlForTable0%
setup0%
get0%
__destruct0%
send0%
__wakeup0%
__sleep0%
supports0%
createTransport0%
__construct0%
getSender0%
getReceiver0%
getExtraSetupSqlForTable0%
configureSchema0%
setup0%
createQueryBuilder0%
getExtraSetupSqlForTable0%
testFromDsnWithOptions0%
testItRetrieveTheFirstAvailableMessage0%
createDoctrineEnvelope0%
testFind0%
testAll0%
testOccursRetryableExceptionFromConnection0%
testItRejectTheMessageIfThereIsAMessageDecodingFailedException0%
testItReturnsTheDecodedMessageToTheHandler0%
formatDateTime0%
testTheTransportIsSetupOnGet0%
testItRetrieveTheMessageThatIsOlderThanRedeliverTimeout0%
getMessage0%
testSendWithDelay0%
testSend0%
testConnectionSendAndGet0%
tearDown0%
setUp0%
testConfigureSchemaTableExists0%
testConfigureSchemaDifferentDbalConnection0%
testConfigureSchema0%
testFindAll0%
testFind0%
testItThrowsAnExceptionIfAnExtraOptionsInDefinedInDSN0%
testItThrowsAnExceptionIfAnExtraOptionsInDefined0%
createSerializer0%
testSendWithDelay0%
configureSchema0%
reset0%
find0%
findAll0%
getMessageCount0%
setup0%
reject0%
ack0%
get0%
send0%
buildConfiguration0%
getConfiguration0%
__construct0%
testSupports0%
testGetExtraSetupSqlWrongTable0%
testGetExtraSetupSql0%
testUnserialize0%
testSerialize0%
getTransport0%
testConfigureSchema0%
testReceivesMessages0%
testItIsATransport0%
testCreateTransportMustThrowAnExceptionIfManagerIsNotFound0%
testCreateTransport0%
testFromDsnOnUnixSocket0%
testFromDsnWithOptionsAndTrailingSlash0%
testBuildConfiguration0%
send0%
reset0%
getName0%
collect0%
runInteractive0%
convertToBytes0%
supports0%
createTransport0%
getSender0%
getReceiver0%
setup0%
reject0%
getBuses0%
ack0%
get0%
__construct0%
send0%
__construct0%
findRedisReceivedStamp0%
reject0%
ack0%
get0%
__construct0%
getExceptionsCount0%
setEnvelope0%
cleanup0%
getViolations0%
supports0%
createTransport0%
__construct0%
supports0%
reject0%
ack0%
stop0%
get0%
reset0%
handle0%
getViolatingMessage0%
getWorker0%
getExceptions0%
getSubscribedEvents0%
getSubscribedEvents0%
onWorkerStarted0%
getSubscribedEvents0%
getSubscribedEvents0%
getSubscribedEvents0%
getSubscribedEvents0%
onWorkerRunning0%
getWorker0%
getId0%
getCurrentTimeInMilliseconds0%
testFromDsnWithTls0%
testClaimAbandonedMessage0%
testGetTheFirstAvailableMessage0%
testConnectionSendAndGet0%
setUp0%
testLastErrorGetsCleared0%
testDeleteAfterAck0%
testMaxEntries0%
testJsonError0%
testGetNonBlocking0%
testGetAfterReject0%
testUnexpectedRedisError0%
testClaimAbandonedMessageWithRaceCondition0%
testConnectionSendAndGetDelayed0%
testGetPendingMessageFirst0%
testDbIndex0%
testFailedAuth0%
testAuthZeroPassword0%
testNoAuthWithEmptyPassword0%
testAuth0%
testKeepGettingPendingMessages0%
testDeprecationIfInvalidOptionIsPassedWithDsn0%
testFromDsnWithQueryOptions0%
testFromDsnWithTlsOption0%
testConnectionSendWithSameContent0%
testConnectionSendDelayedMessagesWithSameContent0%
setup0%
testItIsATransport0%
add0%
reject0%
ack0%
get0%
claimOldPendingMessages0%
validateOptions0%
fromDsn0%
__construct0%
getTransport0%
testReceivesMessages0%
skipIfRedisUnavailable0%
testConnectionBelowRedeliverTimeout0%
testCreateTransport0%
testSupportsOnlyRedisTransports0%
testSend0%
createSerializer0%
createRedisEnvelope0%
testItRejectTheMessageIfThereIsAMessageDecodingFailedException0%
testItReturnsTheDecodedMessageToTheHandler0%
getConnectionStream0%
getConnectionGroup0%
testConnectionClaimAndRedeliver0%
buildConfigurationProvider0%
testItCountMessages0%
getResultMock0%
getPendingMessages0%
__construct0%
isFifoQueue0%
getQueueUrl0%
reset0%
send0%
getMessageCount0%
delete0%
setup0%
fetchMessage0%
getNewMessages0%
getNextMessages0%
setUp0%
get0%
fromDsn0%
__destruct0%
__construct0%
supports0%
createTransport0%
getSender0%
getReceiver0%
reset0%
setup0%
getMessage0%
testItSendsAndReceivesMessages0%
reject0%
testItSendsTheEncodedMessage0%
testSupportsOnlyAmqpTransports0%
testCreateFromAmqpEnvelopeWithPreviousStamp0%
testCreateFromAmqpEnvelope0%
testFlagsAndAttributes0%
testRoutingKeyOnly0%
testItThrowsATransportExceptionIfItCannotSendTheMessage0%
testContentTypeHeaderDoesNotOverwriteAttribute0%
testContentTypeHeaderIsMovedToAttribute0%
testItSendsTheEncodedMessageWithoutHeaders0%
testItSendsTheEncodedMessageUsingARoutingKey0%
createAMQPEnvelope0%
testRetryAndDelay0%
getQueryBuilderMock0%
testItThrowsATransportExceptionIfItCannotAcknowledgeMessage0%
testItReturnsTheDecodedMessageToTheHandler0%
testStamp0%
receiveEnvelopes0%
assertApproximateDuration0%
createSerializer0%
waitForOutput0%
testItCountsMessagesInQueue0%
testItReceivesSignals0%
send0%
ack0%
testItIsATransport0%
testItIsATransport0%
testFromDsnWithCustomEndpoint0%
testFromDsnWithRegion0%
testDsnPrecedence0%
testFromDsn0%
testFromInvalidDsn0%
testConfigureWithCredentials0%
testExtraParamsInQuery0%
testExtraOptions0%
getTransport0%
testReceivesMessages0%
testSupportsOnlySqsTransports0%
testFromDsnWithSslModeOnDefault0%
testSendWithAmazonSqsFifoStamp0%
testSend0%
createSerializer0%
createSqsEnvelope0%
testItRejectTheMessageIfThereIsAMessageDecodingFailedException0%
testItReturnsTheDecodedMessageToTheHandler0%
clearSqs0%
execute0%
testConnectionSendAndGet0%
testConnectionSendToFifoQueueAndGet0%
testFromDsnWithSslMode0%
testFromDsnWithCustomEndpointAndPort0%
get0%
__construct0%
__construct0%
send0%
__construct0%
findSqsReceivedStamp0%
getMessageCount0%
reject0%
ack0%
get0%
__construct0%
getId0%
getMessageDeduplicationId0%
testFromDsnWithOptions0%
getMessageGroupId0%
__construct0%
testUnexpectedSqsError0%
testKeepGettingPendingMessages0%
testFromDsnWithInvalidQueryStringAndOption0%
testFromDsnWithInvalidOption0%
testFromDsnWithInvalidQueryString0%
testFromDsnWithAccountAndEndpointOption0%
testFromDsnWithQueueNameOption0%
testFromDsnWithQueryOptions0%
testItCreatesTheTransport0%
testItThrowsATransportExceptionIfItCannotRejectMessage0%
testReceivesMessages0%
getReceiver0%
publishWithDelay0%
countMessagesInQueues0%
publish0%
normalizeQueueArguments0%
validateOptions0%
fromDsn0%
__construct0%
supports0%
createTransport0%
getTransport0%
getMessageCount0%
setupDelay0%
setup0%
send0%
reject0%
ack0%
get0%
__construct0%
createWithAttributes0%
createFromAmqpEnvelope0%
getAttributes0%
getFlags0%
publishOnExchange0%
getDelayExchange0%
__construct0%
shouldSetup0%
getDBALConnectionMock0%
testItThrowsATransportExceptionIfItCannotRejectMessage0%
testItThrowsATransportExceptionIfItCannotAcknowledgeMessage0%
testGetWithNoPendingMessageWillReturnNull0%
testGetAMessageWillChangeItsStatus0%
getMessage0%
__construct0%
getRoutingKeyForMessage0%
purgeQueues0%
getDefaultPublishRoutingKey0%
clearWhenDisconnected0%
createDelayQueue0%
exchange0%
queue0%
channel0%
getQueueNames0%
setupExchangeAndQueues0%
setup0%
nack0%
ack0%
get0%
getRoutingKeyForDelay0%
getRoutingKey0%
getSender0%
send0%
__construct0%
testDeprecationIfInvalidOptionIsPassedWithDsn0%
testItCanPublishWithCustomFlagsAndAttributes0%
testItDelaysTheMessageWithTheInitialSuppliedRoutingKeyAsArgument0%
testItCanPublishWithASuppliedRoutingKey0%
testItCanPublishWithTheDefaultRoutingKey0%
testAmqpStampDelireryModeIsUsed0%
testDeprecationIfInvalidOptionIsPassedAsArgument0%
testDeprecationIfInvalidQueueOptionIsPassed0%
testDeprecationIfInvalidExchangeOptionIsPassed0%
testAmqpStampHeadersAreUsed0%
testObfuscatePasswordInDsn0%
testBindingArguments0%
testItDelaysTheMessageWithADifferentRoutingKeyAndTTLs0%
testItDelaysTheMessage0%
testAutoSetupWithDelayDeclaresExchangeQueuesAndDelay0%
testSetsParametersOnTheQueueAndExchange0%
invalidQueueArgumentsDataProvider0%
testFromDsnWithInvalidValueOnQueueArguments0%
testItUsesANormalConnectionByDefault0%
testItAllowsToUseAPersistentConnection0%
testSetChannelPrefetchWhenSetup0%
testItSetupsTheConnectionWithDefaults0%
testItCanDisableTheSetup0%
__construct0%
testOptionsAreTakenIntoAccountAndOverwrittenByDsn0%
testOverrideOptionsViaQueryParameters0%
createExchange0%
findAmqpStamp0%
rejectAmqpEnvelope0%
getMessageCount0%
reject0%
ack0%
getEnvelope0%
get0%
__construct0%
getQueueName0%
getAmqpEnvelope0%
__construct0%
createQueue0%
testItGetsParametersFromTheDsn0%
createChannel0%
createConnection0%
createExchange0%
createQueue0%
createChannel0%
testItCannotBeConstructedWithAWrongDsn0%
testItCanBeConstructedWithDefaults0%
createConnection0%
testItSetupsTheConnection0%
interact33%
getMessages40%
printPendingMessagesMessage40%
__construct61%
shouldHandle66%
__construct66%
getSenderForTransport66%
getCaller69%
guessHandledClasses70%
execute72%
getMimeTypeForFormat72%
__construct72%
handleMessage73%
dispatchEvent75%
execute77%
handle79%
retrySpecificIds80%
onWorkerRunning80%
__construct80%
shouldRetry80%
__construct80%
registerReceivers81%
displaySingleMessage82%
create83%
__construct83%
getClassDescription83%
onMessageFailed84%
callableName85%
removeMessages85%
getServiceClass85%
dispatch87%
onMessageFailed89%

Project Risks

Method CRAP
get306
fromDsn240
send210
fromDsn182
add156
__construct132
fromDsn110
validateOptions72
setup72
addTableToSchema72
get72
createTransport56
get56
convertToBytes56
send56
fetchMessage56
claimOldPendingMessages56
runInteractive56
reject42
executeStatement42
get42
ack42
getResultMock30
testFindAll30
buildConfiguration30
channel30
getEnvelope30
handle30
setup30
get30
setUpBeforeClass20
get20
createTransport20
send20
findAll20
find20
updateSchema20
normalizeQueueArguments20
reset20
executeQuery20
execute18
getCaller17
interact16
guessHandledClasses14
registerReceivers14
getTransport12
getExtraSetupSqlForTable12
get12
all12
configureSchema12
__construct12
send12
setup12
testOccursRetryableExceptionFromConnection12
getMessageCount12
find12
getTransport12
exchange12
testSendWithDelay12
publish12
execute12
getTransport12
supports12
get12
getNewMessages12
testItReceivesSignals12
waitForOutput12
receiveEnvelopes12
__construct12
getTransport12
publishOnExchange12
setupExchangeAndQueues12
shouldSetup12
setUp12
queue12
testLastErrorGetsCleared12
displaySingleMessage10
handle8
shouldRetry8
handleMessage7
callableName7
removeMessages7
getMimeTypeForFormat6
__construct6
onMessageFailed6
skipIfRedisUnavailable6
findRedisReceivedStamp6
reset6
getSubscribedEvents6
getExceptionsCount6
validateOptions6
send6
getSubscribedEvents6
testConnectionSendToFifoQueueAndGet6
testJsonError6
setUp6
setupDelay6
unlisten6
rejectAmqpEnvelope6
getMessageCount6
ack6
get6
assertApproximateDuration6
getQueueUrl6
clearWhenDisconnected6
getPendingMessages6
reset6
setup6
findSqsReceivedStamp6
getMessageCount6
reject6
ack6
getDelayExchange6
findAmqpStamp6
purgeQueues6
tearDown6
findDoctrineReceivedStamp6
ack6
testConnectionSendAndGet6
createAvailableMessagesQueryBuilder6
reject6
ack6
send6
createEnvelopeFromData6
__construct6
getMessageCount6
reject6
testItThrowsATransportExceptionIfItCannotRejectMessage6
setUp6
getRoutingKeyForMessage6
testItThrowsATransportExceptionIfItCannotAcknowledgeMessage6
execute5
onMessageFailed5
printPendingMessagesMessage4
__construct4
retrySpecificIds4
getServiceClass4
dispatch4
onWorkerRunning3
__construct3
getClassDescription3
getMessages2
__construct2
shouldHandle2
getSenderForTransport2
dispatchEvent2
__construct2
__construct2
create2