NAME

Net::WAMP::RawSocket

SYNOPSIS

Client:

    my $rs = Net::WAMP::RawSocket::Client->new(

        #required
        io => IO::Framed::ReadWrite->new( $inet ),

        #optional
        max_pings           => 10,
        max_receive_length  => 2**23,    #default
    );

    #msgpack is also accepted
    $rs->send_handshake(
        serialization => 'json',    #default
    );

    $rs->verify_handshake();

    $rs->send_message('This is a message.);

    my $msg_txt = $rs->get_next_message();

Server:

    my $rs = Net::WAMP::RawSocket::Server->new(

        #required
        io => IO::Framed::ReadWrite->new( $inet ),

        #optional
        max_pings           => 10,
        max_receive_length  => 2**23,    #default
    );

    $rs->receive_and_answer_handshake();

    $rs->send_message('This is a message.);

    my $msg_txt = $rs->get_next_message();

DESCRIPTION

This module implements WAMP’s RawSocket protocol. It’s a simpler—and hopefully faster—protocol for speaking to a WAMP server when you have a raw TCP connection as opposed to a web browser.

Note that one of RawSocket’s limitations is a hard upper limit (16 MiB) on message size: if you want to send or receive single messages of over 16 MiB, you’ll need some other transport mechanism besides RawSocket.

GENERAL METHODS

CLASS->new( %OPTS )

Instantiates the relevant class. %OPTS are:

• max_receive_length As per the protocol specification, this must be a power of 2 from 512 (2**9) to 16,777,216 (2**24), inclusive.

• max_pings The number of pings to allow unanswered before we give up on the connection.

OBJ->send_message( MSG_STRING )

Sends a regular message.

OBJ->get_next_message()

Returns the next message string, or undef if no message is available. This will also (silently) consume any PONG messages that may arrive.

OBJ->check_heartbeat()

Run this when your read timeout expires to send a PING message.

OBJ->get_serialization()

json or msgpack.

OBJ->get_max_send_length()

The maximum bytes that the connection’s peer is willing to receive in a single RawSocket frame.