activemq-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Claus Ibsen (JIRA)" <j...@apache.org>
Subject [jira] [Resolved] (AMQ-4070) catstomp.rb does not work anymore
Date Tue, 25 Sep 2012 11:02:07 GMT

     [ https://issues.apache.org/jira/browse/AMQ-4070?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]

Claus Ibsen resolved AMQ-4070.
------------------------------

       Resolution: Fixed
    Fix Version/s: 5.7.0
         Assignee: Claus Ibsen

Thanks for the patch.
                
> catstomp.rb does not work anymore
> ---------------------------------
>
>                 Key: AMQ-4070
>                 URL: https://issues.apache.org/jira/browse/AMQ-4070
>             Project: ActiveMQ
>          Issue Type: Bug
>          Components: Samples
>    Affects Versions: 5.6.0
>            Reporter: Francesco
>            Assignee: Claus Ibsen
>            Priority: Trivial
>             Fix For: 5.7.0
>
>
> with the most recente stomp gem, the send method has been replaced with publish, so the
bundled catstomp does not longer work.
> Follows a proposal of a working catstomp.rb with one improvement: now it stops gracefully
con CTRL+C
> cheers,
> Francesco
> #!/usr/bin/env 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'
> continue = true
> trap("INT") {
>   puts "CTRL+C"
>   puts "shutting down ..."
>   @conn.disconnect
>   sleep 1
>   STDIN.close
> }
>   
> @port = 61613
> @host = "localhost"
> @user = ENV["STOMP_USER"];
> @password = ENV["STOMP_PASSWORD"]
>     
> @host = ENV["STOMP_HOST"] if ENV["STOMP_HOST"] != NIL
> @port = ENV["STOMP_PORT"] if ENV["STOMP_PORT"] != NIL
>     
> @destination = "/topic/stompcat"
> @destination = $*[0] if $*[0] != NIL
>     
> $stderr.print "Connecting to stomp://#{@host}:#{@port} as #{@user}\n"
> @conn = Stomp::Connection.open @user, @password, @host, @port, true
> $stderr.print "Sending input to #{@destination}\n"
> @headers = {'persistent'=>'false'} 
> @headers['reply-to'] = $*[1] if $*[1] != NIL
> begin
>   STDIN.each_line { |line| 
>     @conn.publish @destination, line, @headers
>   }
> rescue IOError
> end

--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators
For more information on JIRA, see: http://www.atlassian.com/software/jira

Mime
View raw message