MAKS\AmqpAgent\Worker\AbstractWorker::connect
Establishes a connection with RabbitMQ server and opens a channel for the worker in the opened connection, it also sets both of them as defaults.
Signature
public function connect()
Returns
- AbstractWorker
Defined by Interface
AbstractWorkerInterface
Test Coverage
Information
- Coverage: 5/5 Lines (100%)
- Tests: 38
- Passed: 38 (100%)
Tests
- [ PASSED ] — MAKS\AmqpAgent\Tests\Worker\AbstractWorkerTest::testConnectReturnsAnAMQPStreamConnection
- [ PASSED ] — MAKS\AmqpAgent\Tests\Worker\AbstractWorkerTest::testReconnectRepopulatesClassPropertiesAndReturnsSelf
- [ PASSED ] — MAKS\AmqpAgent\Tests\Worker\AbstractWorkerTest::testQueueReturnsSelf
- [ PASSED ] — MAKS\AmqpAgent\Tests\Worker\AbstractWorkerTest::testGetConnectionReturnsTheDefaultConnection
- [ PASSED ] — MAKS\AmqpAgent\Tests\Worker\AbstractWorkerTest::testGetNewConnectionReturnsANewConnectionAndUsesOverrideParameters
- [ PASSED ] — MAKS\AmqpAgent\Tests\Worker\AbstractWorkerTest::testSetConnectionSetsAnotherConnectionAsDefaultAndReturnsSelf
- [ PASSED ] — MAKS\AmqpAgent\Tests\Worker\AbstractWorkerTest::testGetChannelReturnsTheDefaultChannel
- [ PASSED ] — MAKS\AmqpAgent\Tests\Worker\AbstractWorkerTest::testGetNewChannelReturnsANewChannelAndUsesOverrideParameters
- [ PASSED ] — MAKS\AmqpAgent\Tests\Worker\AbstractWorkerTest::testSetChannelSetsAnotherChannelAsDefaultAndReturnsSelf
- [ PASSED ] — MAKS\AmqpAgent\Tests\Worker\AbstractWorkerTest::testGetChannelByIdReturnsAChannelWithThatId
- [ PASSED ] — MAKS\AmqpAgent\Tests\Worker\AbstractWorkerTest::testGetChannelByIdReturnsNullForRandomChannelId
- [ PASSED ] — MAKS\AmqpAgent\Tests\Worker\AbstractWorkerTest::testWorkerShutdownFunction
- [ PASSED ] — MAKS\AmqpAgent\Tests\Worker\AbstractWorkerTest::testMutateClassMemberTakesEffectByRevertingPropertyToItsState
- [ PASSED ] — MAKS\AmqpAgent\Tests\Worker\PublisherTest::testQueueReturnsSelfAndOverrideParametersTakeEffect
- [ PASSED ] — MAKS\AmqpAgent\Tests\Worker\PublisherTest::testExchangeReturnsSelfAndOverrideParametersTakeEffect
- [ PASSED ] — MAKS\AmqpAgent\Tests\Worker\PublisherTest::testBindReturnsSelfAndOverrideParametersTakeEffect
- [ PASSED ] — MAKS\AmqpAgent\Tests\Worker\PublisherTest::testPublishRaisesAnExceptionIfUnexpectedParameterIsPassed
- [ PASSED ] — MAKS\AmqpAgent\Tests\Worker\PublisherTest::testPublishBatchAndPublishPublishesMessagesToRabbitMQServerAndOverrideParametersTakeEffect
- [ PASSED ] — MAKS\AmqpAgent\Tests\Worker\PublisherTest::testPublishBatchRaisesAnExceptionIfUnexpectedParameterIsPassed
- [ PASSED ] — MAKS\AmqpAgent\Tests\Worker\PublisherTest::testPublishPublishesMessagesToRabbitMQServerWithDifferentTypesOfMessages
- [ PASSED ] — MAKS\AmqpAgent\Tests\Worker\PublisherTest::testPublishingMessagesToRabbitMQServerViaWorkMethod
- [ PASSED ] — MAKS\AmqpAgent\Tests\Worker\PublisherTest::testWorkRaisesAnExceptionIfUnexpectedParameterIsPassed
- [ PASSED ] — MAKS\AmqpAgent\Tests\Worker\ConsumerTest::testQosReturnsSelfAndOverrideParametersTakeEffect
- [ PASSED ] — MAKS\AmqpAgent\Tests\Worker\ConsumerTest::testIsConsumingReturnsFalseWhenCalledOnAnIdleChannel
- [ PASSED ] — MAKS\AmqpAgent\Tests\Worker\ConsumerTest::testConsumeConsumesMessagesFromRabbitMQServerAndAknowledgesThem
- [ PASSED ] — MAKS\AmqpAgent\Tests\Worker\ConsumerTest::testConsumeRaisesAnExceptionIfInvalidCallbackIsPassed
- [ PASSED ] — MAKS\AmqpAgent\Tests\Worker\ConsumerTest::testWaitForAllWaitsForMultipleChannelAndReturnsSelf
- [ PASSED ] — MAKS\AmqpAgent\Tests\Worker\ConsumerTest::testConsumingMessagesFromRabbitMQServerViaWorkMethod
- [ PASSED ] — MAKS\AmqpAgent\Tests\Worker\ConsumerTest::testWorkRaisesAnExceptionIfUnexpectedParameterIsPassed
- [ PASSED ] — MAKS\AmqpAgent\Tests\Worker\ConsumerTest::testGetGetsAMessageFromRabbitMQServer
- [ PASSED ] — MAKS\AmqpAgent\Tests\Worker\ConsumerTest::testGetGetsMessagesFromRabbitMQServerAndUnaknowledgesThem
- [ PASSED ] — MAKS\AmqpAgent\Tests\Worker\ConsumerTest::testCancelCancelsAConsumerAndRedeiliversMessagesToRabbitMQServer
- [ PASSED ] — MAKS\AmqpAgent\Tests\Worker\ConsumerTest::testRecoverRedeliversAllUnaknowledgeMessagesToRabbitMQServer
- [ PASSED ] — MAKS\AmqpAgent\Tests\Worker\ConsumerTest::testRejectRejectsAMessageAndRedeiliversMessagesToRabbitMQServer
- [ PASSED ] — MAKS\AmqpAgent\Tests\Worker\ConsumerTest::testConsumingMessagesFromRabbitMQServerUsingConfigCallback
- [ PASSED ] — MAKS\AmqpAgent\Tests\Worker\PublisherSingletonTest::testSingletonInstanceGetPropertyViaPublicAccessNotation
- [ PASSED ] — MAKS\AmqpAgent\Tests\Worker\PublisherSingletonTest::testSingletonInstanceGetPropertyViaPublicAssignmentNotation
- [ PASSED ] — MAKS\AmqpAgent\Tests\Worker\PublisherSingletonTest::testSingletonInstanceWhenCallingStaticMethod