NAME

XAS::Collector::Input::Stomp - A class for the XAS environment

SYNOPSIS

use XAS::Collector::Input::Stomp;

my $types => {
    'xas-alerts' => {
        queue  => '/queue/alerts',
        format => 'format-alerts',
        input  => 'input-stomp',
        output => 'output-logstash',
    },
};

my $processor = XAS::Collector::Input::Stomp->new(
    -alias => 'input-stomp',
    -types => $types
);

DESCRIPTION

This module will monitor a queue on a STOMP based message queue server. It will attempt to maintain a connection to the server.

METHODS

new

This method will initialize the module and takes these parameters:

-types

The message types that this input module can handle.

-prefetch

The number of messages to prefetch from the queue. Default is unlimitied. This may have meaning only on a RabbitMQ server.

PUBLIC EVENTS

This module declares the following events:

pause_processing

This event is broadcasted when the connection to the message queue server is down. It's purpose is to stop processing messages on a queue.

resume_processing

This event is broadcasted when the connection to the message queue server is down. It's purpose is to start processing messages on a queue.

SEE ALSO

XAS::Collector

XAS

AUTHOR

Kevin L. Esteb, <kevin@kesteb.us>

COPYRIGHT AND LICENSE

Copyright (c) 2012-2015 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.