qpat
Message queue systems and patterns.
Load with: use qpat
Quick example
use qpat
result = qbscc("hello", 10)
prn(result)Functions
Functions
qbsaa()
Performs the operation.
qbscc(name, max_size)
Performs the operation. Takes name, max_size.
qbscn(queue, item)
Performs the operation. Takes queue, item.
qbscd(queue)
Performs the operation. Takes queue.
qbscp(queue)
Performs the operation. Takes queue.
qbscm(queue)
Performs the operation. Takes queue.
qbscl(queue)
Closes or clears. Takes queue.
qprea()
Performs the operation.
qprca(name, max_size, comparator)
Performs the operation. Takes name, max_size, comparator.
qpraa(queue, item, priority)
Performs the operation. Takes queue, item, priority.
qprrt(queue)
Performs the operation. Takes queue.
qprba(queue)
Performs the operation. Takes queue.
qcrga()
Performs the operation.
qcrea(name, capacity)
Performs the operation. Takes name, capacity.
qpqcr(queue, item)
Creates a new instance. Takes queue, item.
qcrcl(queue)
Closes or clears. Takes queue.
qpada(queue)
Performs the operation. Takes queue.
qpaca(queue)
Performs the operation. Takes queue.
qpaba(queue)
Performs the operation. Takes queue.
qdlea()
Performs the operation.
qdlca(name)
Performs the operation. Takes name.
qdlaa(queue, item, delay_ms)
Performs the operation. Takes queue, item, delay_ms.
qdlyd(queue)
Performs the operation. Takes queue.
qdlba(queue)
Performs the operation. Takes queue.
qblea()
Performs the operation.
qblda(name, max_size)
Performs the operation. Takes name, max_size.
qblca(blocking_queue, item, timeout)
Performs the operation. Takes blocking_queue, item, timeout.
qblba(blocking_queue, timeout)
Performs the operation. Takes blocking_queue, timeout.
qblck(blocking_queue)
Performs the operation. Takes blocking_queue.
qemsg()
Performs the operation.
qmsgc(name)
Performs the operation. Takes name.
qmsgt(message_queue, topic_name)
Performs the operation. Takes message_queue, topic_name.
qmsgp(message_queue, topic_name, message)
Performs the operation. Takes message_queue, topic_name, message.
qmsgs(message_queue, topic_name, subscriber_id, callback)
Performs the operation. Takes message_queue, topic_name, subscriber_id, callback.
qmsgn(message_queue, topic_name, subscriber_id)
Performs the operation. Takes message_queue, topic_name, subscriber_id.
qedlq()
Performs the operation.
qdlqc(name, max_size)
Performs the operation. Takes name, max_size.
qdlqd(dlq, message, error)
Performs the operation. Takes dlq, message, error.
qdlqr(dlq, index)
Performs the operation. Takes dlq, index.
qemgr()
Performs the operation.
qmgrc()
Performs the operation.
qmgaa(manager, name, queue)
Performs the operation. Takes manager, name, queue.
qmgrg(manager, name)
Performs the operation. Takes manager, name.
qmgrn(manager, queue_name, item, priority)
Performs the operation. Takes manager, queue_name, item, priority.
qmgrd(manager, queue_name)
Reads data. Takes manager, queue_name.
qmgrs(manager)
Resets. Takes manager.
qbsic(name, max_size)
Performs the operation. Takes name, max_size.
qprda(name, max_size, comparator)
Performs the operation. Takes name, max_size, comparator.
qcrfa(name, capacity)
Performs the operation. Takes name, capacity.
qdlda(name)
Performs the operation. Takes name.
qblaa(name, max_size)
Performs the operation. Takes name, max_size.
qmsca(name)
Performs the operation. Takes name.
qddlt(name, max_size)
Performs the operation. Takes name, max_size.
qmngr()
Performs the operation.
qnque(queue, item, priority)
Performs the operation. Takes queue, item, priority.
qdque(queue)
Performs the operation. Takes queue.
qpeek(queue)
Performs the operation. Takes queue.
qmpty(queue)
Performs the operation. Takes queue.
qelen(queue)
Encodes. Takes queue.
qmsba(message_queue, topic, message)
Performs the operation. Takes message_queue, topic, message.
qmsaa(message_queue, topic, subscriber_id, callback)
Performs the operation. Takes message_queue, topic, subscriber_id, callback.
qmssg(message_queue, topic, subscriber_id)
Performs the operation. Takes message_queue, topic, subscriber_id.
Notes
- Query pattern matching - SQL-like queries over in-memory data.