Issue while publishing to RMQ using bunny in production

[Sourav Gulati]

We tried using Bunny client to push messages to RMQ and got following exception:

 

/opt/fluentd/local/lib/ruby/gems/1.9.1/gems/amq-protocol-1.9.2/lib/amq/protocol/frame.rb:62: [BUG] Bus Error

ruby 1.9.3p545 (2014-02-24 revision 45159) [sparc-solaris2.10]

 

-- Control frame information -----------------------------------------------

c:0008 p:---- s:0040 b:0040 l:000039 d:000039 CFUNC  :unpack

c:0007 p:0053 s:0036 b:0036 l:000035 d:000035 METHOD /opt/fluentd/local/lib/ruby/gems/1.9.1/gems/amq-protocol-1.9.2/lib/amq/protocol/frame.rb:62

c:0006 p:0042 s:0028 b:0028 l:000027 d:000027 METHOD /opt/fluentd/local/lib/ruby/gems/1.9.1/gems/bunny-1.1.0.rc1/lib/bunny/transport.rb:205

c:0005 p:0023 s:0018 b:0018 l:000017 d:000017 METHOD /opt/fluentd/local/lib/ruby/gems/1.9.1/gems/bunny-1.1.0.rc1/lib/bunny/session.rb:890

c:0004 p:0112 s:0014 b:0014 l:000013 d:000013 METHOD /opt/fluentd/local/lib/ruby/gems/1.9.1/gems/bunny-1.1.0.rc1/lib/bunny/session.rb:248

c:0003 p:0059 s:0010 b:0010 l:001d6c d:002674 EVAL   ./helloworld.rb:8

c:0002 p:---- s:0004 b:0004 l:000003 d:000003 FINISH

c:0001 p:0000 s:0002 b:0002 l:001d6c d:001d6c TOP

 

-- Ruby level backtrace information ----------------------------------------

./helloworld.rb:8:in `<main>'

/opt/fluentd/local/lib/ruby/gems/1.9.1/gems/bunny-1.1.0.rc1/lib/bunny/session.rb:248:in `start'

/opt/fluentd/local/lib/ruby/gems/1.9.1/gems/bunny-1.1.0.rc1/lib/bunny/session.rb:890:in `init_connection'

/opt/fluentd/local/lib/ruby/gems/1.9.1/gems/bunny-1.1.0.rc1/lib/bunny/transport.rb:205:in `read_next_frame'

/opt/fluentd/local/lib/ruby/gems/1.9.1/gems/amq-protocol-1.9.2/lib/amq/protocol/frame.rb:62:in `decode_header'

/opt/fluentd/local/lib/ruby/gems/1.9.1/gems/amq-protocol-1.9.2/lib/amq/protocol/frame.rb:62:in `unpack'

 

-- Other runtime information -----------------------------------------------

 

* Loaded script: ./helloworld.rb

 

* Loaded features:

 

    0 enumerator.so

    1 /opt/fluentd/local/lib/ruby/1.9.1/sparc-solaris2.10/enc/encdb.so

    2 /opt/fluentd/local/lib/ruby/1.9.1/sparc-solaris2.10/enc/trans/transdb.so

    3 /opt/fluentd/local/lib/ruby/1.9.1/rubygems/defaults.rb

    4 /opt/fluentd/local/lib/ruby/1.9.1/sparc-solaris2.10/rbconfig.rb

    5 /opt/fluentd/local/lib/ruby/1.9.1/rubygems/deprecate.rb

    6 /opt/fluentd/local/lib/ruby/1.9.1/rubygems/exceptions.rb

    7 /opt/fluentd/local/lib/ruby/1.9.1/rubygems/custom_require.rb

    8 /opt/fluentd/local/lib/ruby/1.9.1/rubygems.rb

    9 /opt/fluentd/local/lib/ruby/1.9.1/rubygems/version.rb

   10 /opt/fluentd/local/lib/ruby/1.9.1/rubygems/requirement.rb

   11 /opt/fluentd/local/lib/ruby/1.9.1/rubygems/platform.rb

   12 /opt/fluentd/local/lib/ruby/1.9.1/rubygems/specification.rb

   13 /opt/fluentd/local/lib/ruby/1.9.1/rubygems/path_support.rb

   14 /opt/fluentd/local/lib/ruby/1.9.1/rubygems/dependency.rb

   15 /opt/fluentd/local/lib/ruby/1.9.1/timeout.rb

   16 /opt/fluentd/local/lib/ruby/gems/1.9.1/gems/bunny-1.1.0.rc1/lib/bunny/version.rb

   17 /opt/fluentd/local/lib/ruby/gems/1.9.1/gems/amq-protocol-1.9.2/lib/amq/endianness.rb

   18 /opt/fluentd/local/lib/ruby/gems/1.9.1/gems/amq-protocol-1.9.2/lib/amq/pack.rb

   19 /opt/fluentd/local/lib/ruby/gems/1.9.1/gems/amq-protocol-1.9.2/lib/amq/protocol/type_constants.rb

   20 /opt/fluentd/local/lib/ruby/1.9.1/sparc-solaris2.10/date_core.so

   21 /opt/fluentd/local/lib/ruby/1.9.1/date/format.rb

   22 /opt/fluentd/local/lib/ruby/1.9.1/date.rb

   23 /opt/fluentd/local/lib/ruby/gems/1.9.1/gems/amq-protocol-1.9.2/lib/amq/protocol/float_32bit.rb

   24 /opt/fluentd/local/lib/ruby/gems/1.9.1/gems/amq-protocol-1.9.2/lib/amq/protocol/table_value_encoder.rb

   25 /opt/fluentd/local/lib/ruby/gems/1.9.1/gems/amq-protocol-1.9.2/lib/amq/protocol/table_value_decoder.rb

   26 /opt/fluentd/local/lib/ruby/gems/1.9.1/gems/amq-protocol-1.9.2/lib/amq/protocol/table.rb

   27 /opt/fluentd/local/lib/ruby/gems/1.9.1/gems/amq-protocol-1.9.2/lib/amq/protocol/frame.rb

   28 /opt/fluentd/local/lib/ruby/gems/1.9.1/gems/amq-protocol-1.9.2/lib/amq/protocol/constants.rb

   29 /opt/fluentd/local/lib/ruby/gems/1.9.1/gems/amq-protocol-1.9.2/lib/amq/protocol/exceptions.rb

   30 /opt/fluentd/local/lib/ruby/gems/1.9.1/gems/amq-protocol-1.9.2/lib/amq/protocol/client.rb

   31 /opt/fluentd/local/lib/ruby/gems/1.9.1/gems/bunny-1.1.0.rc1/lib/amq/protocol/extensions.rb

   32 /opt/fluentd/local/lib/ruby/gems/1.9.1/gems/bunny-1.1.0.rc1/lib/bunny/framing.rb

   33 /opt/fluentd/local/lib/ruby/gems/1.9.1/gems/bunny-1.1.0.rc1/lib/bunny/exceptions.rb

   34 /opt/fluentd/local/lib/ruby/1.9.1/sparc-solaris2.10/socket.so

   35 /opt/fluentd/local/lib/ruby/1.9.1/socket.rb

   36 /opt/fluentd/local/lib/ruby/gems/1.9.1/gems/bunny-1.1.0.rc1/lib/bunny/cruby/socket.rb

   37 /opt/fluentd/local/lib/ruby/gems/1.9.1/gems/bunny-1.1.0.rc1/lib/bunny/socket.rb

   38 /opt/fluentd/local/lib/ruby/gems/1.9.1/gems/bunny-1.1.0.rc1/lib/bunny/timeout.rb

   39 /opt/fluentd/local/lib/ruby/1.9.1/sparc-solaris2.10/digest.so

   40 /opt/fluentd/local/lib/ruby/1.9.1/digest.rb

   41 /opt/fluentd/local/lib/ruby/1.9.1/sparc-solaris2.10/openssl.so

   42 /opt/fluentd/local/lib/ruby/1.9.1/openssl/bn.rb

   43 /opt/fluentd/local/lib/ruby/1.9.1/openssl/cipher.rb

   44 /opt/fluentd/local/lib/ruby/1.9.1/sparc-solaris2.10/stringio.so

   45 /opt/fluentd/local/lib/ruby/1.9.1/openssl/config.rb

   46 /opt/fluentd/local/lib/ruby/1.9.1/openssl/digest.rb

   47 /opt/fluentd/local/lib/ruby/1.9.1/openssl/buffering.rb

   48 /opt/fluentd/local/lib/ruby/1.9.1/sparc-solaris2.10/fcntl.so

   49 /opt/fluentd/local/lib/ruby/1.9.1/openssl/ssl-internal.rb

   50 /opt/fluentd/local/lib/ruby/1.9.1/openssl/x509-internal.rb

   51 /opt/fluentd/local/lib/ruby/1.9.1/openssl.rb

   52 /opt/fluentd/local/lib/ruby/gems/1.9.1/gems/bunny-1.1.0.rc1/lib/bunny/cruby/ssl_socket.rb

   53 /opt/fluentd/local/lib/ruby/gems/1.9.1/gems/bunny-1.1.0.rc1/lib/bunny/ssl_socket.rb

   54 /opt/fluentd/local/lib/ruby/1.9.1/thread.rb

   55 /opt/fluentd/local/lib/ruby/1.9.1/monitor.rb

   56 /opt/fluentd/local/lib/ruby/1.9.1/logger.rb

   57 /opt/fluentd/local/lib/ruby/gems/1.9.1/gems/bunny-1.1.0.rc1/lib/bunny/transport.rb

   58 /opt/fluentd/local/lib/ruby/gems/1.9.1/gems/amq-protocol-1.9.2/lib/amq/bit_set.rb

   59 /opt/fluentd/local/lib/ruby/gems/1.9.1/gems/amq-protocol-1.9.2/lib/amq/int_allocator.rb

   60 /opt/fluentd/local/lib/ruby/gems/1.9.1/gems/bunny-1.1.0.rc1/lib/bunny/channel_id_allocator.rb

   61 /opt/fluentd/local/lib/ruby/gems/1.9.1/gems/bunny-1.1.0.rc1/lib/bunny/heartbeat_sender.rb

   62 /opt/fluentd/local/lib/ruby/gems/1.9.1/gems/bunny-1.1.0.rc1/lib/bunny/reader_loop.rb

   63 /opt/fluentd/local/lib/ruby/gems/1.9.1/gems/bunny-1.1.0.rc1/lib/bunny/authentication/credentials_encoder.rb

   64 /opt/fluentd/local/lib/ruby/gems/1.9.1/gems/bunny-1.1.0.rc1/lib/bunny/authentication/plain_mechanism_encoder.rb

   65 /opt/fluentd/local/lib/ruby/gems/1.9.1/gems/bunny-1.1.0.rc1/lib/bunny/authentication/external_mechanism_encoder.rb

   66 /opt/fluentd/local/lib/ruby/gems/1.9.1/gems/bunny-1.1.0.rc1/lib/bunny/concurrent/continuation_queue.rb

   67 /opt/fluentd/local/lib/ruby/1.9.1/cgi/core.rb

   68 /opt/fluentd/local/lib/ruby/1.9.1/cgi/cookie.rb

   69 /opt/fluentd/local/lib/ruby/1.9.1/cgi/util.rb

   70 /opt/fluentd/local/lib/ruby/1.9.1/cgi.rb

   71 /opt/fluentd/local/lib/ruby/1.9.1/uri/common.rb

   72 /opt/fluentd/local/lib/ruby/1.9.1/uri/generic.rb

   73 /opt/fluentd/local/lib/ruby/1.9.1/uri/ftp.rb

   74 /opt/fluentd/local/lib/ruby/1.9.1/uri/http.rb

   75 /opt/fluentd/local/lib/ruby/1.9.1/uri/https.rb

   76 /opt/fluentd/local/lib/ruby/1.9.1/uri/ldap.rb

   77 /opt/fluentd/local/lib/ruby/1.9.1/uri/ldaps.rb

   78 /opt/fluentd/local/lib/ruby/1.9.1/uri/mailto.rb

   79 /opt/fluentd/local/lib/ruby/1.9.1/uri.rb

   80 /opt/fluentd/local/lib/ruby/gems/1.9.1/gems/amq-protocol-1.9.2/lib/amq/uri.rb

   81 /opt/fluentd/local/lib/ruby/gems/1.9.1/gems/amq-protocol-1.9.2/lib/amq/settings.rb

   82 /opt/fluentd/local/lib/ruby/gems/1.9.1/gems/bunny-1.1.0.rc1/lib/bunny/session.rb

   83 /opt/fluentd/local/lib/ruby/1.9.1/set.rb

   84 /opt/fluentd/local/lib/ruby/gems/1.9.1/gems/bunny-1.1.0.rc1/lib/bunny/concurrent/atomic_fixnum.rb

   85 /opt/fluentd/local/lib/ruby/gems/1.9.1/gems/bunny-1.1.0.rc1/lib/bunny/consumer_work_pool.rb

   86 /opt/fluentd/local/lib/ruby/gems/1.9.1/gems/bunny-1.1.0.rc1/lib/bunny/compatibility.rb

   87 /opt/fluentd/local/lib/ruby/gems/1.9.1/gems/bunny-1.1.0.rc1/lib/bunny/exchange.rb

   88 /opt/fluentd/local/lib/ruby/gems/1.9.1/gems/bunny-1.1.0.rc1/lib/bunny/queue.rb

   89 /opt/fluentd/local/lib/ruby/gems/1.9.1/gems/bunny-1.1.0.rc1/lib/bunny/versioned_delivery_tag.rb

   90 /opt/fluentd/local/lib/ruby/gems/1.9.1/gems/bunny-1.1.0.rc1/lib/bunny/delivery_info.rb

   91 /opt/fluentd/local/lib/ruby/gems/1.9.1/gems/bunny-1.1.0.rc1/lib/bunny/return_info.rb

   92 /opt/fluentd/local/lib/ruby/gems/1.9.1/gems/bunny-1.1.0.rc1/lib/bunny/message_properties.rb

   93 /opt/fluentd/local/lib/ruby/gems/1.9.1/gems/bunny-1.1.0.rc1/lib/bunny/channel.rb

   94 /opt/fluentd/local/lib/ruby/gems/1.9.1/gems/bunny-1.1.0.rc1/lib/bunny/consumer.rb

   95 /opt/fluentd/local/lib/ruby/gems/1.9.1/gems/bunny-1.1.0.rc1/lib/bunny.rb

 

It seems some conversion error . Dows bunny convert message to UTF-8 before sending . Is this issue related to conversion or there is some other issue