Contents

require 'java'

java_import 'java.util.concurrent.Callable'

require 'alephant/publisher/writer'

module Alephant
  module Publisher
    class PublishTask
      include Callable

      attr_reader :opts, :message

      def initialize(opts, message)
        @message = message
        @opts = opts
      end

      def call
        unless message.nil?
          Writer.new(opts, message).run!
          message.delete
        end
      end

    end
  end
end

Version data entries

3 entries across 3 versions & 1 rubygems

Version	Path
alephant-publisher-0.1.7	lib/alephant/publisher/publish_task.rb
alephant-publisher-0.1.6	lib/alephant/publisher/publish_task.rb
alephant-publisher-0.1.5	lib/alephant/publisher/publish_task.rb