NAME

XAS::Collector::Connector - Perl extension for the XAS environment

SYNOPSIS

use XAS::Collector::Connector;

my $types = [
   { 'xas-alert', 'alert' },
];

my $queues = [
    '/queue/alert',
];

XAS::Collector::Connector->spawn(
    RemoteAddress => $host,
    RemotePort    => $port,
    Alias         => 'collector',
    Logger        => 'logger',
    Login         => 'collector',
    Passcode      => 'ddc',
    Queues        => $queues,
    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

spawn

The module uses the configuration items from POE::Component::Client::Stomp along with this additional items.

Queues

The queues that the connector will subscribe too. This can be a string or an array of strings.

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_connected($kernel, $self, $frame)

Subscribe to the appropriate queue(s) after authentication.

$kernel

A handle to the POE kernel

$self

A handle to the current object.

$frame

The received STOMP frame.

handle_message($kernel, $self, $frame)

Decode the packet type and pass it off to the appropriate message handler.

$kernel

A handle to the POE kernel

$self

A handle to the current object.

$frame

The received STOMP frame.

SEE ALSO

POE::Component::Client::Stomp

XAS::Base
XAS::Class
XAS::Constants
XAS::Exception
XAS::System
XAS::Utils

XAS::Apps::Base::Alerts
XAS::Apps::Base::Collector
XAS::Apps::Base::ExtractData
XAS::Apps::Base::ExtractGlobals
XAS::Apps::Base::RemoveData
XAS::Apps::Database::Schema
XAS::Apps::Templates::Daemon
XAS::Apps::Templates::Generic
XAS::Apps::Test::Echo::Client
XAS::Apps::Test::Echo::Server
XAS::Apps::Test::RPC::Client
XAS::Apps::Test::RPC::Methods
XAS::Apps::Test::RPC::Server

XAS::Collector::Alert
XAS::Collector::Base
XAS::Collector::Connector
XAS::Collector::Factory

XAS::Lib::App
XAS::Lib::App::Daemon
XAS::Lib::App::Daemon::POE
XAS::Lib::Connector
XAS::Lib::Counter
XAS::Lib::Daemon::Logger
XAS::Lib::Daemon::Logging
XAS::Lib::Gearman::Admin
XAS::Lib::Gearman::Admin::Status
XAS::Lib::Gearman::Admin::Worker
XAS::Lib::Gearman::Client
XAS::Lib::Gearman::Client::Status
XAS::Lib::Gearman::Worker
XAS::Lib::Net::Client
XAS::LIb::Net::Server
XAS::Lib::RPC::JSON::Client
XAS::Lib::RPC::JSON::Server
XAS::Lib::Session
XAS::Lib::Spool

XAS::Model::Database
XAS::Model::Database::Alert
XAS::Model::Database::Counter
XAS::Model::DBM

XAS::Monitor::Base
XAS::Monitor::Database
XAS::Monitor::Database::Alert

XAS::Scheduler::Base

XAS::System::Alert
XAS::System::Email
XAS::System::Environment
XAS::System::Logger

AUTHOR

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

COPYRIGHT AND LICENSE

Copyright (C) 2012 by Kevin L. Esteb

This library is free software; you can redistribute it and/or modify it under the same terms as Perl itself, either Perl version 5.8.8 or, at your option, any later version of Perl 5 you may have available.