appserver-io/stomp-mq-adapter

Stomp message queue adapter

v0.9-beta 2015-03-24 18:05 UTC

Requires

• php: >=5.4.0
• appserver-io-psr/epb: ~1.0
• appserver-io-psr/mop: ~1.0
• appserver-io-psr/naming: ~1.0
• appserver-io-psr/pms: ~1.0
• appserver-io/lang: ~1.0
• appserver-io/messaging: ~1.0
• appserver-io/server: ~1.0
• psr/log: ~1.0

Requires (Dev)

• appserver-io/build: ~1.0

OSL-3.0

• Lars Roettig

• php
• server
• adapter
• stomp
• protocol

README

Can receive stomp messages and will send it to "Appserver.io message Queue".

Installation Mac

• Clone repository or Download the ZIP
• Add the followings lines to /opt/appserver/composer.json

    "repositories": [
        {
            "type":"vcs",
            "url":"/YOUR/PATH/stomp"
        }
    ],
    "require": {
    "appserver-io/stomp" : "dev-master"
    }

• Run the command "sudo bin/php bin/composer.phar update" in /opt/appserver
• Add the new server node to /opt/appserver/etc/appserver/appserver.xml

                <server
                        name="stomp"
                        type="\AppserverIo\Server\Servers\MultiThreadedServer"
                        worker="\AppserverIo\Server\Workers\ThreadWorker"
                        socket="\AppserverIo\Server\Sockets\StreamSocket"
                        requestContext="\AppserverIo\Server\Contexts\RequestContext"
                        serverContext="\AppserverIo\Server\Contexts\ServerContext"
                        loggerName="System">

                    <params>
                        <param name="admin" type="string">[e-mail]</param>
                        <param name="transport" type="string">tcp</param>
                        <param name="address" type="string">127.0.0.1</param>
                        <param name="port" type="integer">61613</param>
                        <param name="workerNumber" type="integer">64</param>
                        <param name="workerAcceptMin" type="integer">3</param>
                        <param name="workerAcceptMax" type="integer">8</param>
                        <param name="documentRoot" type="string">webapps</param>
                        <param name="directoryIndex" type="string">index.pc</param>
                        <param name="keepAliveMax" type="integer">64</param>
                        <param name="keepAliveTimeout" type="integer">5</param>
                        <param name="errorsPageTemplatePath" type="string">var/www/errors/error.phtml</param>
                    </params>

                    <environmentVariables>
                        <environmentVariable condition="" definition="LOGGER_ACCESS=Access" />
                    </environmentVariables>

                    <connectionHandlers>
                        <connectionHandler type="\AppserverIo\Stomp\StompConnectionHandler" />
                    </connectionHandlers>

                    <accesses>
                        <!-- per default allow everything -->
                        <access type="allow">
                            <params>
                                <param name="X_REQUEST_URI" type="string">.*</param>
                            </params>
                        </access>
                    </accesses>

                    <!-- include of virtual host configurations -->
                    <xi:include href="conf.d/virtual-hosts.xml"/>

                    <modules>
                        <!-- REQUEST_POST hook -->
                        <module type="\AppserverIo\WebServer\Modules\AuthenticationModule"/>
                        <module type="\AppserverIo\WebServer\Modules\VirtualHostModule"/>
                        <module type="\AppserverIo\WebServer\Modules\EnvironmentVariableModule" />
                        <module type="\AppserverIo\WebServer\Modules\RewriteModule"/>
                        <module type="\AppserverIo\WebServer\Modules\DirectoryModule"/>
                        <module type="\AppserverIo\WebServer\Modules\AccessModule"/>
                        <module type="\AppserverIo\WebServer\Modules\CoreModule"/>
                        <module type="\AppserverIo\Appserver\PersistenceContainer\PersistenceContainerModule" />
                        <!-- RESPONSE_PRE hook -->
                        <module type="\AppserverIo\WebServer\Modules\DeflateModule"/>
                        <!-- RESPONSE_POST hook -->
                        <module type="\AppserverIo\Appserver\Core\Modules\ProfileModule"/>
                    </modules>
                </server>

• Restart the Apserver

Development/Deployment

• run unit test => ant run-tests

TODO

• Better documentation
• Example(tutorial)