1 files changed, 21 insertions, 0 deletions
diff --git a/lib/Net/Riak/Role/PBC/Message.pm b/lib/Net/Riak/Role/PBC/Message.pm
new file mode 100644
index 0000000..0c2fbf3
--- /dev/null
+++ b/lib/Net/Riak/Role/PBC/Message.pm
@@ -0,0 +1,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;