lib/miu/publisher.rb in miu-0.0.6 vs lib/miu/publisher.rb in miu-0.1.0

@@ -1,9 +1,8 @@
 require 'miu'
 require 'miu/socket'
-require 'miu/message'
-require 'msgpack'
+require 'miu/packet'
 
 module Miu
   class Publisher < Socket
     def initialize(options = {})
       options[:port] ||= Miu.default_sub_port
@@ -12,11 +11,12 @@
       yield self if block_given?
     end
 
     # tag, time = nil, body
     def send(*args)
-      message = Message.new *args
-      @socket.send_strings message.dump
+      packet = Packet.new *args
+      @socket.send_strings packet.dump
+      packet.id
     end
 
     private
 
     def socket_type