Package coilmq :: Package tests :: Module mock :: Class MockQueueManager
[frames] | no frames]

Class MockQueueManager

object --+
         |
        MockQueueManager

Instance Methods
 
__init__(self)
x.__init__(...) initializes x; see help(type(x)) for signature
 
reset(self)
 
subscribe(self, conn, dest)
 
unsubscribe(self, conn, dest)
 
send(self, message)
 
ack(self, connection, frame, transaction=None)
 
resend_transaction_frames(self, connection, transaction)
Resend the messages that were ACK'd in specified transaction.
 
clear_transaction_frames(self, connection, transaction)
Clears out the queued ACK frames for specified transaction.

Inherited from object: __delattr__, __format__, __getattribute__, __hash__, __new__, __reduce__, __reduce_ex__, __repr__, __setattr__, __sizeof__, __str__, __subclasshook__

Properties

Inherited from object: __class__

Method Details

__init__(self)
(Constructor)

 

x.__init__(...) initializes x; see help(type(x)) for signature

Overrides: object.__init__
(inherited documentation)

resend_transaction_frames(self, connection, transaction)

 

Resend the messages that were ACK'd in specified transaction.

Parameters:
  • connection (coilmq.server.StompConnection) - The client connection that aborted the transaction.
  • transaction (str) - The transaction id (which was aborted).

clear_transaction_frames(self, connection, transaction)

 

Clears out the queued ACK frames for specified transaction.

Parameters:
  • connection (coilmq.server.StompConnection) - The client connection that committed the transaction.
  • transaction (str) - The transaction id (which was committed).