\SimpleInterSSMQ
Synopsis
class SimpleInterSSMQ
implements
MessageQueueImplementation
{
- // members
- protected $conf = NULL;
- protected $remoteServer = NULL;
- // methods
- public void __construct()
- public void send()
- public void encode()
- public void decode()
- protected void init()
- public <type> receive()
- public void processRawMessage()
Hierarchy
Implements
Tasks
Line | Task |
---|---|
100+ | : This really needs to use transactions to ensure that only one reader will get each message. Might need to implement a lock or something for MySQL MyISAM :-( |
Members
protected
- $conf
- $remoteServer
Methods
protected
- init() — Set up for interacting with Stomp, icnluding creating the connection. Configuration info is taken from the interface configuration.
public
- __construct()
- decode() — Convert raw message into an array with "queue" and "msgframe" properties.
- encode()
- processRawMessage() — Given a message received by a remote system, unencode the message and deliver it.
- receive()
- send() — Sends a message. Encodes the message frame and sends it using CURL.