|
ActiveMQ example source code file (listener.rb)
The ActiveMQ listener.rb source code#!/usr/bin/ruby # ------------------------------------------------------------------------ # Licensed to the Apache Software Foundation (ASF) under one or more # contributor license agreements. See the NOTICE file distributed with # this work for additional information regarding copyright ownership. # The ASF licenses this file to You under the Apache License, Version 2.0 # (the "License"); you may not use this file except in compliance with # the License. You may obtain a copy of the License at # # http://www.apache.org/licenses/LICENSE-2.0 # # Unless required by applicable law or agreed to in writing, software # distributed under the License is distributed on an "AS IS" BASIS, # WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. # See the License for the specific language governing permissions and # limitations under the License. # ------------------------------------------------------------------------ require 'rubygems' require 'stomp' @conn = Stomp::Connection.open '', '', 'localhost', 61613, false @count = 0 @conn.subscribe '/topic/event', { :ack =>"auto" } while true @msg = @conn.receive if @msg.command == "MESSAGE" if @msg.body == "SHUTDOWN" exit 0 elsif @msg.body == "REPORT" @diff = Time.now - @start @body = "Received #{@count} in #{@diff} seconds"; @conn.send '/queue/response', @body, {'persistent'=>'false'} @count = 0; else if @count == 0 @start = Time.now end @count += 1; if @count % 1000 == 0 $stdout.print "Received #{@count} messages.\n" end end else $stdout.print "#{@msg.command}: #{@msg.body}\n" end end @conn.disconnect Other ActiveMQ examples (source code examples)Here is a short list of links related to this ActiveMQ listener.rb source code file: |
... this post is sponsored by my books ... | |
#1 New Release! |
FP Best Seller |
Copyright 1998-2021 Alvin Alexander, alvinalexander.com
All Rights Reserved.
A percentage of advertising revenue from
pages under the /java/jwarehouse
URI on this website is
paid back to open source projects.