NAME
XAS::Collector::Connector - Perl extension for the XAS environment
SYNOPSIS
use XAS::Collector::Connector;
my $types = [
{ 'xas-alert', 'alert' },
];
my $connector = XAS::Collector::Connector->new(
-host => $host,
-port => $port,
-alias => 'connector',
-login => 'collector',
-passcode => 'ddc',
-types => $types
);DESCRIPTION
This module is used for monitoring queues on the message server. When messages are received, they are then passed off to the appropriate message handler.
METHODS
new
The module inherits from XAS::Lib::Stomp::POE::Client and adds these additional parameters:
- -types
-
This is a list of XAS packet types that this connector can handle. The list consists of hashes with the following values: XAS packet type, name of the session handler for that packet type.
PUBLIC EVENTS
handle_message(OBJECT, ARG0)
Decode the packet type and pass it off to the appropriate message handler.
- OBJECT
-
A handle to the current object.
- ARG0
-
The received STOMP frame.
connection_down(OBJECT)
Mark the connection to message queue server as down.
- OBJECT
-
A handle to the current object.
connection_up(OBJECT)
Mark the connection to message queue server as up.
- OBJECT
-
A handle to the current object.
stop_queue(OBJECT, ARG0)
Stop processing the specified queue.
- OBJECT
-
A handle to the current object.
- ARG0
-
A hash reference, where the memeber '-queue' contains the name of the queue to stop procesing.
start_queue(OBJECT, ARG0)
Start processing the specified queue.
- OBJECT
-
A handle to the current object.
- ARG0
-
A hash reference, where the memeber '-queue' contains the name of the queue to start procesing.
SEE ALSO
AUTHOR
Kevin L. Esteb, <kevin@kesteb.us>
COPYRIGHT AND LICENSE
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.