\StompMQ
Message queueing implementation class that uses Stomp to exchange messages with an external message system.
NOTE: THIS IS NOT COMPLETE OR TESTED IN ANY WAY, SO DON'T USE IT!
Requires Stomp.php library.
- Author: Mark Stephens <mark@silverstripe.com>
Synopsis
class StompMQ
implements
MessageQueueImplementation
{
- // members
- public static $conn = NULL;
- // methods
- public void __construct()
- protected void init()
- public void send()
- public DataObjectSet receive()
Hierarchy
Implements
Tasks
Line | Task |
---|---|
18+ | : * include stomp redistributables if legal. * complete the implementation and test it against ApacheMQ |
49 | handle authentication and any other connection properties |
69+ | Handle exceptions, and possibly using stomp transactions. If an exception occurs while receiving multiple messages, we need to ensure that the messages successfully retrieved are returned, because the server thinks these are done. |
Members
public
- $conn
Methods
protected
- init() — Set up for interacting with Stomp, icnluding creating the connection. Configuration info is taken from the interface configuration.
public
- __construct()
- receive() — Get a bunch of messages via Stomp.
- send()