set the Content-Type to application/json when appropriate

lib/logglier/client.rb

@@ -16,7 +16,7 @@ def self.new(input_url, opts={})
       unless input_url
         raise URLRequired.new
       end
-      
+
       opts.merge!({ :input_url => input_url })
 
       begin
@@ -33,7 +33,7 @@ def self.new(input_url, opts={})
       else
         raise Logglier::UnsupportedScheme.new("#{input_uri.scheme} is unsupported")
       end
-      
+
     end
 
     module InstanceMethods

lib/logglier/client/http/sync.rb

@@ -19,6 +19,11 @@ def initialize(input_uri, opts={})
           @ca_file = opts[:ca_file]
           @read_timeout = opts[:read_timeout] || 5
           @open_timeout = opts[:open_timeout] || 5
+          @format = opts[:format] ? opts[:format].to_sym : nil
+          @headers = {}
+          if @format == :json
+            @headers['Content-Type'] = 'application/json'
+          end
 
           connect!
         end
@@ -29,7 +34,7 @@ def initialize(input_uri, opts={})
         def deliver(message)
           retried = false
           begin
-            @http.request_post(@input_uri.path, message)
+            @http.request_post(@input_uri.path, message, @headers)
           # We're using persistent connections, so connection can be closed by the other side
           # after a timeout. Don't consider it an error, just retry once.
           rescue Errno::ECONNRESET