Skip to content

Instantly share code, notes, and snippets.

@kml
kml / .gitignore
Last active August 29, 2015 14:02
activemq-stats-ruby
.bundle
bundle
require 'torquebox/messaging'
require 'torquebox/messaging/connection_factory'
require 'torquebox/messaging/destination'
module TorqueBox
module Messaging
class Destination
def publish_each(messages, options = {})
wait_for_destination(options[:startup_timeout]) do
with_session(options) do |session|
# encoding: utf-8
class StringUtilsMock
def self.underscore(name); name.underscore; end
end
JavaUtilities.class_eval do
class << self
alias_method :get_proxy_or_package_under_package_original, :get_proxy_or_package_under_package
def get_proxy_or_package_under_package(obj, sym)
=begin
$ uname -a
Linux jboss-updater2 3.2.21-nkt #1 SMP Wed Aug 1 20:23:57 CEST 2012 x86_64 GNU/Linux
$ java -version
java version "1.7.0_03"
OpenJDK Runtime Environment (IcedTea7 2.1.1pre) (7~u3-2.1.1~pre1-2)
OpenJDK 64-Bit Server VM (build 22.0-b10, mixed mode)
$ jruby --version
# ...
options = {properties: {}}
options[:properties]['_HQ_SCHED_DELIVERY'] = Time.now.to_i * 1000 + 30.seconds * 1000 # milis
download_queue.publish({message: {photo_id: photo.id}}, options)
@kml
kml / Gemfile
Created March 6, 2012 09:32
Torquebox problem
source :rubygems
gem 'rack'
gem 'json'
gem 'torquebox-rake-support'
gem 'rdiscount'