createQueue method

  1. @override
IMessageQueue createQueue(
  1. String name
)
override

Creates a message queue component and assigns its name.

  • name a name of the created message queue.

Implementation

@override
IMessageQueue createQueue(String name) {
  var queue = MemoryMessageQueue(name);

  if (config_ != null) {
    queue.configure(config_!);
  }
  if (references_ != null) {
    queue.setReferences(references_!);
  }

  return queue;
}