Spread::Message Spread::Message is a Perl module created to provide messaging using the Spread toolkit.
Download

Spread::Message Ranking & Summary

Spread::Message Tags

messaging Toolkit Perl module spread Spread toolkit Spread messaging

Spread::Message Description

Spread::Message is a Perl module created to provide messaging using the Spread toolkit. Spread::Message is a Perl module created to provide messaging using the Spread toolkit.SYNOPSIS use Spread::Message; my $mbox = Message->new( spread_name => '4803@host', name => "down$$", group => , #debug => 1, member_sub => &process_control, message_sub => &process_data, timeout_sub => &heartbeat, ); sub process_control { my $mbox = shift; my $loop = shift; # Process membership messages here. See examples } sub process_data { my $mbox = shift; my $loop = shift; # Process the data here. See examples } sub heartbeat { my $mbox = shift; my $loop = shift; # Process any timeouts here. See examples } while(1) { # Process different data as required $mbox->rx(10,$loop); $loop++; # Extra processing of side effects created by the callbacks } $mbox->disconnect();Other possibilites are: # Connection $mbox->connect; $mbox->disconnect; # Config $mbox->configure(%config); $spread_daemon = $mbox->spread_name; $mbox->spread_name('3480@1.1.1.1'); $seed_name = $mbox->name; $mbox->name('test'); $rv = $mbox->debug(); $mbox->debug(1); # tx/rx messages $mbox->send(@grps,$msg); $mbox->sends(@grps,%perlhash); $hashref = $mbox->decode; $msg_size = $mbox->poll; $mbox->rx($timeout,@args); $regular_msg = $mbox->get; $msg = $mbox->getmsg($timeout); # Object/Message details $spread = $mbox->mbox; @grps = $mbox->grps; $sent_by = $mbox->sender; $service_type = $mbox->type; $message_type = $mbox->mess_type; $same_endian = $mbox->endian; $last_message = $mbox->msg; $last_hashref = $mbox->command; $is_new_message = $mbox->new_msg; $time_last_received = $mbox->tm; $timed_out = $mbox->timeout; $mysperrorno = $mbox->error; $whoami = $mbox->me; # Test message $mbox->control_msg; $mbox->aimed_at_me; $mbox->Is_unreliable_mess; $mbox->Is_reliable_mess; $mbox->Is_fifo_mess; $mbox->Is_causal_mess; $mbox->Is_agreed_mess; $mbox->Is_safe_mess; $mbox->Is_regular_mess; $mbox->Is_self_discard; $mbox->Is_reg_memb_mess; $mbox->Is_transition_mess; $mbox->Is_caused_join_mess; $mbox->Is_caused_leave_mess; $mbox->Is_caused_disconnect_mess; $mbox->Is_caused_network_mess; $mbox->Is_membership_mess; $mbox->Is_reject_mess; $mbox->Is_self_leave; # Supplied Callbacks $mbox->_member_sub $mbox->_message_sub $mbox->_error_sub $mbox->_timeout_sub $mbox->handle_commands_aimed_at_meRequirements:· Perl Requirements: · Perl

Spread::Message Related Software