registerDriver method

@override void registerDriver(String name, QueueDriver driver)

Registers a queue driver with the given name. Throws QueueException if the driver name is empty or already registered.

Implementation

@override
void registerDriver(String name, QueueDriver driver) {
  if (name.isEmpty) {
    throw QueueException('Driver name cannot be empty');
  }
  if (_drivers.containsKey(name)) {
    throw QueueException('Driver "$name" is already registered');
  }
  _drivers[name] = driver;

  // Set as default if it's the first driver
  if (_defaultDriverName == null) {
    _defaultDriverName = name;
  }
}