IMessageQueueFactory
- class carb.eventdispatcher.IMessageQueueFactory
Bases:
pybind11_object
Methods
__init__
(*args, **kwargs)create_message_queue
(self, name, **kwargs)Creates a message queue with the given name and parameters, or returns an existing message queue with the given name.
get_message_queue
(self, name)Retrieves a message queue with the given name.
- __init__(*args, **kwargs)
- create_message_queue(self: carb.eventdispatcher._eventdispatcher.IMessageQueueFactory, name: str, **kwargs) Tuple[carb.eventdispatcher._eventdispatcher.IMessageQueue, bool]
Creates a message queue with the given name and parameters, or returns an existing message queue with the given name.
- Parameters
name – (str) The unique name of the message queue. If the name already exists, the message queue will not be created but the previously-created message queue will be returned (params will be ignored). Since names must be unique, a scheme such as reverse-DNS is recommended.
- Keyword Arguments
owning_thread – (int, default: 0) The thread that owns the message queue. If zero, the message queue can be popped by multiple threads. If a specific thread owns the message queue then an error will occur if any other thread attempts to pop the message queue, and the message queue will be optimized for the owning thread. Message queues that are created from a task (carb::tasking::ITasking) or thread pool should use zero here instead of using the calling thread. NOTE: This value should be via threading.get_native_id(), NOT threading.get_ident().
- Returns
Tuple of (IMessageQueue, bool) where the IMessageQueue is the message queue and the bool is whether it was created by this call (True), or an existing message queue was found and returned (False).
- Raises
MemoryError – failed to allocate the message queue
RuntimeError – an invalid argument was passed
- get_message_queue(self: carb.eventdispatcher._eventdispatcher.IMessageQueueFactory, name: str) carb.eventdispatcher._eventdispatcher.IMessageQueue
Retrieves a message queue with the given name.
- Parameters
name – (str) The unique name of a previously-created message queue.
- Returns
A message queue found by name.