XAS::Lib::Stomp::Utils - STOMP protocol utilities for clients
This module uses XAS::Lib::Stomp::Frame to create STOMP frames.
use XAS::Lib::Stomp::Utils; my $stomp = XAS::Lib::Stomp::Utils->new(); my $frame = $stomp->connect( -login => 'test', -passcode => 'test' ); put($frame->to_string);
This module is an easy way to create STOMP frames without worrying about the various differences between the protocol versions.
This method initializes the base object. It takes the following parameters:
This method creates a "CONNECT" frame. This frame is used to initiate a session with a STOMP server. On STOMP v1.1 and later targets the following headers are automatically set:
host heart-beat accept-version
Unless otherwise specified, they will be the defaults. This method takes the following parameters:
An optional login name to be used on the STOMP server.
An optional password for the login name on the STOMP server.
An optional virtual host name to connect to on STOMP v1.1 and later servers. Defaults to 'localhost'.
An optional heart beat request for STOMP v1.1 and later servers. The default is to turn them off.
An optional list of protocol versions that are acceptable to this client for STOMP v1.1 and later clients. The default is '1.0,1.1,1.2'.
This sets the optional header 'prefetch-size' for RabbitMQ or other servers that support this extension.
This method creates a "STOMP" frame, this works the same as connect(), but only works for STOMP v1.1 and later targets. Please see the documentation for connect().
This method creates a "DISCONNECT" frame. This frame is used to signal the server that you no longer wish to communicate with it. This method takes the following parameters:
An optional receipt that will be returned by the server.
This method create a "SUBSCRIBE" frame. This frame is used to notify the server which queues you want to listen too. The naming of queues is left up to the server implementation. This method takes the following parameters:
The name of the queue you wish to subscribe too. Naming convention is server dependent.
A mandatory subscription id for usage on STOMP v1.1 and later targets. It has no meaning for STOMP v1.0 servers.
The type of acknowledgement you would like to receive when messages are sent to a queue. It defaults to 'auto'. It understands 'auto', 'client' and 'client-individual'. Please refer to the STOMP protocol reference for what this means.
This method creates an "UNSUBSCRIBE" frame. This frame is used to notify the server that you don't want to subscribe to a queue anymore. Subsequently any messages left on that queue will no longer be sent to your client.
The optional name of the queue that you subscribed too. STOMP v1.0 targets need a queue name and/or a subscription id to unsubscribe. This is optional on v1.1 and later targets.
The id of the subscription, this should be the same as the one used with subscribe(). This is optional on STOMP v1.0 servers and mandatory on v1.1 and later targets.
This method creates a "BEGIN" frame. This frame signals the server that a transaction is beginning. A transaction is either ended by a "COMMIT" frame or an "ABORT" frame. Any other frame that is sent must have a transaction id associated with them. This method takes the following parameters:
The mandatory id for the transaction.
This method creates a "COMMIT" frame. This frame signals the end of a transaction. This method takes the following parameters:
The mandatory transaction id from begin().
This method creates an "ABORT" frame. This frame is used to signal the server that the current transaction is to be aborted.
This method takes the following parameters:
This method creates a "SEND" frame. This frame is the basis of communication over your queues to the server. This method takes the following parameters:
The name of the queue to send the message too.
The message to be sent. No attempt is made to serializes the message.
An optional transaction number. This should be the same as for begin().
An optional length for the message. If one is not specified a 'content-length' header will be auto generated.
An optional MIME type for the message. If one is not specified, 'text/plain' will be used. This only has meaning for STOMP v1.1 and later targets.
An optional header for indicating that this frame should be 'persisted' by the server. What this means, is highly server specific.
This method creates an "ACK" frame. This frame is used to tell the server that the message was successfully received. This method takes the following parameters:
The id of the message that is being acked.
This should match the id from the subscribe() method. This has meaning for STOMP v1.1 and later targets.
The transaction id if this ack is part of a transaction.
This method creates a "NACK" frame. It notifies the server that the message was rejected. It has meaning on STOMP v1.1 and later targets. This method takes the following parameters:
The id of the message that is being nacked.
The transaction id if this nack is part of a transaction.
This method creates a "NOOP" frame. It has meaning on STOMP v1.1 and later targets.
For more information on the STOMP protocol, please refer to: http://stomp.github.io/ .
Kevin L. Esteb, <kevin@kesteb.us>
Copyright (C) 2014 Kevin L. Esteb
This is free software; you can redistribute it and/or modify it under the terms of the Artistic License 2.0. For details, see the full text of the license at http://www.perlfoundation.org/artistic_license_2_0.
To install XAS, copy and paste the appropriate command in to your terminal.
cpanm
cpanm XAS
CPAN shell
perl -MCPAN -e shell install XAS
For more information on module installation, please visit the detailed CPAN module installation guide.