Index

A

abandon() (pip_services3_messaging.queues.IMessageQueue method) (pip_services3_messaging.queues.IMessageQueue.IMessageQueue method) (pip_services3_messaging.queues.MemoryMessageQueue method) (pip_services3_messaging.queues.MemoryMessageQueue.MemoryMessageQueue method) (pip_services3_messaging.queues.MessageQueue method) (pip_services3_messaging.queues.MessageQueue.MessageQueue method)

B

begin_listen() (pip_services3_messaging.queues.IMessageQueue method) (pip_services3_messaging.queues.IMessageQueue.IMessageQueue method) (pip_services3_messaging.queues.MessageQueue method) (pip_services3_messaging.queues.MessageQueue.MessageQueue method)

C

CachedMessageQueue (class in pip_services3_messaging.queues.CachedMessageQueue) CallbackMessageReceiver (class in pip_services3_messaging.queues.CallbackMessageReceiver) can_abandon() (pip_services3_messaging.queues.MessagingCapabilities method) (pip_services3_messaging.queues.MessagingCapabilities.MessagingCapabilities method) can_clear() (pip_services3_messaging.queues.MessagingCapabilities method) (pip_services3_messaging.queues.MessagingCapabilities.MessagingCapabilities method) can_dead_letter() (pip_services3_messaging.queues.MessagingCapabilities method) (pip_services3_messaging.queues.MessagingCapabilities.MessagingCapabilities method) can_message_count() (pip_services3_messaging.queues.MessagingCapabilities method) (pip_services3_messaging.queues.MessagingCapabilities.MessagingCapabilities method) can_peek() (pip_services3_messaging.queues.MessagingCapabilities method) (pip_services3_messaging.queues.MessagingCapabilities.MessagingCapabilities method) can_peek_batch() (pip_services3_messaging.queues.MessagingCapabilities method) (pip_services3_messaging.queues.MessagingCapabilities.MessagingCapabilities method) can_receive() (pip_services3_messaging.queues.MessagingCapabilities method) (pip_services3_messaging.queues.MessagingCapabilities.MessagingCapabilities method) can_renew_lock() (pip_services3_messaging.queues.MessagingCapabilities method) (pip_services3_messaging.queues.MessagingCapabilities.MessagingCapabilities method) can_send() (pip_services3_messaging.queues.MessagingCapabilities method) (pip_services3_messaging.queues.MessagingCapabilities.MessagingCapabilities method) clear() (pip_services3_messaging.queues.CachedMessageQueue.CachedMessageQueue method) (pip_services3_messaging.queues.MemoryMessageQueue method) (pip_services3_messaging.queues.MemoryMessageQueue.MemoryMessageQueue method) (pip_services3_messaging.queues.MessageQueue method) (pip_services3_messaging.queues.MessageQueue.MessageQueue method) (pip_services3_messaging.test.TestMessageReceiver.TestMessageReceiver method)

close() (pip_services3_messaging.queues.CachedMessageQueue.CachedMessageQueue method) (pip_services3_messaging.queues.MemoryMessageQueue method) (pip_services3_messaging.queues.MemoryMessageQueue.MemoryMessageQueue method) (pip_services3_messaging.queues.MessageQueue method) (pip_services3_messaging.queues.MessageQueue.MessageQueue method) complete() (pip_services3_messaging.queues.IMessageQueue method) (pip_services3_messaging.queues.IMessageQueue.IMessageQueue method) (pip_services3_messaging.queues.MemoryMessageQueue method) (pip_services3_messaging.queues.MemoryMessageQueue.MemoryMessageQueue method) (pip_services3_messaging.queues.MessageQueue method) (pip_services3_messaging.queues.MessageQueue.MessageQueue method) configure() (pip_services3_messaging.build.MessageQueueFactory.MessageQueueFactory method) (pip_services3_messaging.queues.CachedMessageQueue.CachedMessageQueue method) (pip_services3_messaging.queues.MemoryMessageQueue method) (pip_services3_messaging.queues.MemoryMessageQueue.MemoryMessageQueue method) (pip_services3_messaging.queues.MessageQueue method) (pip_services3_messaging.queues.MessageQueue.MessageQueue method) create_queue() (pip_services3_messaging.build.IMessageQueueFactory.IMessageQueueFactory method) (pip_services3_messaging.build.MemoryMessageQueueFactory method) (pip_services3_messaging.build.MemoryMessageQueueFactory.MemoryMessageQueueFactory method) (pip_services3_messaging.build.MessageQueueFactory.MessageQueueFactory method) (pip_services3_messaging.connect.IMessageQueueConnection.IMessageQueueConnection method)

D

DefaultMessagingFactory (class in pip_services3_messaging.build) (class in pip_services3_messaging.build.DefaultMessagingFactory)

delete_queue() (pip_services3_messaging.connect.IMessageQueueConnection.IMessageQueueConnection method)

E

end_listen() (pip_services3_messaging.queues.CachedMessageQueue.CachedMessageQueue method) (pip_services3_messaging.queues.IMessageQueue method) (pip_services3_messaging.queues.IMessageQueue.IMessageQueue method) (pip_services3_messaging.queues.MemoryMessageQueue method) (pip_services3_messaging.queues.MemoryMessageQueue.MemoryMessageQueue method) (pip_services3_messaging.queues.MessageQueue method) (pip_services3_messaging.queues.MessageQueue.MessageQueue method)

F

from_json() (pip_services3_messaging.queues.MessageEnvelope static method) (pip_services3_messaging.queues.MessageEnvelope.MessageEnvelope static method)

G

get_capabilities() (pip_services3_messaging.queues.IMessageQueue method) (pip_services3_messaging.queues.IMessageQueue.IMessageQueue method) (pip_services3_messaging.queues.MessageQueue method) (pip_services3_messaging.queues.MessageQueue.MessageQueue method) get_message_as() (pip_services3_messaging.queues.MessageEnvelope method) (pip_services3_messaging.queues.MessageEnvelope.MessageEnvelope method) get_message_as_string() (pip_services3_messaging.queues.MessageEnvelope method) (pip_services3_messaging.queues.MessageEnvelope.MessageEnvelope method)

get_name() (pip_services3_messaging.queues.IMessageQueue method) (pip_services3_messaging.queues.IMessageQueue.IMessageQueue method) (pip_services3_messaging.queues.MessageQueue method) (pip_services3_messaging.queues.MessageQueue.MessageQueue method) get_reference() (pip_services3_messaging.queues.MessageEnvelope method) (pip_services3_messaging.queues.MessageEnvelope.MessageEnvelope method)

I

IMessageQueue (class in pip_services3_messaging.queues) (class in pip_services3_messaging.queues.IMessageQueue) IMessageQueueConnection (class in pip_services3_messaging.connect.IMessageQueueConnection) IMessageQueueFactory (class in pip_services3_messaging.build.IMessageQueueFactory) IMessageReceiver (class in pip_services3_messaging.queues) (class in pip_services3_messaging.queues.IMessageReceiver)

is_open() (pip_services3_messaging.queues.MemoryMessageQueue method) (pip_services3_messaging.queues.MemoryMessageQueue.MemoryMessageQueue method) (pip_services3_messaging.queues.MessageQueue method) (pip_services3_messaging.queues.MessageQueue.MessageQueue method)

L

listen() (pip_services3_messaging.queues.CachedMessageQueue.CachedMessageQueue method) (pip_services3_messaging.queues.IMessageQueue method) (pip_services3_messaging.queues.IMessageQueue.IMessageQueue method) (pip_services3_messaging.queues.MemoryMessageQueue method) (pip_services3_messaging.queues.MemoryMessageQueue.MemoryMessageQueue method) (pip_services3_messaging.queues.MessageQueue method) (pip_services3_messaging.queues.MessageQueue.MessageQueue method)

LockedMessage (class in pip_services3_messaging.queues.LockedMessage)

M

MemoryMessageQueue (class in pip_services3_messaging.queues) (class in pip_services3_messaging.queues.MemoryMessageQueue) MemoryMessageQueueDescriptor (pip_services3_messaging.build.DefaultMessagingFactory attribute) (pip_services3_messaging.build.DefaultMessagingFactory.DefaultMessagingFactory attribute) MemoryMessageQueueFactory (class in pip_services3_messaging.build) (class in pip_services3_messaging.build.MemoryMessageQueueFactory) MemoryMessageQueueFactoryDescriptor (pip_services3_messaging.build.DefaultMessagingFactory attribute) (pip_services3_messaging.build.DefaultMessagingFactory.DefaultMessagingFactory attribute) MemoryQueueDescriptor (pip_services3_messaging.build.MemoryMessageQueueFactory attribute) (pip_services3_messaging.build.MemoryMessageQueueFactory.MemoryMessageQueueFactory attribute) message_count() (pip_services3_messaging.test.TestMessageReceiver.TestMessageReceiver property) MessageEnvelope (class in pip_services3_messaging.queues) (class in pip_services3_messaging.queues.MessageEnvelope) MessageQueue (class in pip_services3_messaging.queues) (class in pip_services3_messaging.queues.MessageQueue) MessageQueueFactory (class in pip_services3_messaging.build.MessageQueueFactory) messages() (pip_services3_messaging.test.TestMessageReceiver.TestMessageReceiver property) MessagingCapabilities (class in pip_services3_messaging.queues) (class in pip_services3_messaging.queues.MessagingCapabilities) module pip_services3_messaging, [1] pip_services3_messaging.build pip_services3_messaging.build.DefaultMessagingFactory pip_services3_messaging.build.IMessageQueueFactory pip_services3_messaging.build.MemoryMessageQueueFactory pip_services3_messaging.build.MessageQueueFactory pip_services3_messaging.connect pip_services3_messaging.connect.IMessageQueueConnection pip_services3_messaging.queues pip_services3_messaging.queues.CachedMessageQueue pip_services3_messaging.queues.CallbackMessageReceiver pip_services3_messaging.queues.IMessageQueue pip_services3_messaging.queues.IMessageReceiver pip_services3_messaging.queues.LockedMessage pip_services3_messaging.queues.MemoryMessageQueue pip_services3_messaging.queues.MessageEnvelope pip_services3_messaging.queues.MessageQueue pip_services3_messaging.queues.MessagingCapabilities pip_services3_messaging.test pip_services3_messaging.test.TestMessageReceiver

move_to_dead_letter() (pip_services3_messaging.queues.IMessageQueue method) (pip_services3_messaging.queues.IMessageQueue.IMessageQueue method) (pip_services3_messaging.queues.MemoryMessageQueue method) (pip_services3_messaging.queues.MemoryMessageQueue.MemoryMessageQueue method) (pip_services3_messaging.queues.MessageQueue method) (pip_services3_messaging.queues.MessageQueue.MessageQueue method)

O

open() (pip_services3_messaging.queues.CachedMessageQueue.CachedMessageQueue method) (pip_services3_messaging.queues.MessageQueue method) (pip_services3_messaging.queues.MessageQueue.MessageQueue method)

P

peek() (pip_services3_messaging.queues.CachedMessageQueue.CachedMessageQueue method) (pip_services3_messaging.queues.IMessageQueue method) (pip_services3_messaging.queues.IMessageQueue.IMessageQueue method) (pip_services3_messaging.queues.MemoryMessageQueue method) (pip_services3_messaging.queues.MemoryMessageQueue.MemoryMessageQueue method) (pip_services3_messaging.queues.MessageQueue method) (pip_services3_messaging.queues.MessageQueue.MessageQueue method) peek_batch() (pip_services3_messaging.queues.CachedMessageQueue.CachedMessageQueue method) (pip_services3_messaging.queues.IMessageQueue method) (pip_services3_messaging.queues.IMessageQueue.IMessageQueue method) (pip_services3_messaging.queues.MemoryMessageQueue method) (pip_services3_messaging.queues.MemoryMessageQueue.MemoryMessageQueue method) (pip_services3_messaging.queues.MessageQueue method) (pip_services3_messaging.queues.MessageQueue.MessageQueue method) pip_services3_messaging module, [1] pip_services3_messaging.build module pip_services3_messaging.build.DefaultMessagingFactory module pip_services3_messaging.build.IMessageQueueFactory module pip_services3_messaging.build.MemoryMessageQueueFactory module pip_services3_messaging.build.MessageQueueFactory module pip_services3_messaging.connect module

pip_services3_messaging.connect.IMessageQueueConnection module pip_services3_messaging.queues module pip_services3_messaging.queues.CachedMessageQueue module pip_services3_messaging.queues.CallbackMessageReceiver module pip_services3_messaging.queues.IMessageQueue module pip_services3_messaging.queues.IMessageReceiver module pip_services3_messaging.queues.LockedMessage module pip_services3_messaging.queues.MemoryMessageQueue module pip_services3_messaging.queues.MessageEnvelope module pip_services3_messaging.queues.MessageQueue module pip_services3_messaging.queues.MessagingCapabilities module pip_services3_messaging.test module pip_services3_messaging.test.TestMessageReceiver module

R

read_message_count() (pip_services3_messaging.queues.CachedMessageQueue.CachedMessageQueue method) (pip_services3_messaging.queues.IMessageQueue method) (pip_services3_messaging.queues.IMessageQueue.IMessageQueue method) (pip_services3_messaging.queues.MemoryMessageQueue method) (pip_services3_messaging.queues.MemoryMessageQueue.MemoryMessageQueue method) (pip_services3_messaging.queues.MessageQueue method) (pip_services3_messaging.queues.MessageQueue.MessageQueue method) read_queue_names() (pip_services3_messaging.connect.IMessageQueueConnection.IMessageQueueConnection method) receive() (pip_services3_messaging.queues.CachedMessageQueue.CachedMessageQueue method) (pip_services3_messaging.queues.IMessageQueue method) (pip_services3_messaging.queues.IMessageQueue.IMessageQueue method) (pip_services3_messaging.queues.MemoryMessageQueue method) (pip_services3_messaging.queues.MemoryMessageQueue.MemoryMessageQueue method) (pip_services3_messaging.queues.MessageQueue method) (pip_services3_messaging.queues.MessageQueue.MessageQueue method)

receive_message() (pip_services3_messaging.queues.CallbackMessageReceiver.CallbackMessageReceiver method) (pip_services3_messaging.queues.IMessageReceiver method) (pip_services3_messaging.queues.IMessageReceiver.IMessageReceiver method) (pip_services3_messaging.test.TestMessageReceiver.TestMessageReceiver method) renew_lock() (pip_services3_messaging.queues.IMessageQueue method) (pip_services3_messaging.queues.IMessageQueue.IMessageQueue method) (pip_services3_messaging.queues.MemoryMessageQueue method) (pip_services3_messaging.queues.MemoryMessageQueue.MemoryMessageQueue method) (pip_services3_messaging.queues.MessageQueue method) (pip_services3_messaging.queues.MessageQueue.MessageQueue method)

S

send() (pip_services3_messaging.queues.IMessageQueue method) (pip_services3_messaging.queues.IMessageQueue.IMessageQueue method) (pip_services3_messaging.queues.MemoryMessageQueue method) (pip_services3_messaging.queues.MemoryMessageQueue.MemoryMessageQueue method) (pip_services3_messaging.queues.MessageQueue method) (pip_services3_messaging.queues.MessageQueue.MessageQueue method) send_as_object() (pip_services3_messaging.queues.IMessageQueue method) (pip_services3_messaging.queues.IMessageQueue.IMessageQueue method) (pip_services3_messaging.queues.MessageQueue method) (pip_services3_messaging.queues.MessageQueue.MessageQueue method)

set_message_as_object() (pip_services3_messaging.queues.MessageEnvelope method) (pip_services3_messaging.queues.MessageEnvelope.MessageEnvelope method) set_message_as_string() (pip_services3_messaging.queues.MessageEnvelope method) (pip_services3_messaging.queues.MessageEnvelope.MessageEnvelope method) set_reference() (pip_services3_messaging.queues.MessageEnvelope method) (pip_services3_messaging.queues.MessageEnvelope.MessageEnvelope method) set_references() (pip_services3_messaging.build.MessageQueueFactory.MessageQueueFactory method) (pip_services3_messaging.queues.MessageQueue method) (pip_services3_messaging.queues.MessageQueue.MessageQueue method)

T

TestMessageReceiver (class in pip_services3_messaging.test.TestMessageReceiver) to_json() (pip_services3_messaging.queues.MessageEnvelope method) (pip_services3_messaging.queues.MessageEnvelope.MessageEnvelope method)

to_string() (pip_services3_messaging.queues.MessageEnvelope method) (pip_services3_messaging.queues.MessageEnvelope.MessageEnvelope method) (pip_services3_messaging.queues.MessageQueue method) (pip_services3_messaging.queues.MessageQueue.MessageQueue method)