lib/Net/Riak/Role/PBC/Message.pm


1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21

package Net::Riak::Role::PBC::Message;

use Moose::Role;
use Net::Riak::Transport::PBC::Message;

sub send_message {
    my ( $self, $type, $params, $cb ) = @_;

    $self->connect unless $self->connected;

    my $message = Net::Riak::Transport::PBC::Message->new(
        message_type => $type,
        params       => $params || {},
    );

    $message->socket( $self->socket );

    return $message->send($cb);
}

1;