blob: 0c2fbf3cc1a228ab3ccfc3f26877d9f19cbd419d (
plain) (
blame)
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;
|