manager-addSubscriber-005.phpt
No OneTemporary
Actions

Authored By

Unknown

Size

1 KB

Referenced Files

None

Subscribers

None

manager-addSubscriber-005.phpt
View Options

	--TEST--
	MongoDB\Driver\Manager::addSubscriber() subscriber is only notified once (Manager and global)
	--SKIPIF--
	<?php require __DIR__ . '/../utils/basic-skipif.inc'; ?>
	<?php skip_if_not_live(); ?>
	<?php skip_if_not_clean(); ?>
	--FILE--
	<?php

	require_once __DIR__ . '/../utils/basic.inc';

	class MySubscriber implements MongoDB\Driver\Monitoring\CommandSubscriber
	{
	public function commandStarted(MongoDB\Driver\Monitoring\CommandStartedEvent $event): void
	{
	printf("commandStarted: %s\n", $event->getCommandName());
	}

	public function commandSucceeded(MongoDB\Driver\Monitoring\CommandSucceededEvent $event): void
	{
	printf("commandSucceeded: %s\n", $event->getCommandName());
	}

	public function commandFailed(MongoDB\Driver\Monitoring\CommandFailedEvent $event): void
	{
	printf("commandFailed: %s\n", $event->getCommandName());
	}
	}

	$m = create_test_manager();

	$pingCommand = new MongoDB\Driver\Command(['ping' => 1]);

	$subscriber = new MySubscriber;

	MongoDB\Driver\Monitoring\addSubscriber($subscriber);
	$m->addSubscriber($subscriber);

	printf("ping: %d\n", $m->executeCommand(DATABASE_NAME, $pingCommand)->toArray()[0]->ok);

	// Global subscriber is still notified after Manager subscriber is unregistered
	$m->removeSubscriber($subscriber);

	printf("ping: %d\n", $m->executeCommand(DATABASE_NAME, $pingCommand)->toArray()[0]->ok);

	?>
	--EXPECT--
	commandStarted: ping
	commandSucceeded: ping
	ping: 1
	commandStarted: ping
	commandSucceeded: ping
	ping: 1