<NME> server.rb
<BEF> ADDFILE
<MSG> - Add MessageClient and MessageServer. These are just empty subclasses of
  MessageSocketMux, but the subclass names detail the intent much more clearly.
  Later, we may want to move MessageSocketMux#listen to MessageServer, and
  #connect to MessageClient.
- Some style fixings:
  * All private methods are prefixed with 'private' on the preceding line.
  * End all methods with 'end # def <method name>'
  * Make methods private that should be private
  * Add documentation to many methods
- Add array support to MessageSocketMux#_sendmsg (and thus #sendmsg). This lets
  a client internally queue things and send multiple message to the output
  queue at the same time.
- Add 'success?' method to ResponseMessage and IndexEventResponse.
- Raise exception if we try to read a message that is too large and is likely
  incorrect/corrupt.
- Refactor MessageReader#each to be much more concise
- Added MessageReader#get (and private methods #ready? and #next_length)


<DFF> @@ -0,0 +1,9 @@
+require 'lib/net/socketmux'
+
+module LogStash; module Net
+  # The MessageServer class exists only as an alias
+  # to the MessageSocketMux. You should use the
+  # client class if you are implementing a client.
+  class MessageServer < MessageSocketMux
+  end # class MessageServer
+end; end # module LogStash::Net

- Add MessageClient and MessageServer. These are just empty subclasses of   MessageSocketMux, but the subclass names detail the intent much more clearly.   Later, we may want to move MessageSocketMux#listen to MessageServer, and   #connect to MessageClient. - Some style fixings:   * All private methods are prefixed with 'private' on the preceding line.   * End all methods with 'end # def <method name>'   * Make methods private that should be private   * Add documentation to many methods - Add array support to MessageSocketMux#_sendmsg (and thus #sendmsg). This lets   a client internally queue things and send multiple message to the output   queue at the same time. - Add 'success?' method to ResponseMessage and IndexEventResponse. - Raise exception if we try to read a message that is too large and is likely   incorrect/corrupt. - Refactor MessageReader#each to be much more concise - Added MessageReader#get (and private methods #ready? and #next_length)