activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Timothy Bish <tabish...@gmail.com>
Subject Re: Sending Image Files through ActiveMQ-CPP
Date Wed, 22 Apr 2009 17:29:16 GMT
On Wed, 2009-04-22 at 10:23 -0700, manua wrote:
> HI Tim,
> 
> I am trying to send large bytes messages. From the producer end, I am able
> to send the messages, but at the consumer end, after recieving some
> messages, I am getting Segmentation fault. Please find below the output, I
> recieved at the consumer end. Kindly help me with this. 
> 
> 

The best way to go about finding what is wrong is to try and reproduce
the error in a small example app that you can attach the code to a Jira
issue.  The output here doesn't really provide enough info to guess at
what is going wrong, we'd need to capture some backtraces from gdb to
see where in the code the error is occurring.  

> Starting the example: -----------------------------------------------------
> Press 'q' to quit Message #1 Received:
> fsfdfsgdfgdhdhdfghdhdhhhfgjjtrwertrtrtytryryfgchfghfghdfhdf hfdgdf no. of
> bytes = 65 
> 
> Message #2 Received:
> fsfdfsgdfgdhdhdfghdhdhhhfgjjtrwertrtrtytryryfgchfghfghdfhdf hfdgdf no. of
> bytes = 65 
> Message #3 Received:
> fsfdfsgdfgdhdhdfghdhdhhhfgjjtrwertrtrtytryryfgchfghfghdfhdf hfdgdf~l no. of
> bytes = 65
> 
>  *** glibc detected ***
> /root/amq/activemq-cpp-2.2.4-src/src/examples/.libs/lt-si
> mple_async_consumer: corrupted double-linked list: 0x09b6eba0 *** =======
> Backtrace: ========= /lib/i686/nosegneg/libc.so.6[0xa910c9]
> /lib/i686/nosegneg/libc.so.6(__libc_malloc+0x82)[0xa92772]
> /usr/lib/libstdc++.so.6(_Znwj+0x27)[0x7895c7]
> /root/amq/activemq-cpp-2.2.4-src/src/main/.libs/libactivemq-cpp.so.6(_ZNSt6vecto
> rIhSaIhEE13_M_insert_auxEN9__gnu_cxx17__normal_iteratorIPhS1_EERKh+0x9c)[0x3c90d
> c]
> /root/amq/activemq-cpp-2.2.4-src/src/main/.libs/libactivemq-cpp.so.6(_ZN5decaf2i
> o21ByteArrayOutputStream5writeEPKhjj+0x69)[0x4acd59]
> /root/amq/activemq-cpp-2.2.4-src/src/main/.libs/libactivemq-cpp.so.6(_ZN5decaf2i
> o16DataOutputStream8writeIntEi+0x68)[0x4ab728]
> /root/amq/activemq-cpp-2.2.4-src/src/main/.libs/libactivemq-cpp.so.6(_ZN8activem
> q9connector8openwire7marshal2v321BaseCommandMarshaller12looseMarshalEPNS1_14Open
> WireFormatEPNS1_8commands13DataStructureEPN5decaf2io16DataOutputStreamE+0x65)[0x
> 5c8b85]
> /root/amq/activemq-cpp-2.2.4-src/src/main/.libs/libactivemq-cpp.so.6(_ZN8activem
> q9connector8openwire7marshal2v320MessageAckMarshaller12looseMarshalEPNS1_14OpenW
> ireFormatEPNS1_8commands13DataStructureEPN5decaf2io16DataOutputStreamE+0x60)[0x5
> e9810]
> /root/amq/activemq-cpp-2.2.4-src/src/main/.libs/libactivemq-cpp.so.6(_ZN8activem
> q9connector8openwire14OpenWireFormat7marshalEPNS_9transport7CommandEPN5decaf2io1
> 6DataOutputStreamE+0xf0)[0x4106c0]
> /root/amq/activemq-cpp-2.2.4-src/src/main/.libs/libactivemq-cpp.so.6(_ZN8activem
> q9connector8openwire21OpenWireCommandWriter12writeCommandEPNS_9transport7Command
> E+0x48)[0x416478]
> /root/amq/activemq-cpp-2.2.4-src/src/main/.libs/libactivemq-cpp.so.6(_ZN8activem
> q9transport11IOTransport6onewayEPNS0_7CommandE+0x67)[0x445107]
> /root/amq/activemq-cpp-2.2.4-src/src/main/.libs/libactivemq-cpp.so.6(_ZN8activem
> q9transport15TransportFilter6onewayEPNS0_7CommandE+0x27)[0x443787]
> /root/amq/activemq-cpp-2.2.4-src/src/main/.libs/libactivemq-cpp.so.6(_ZN8activem
> q9transport7filters18ResponseCorrelator6onewayEPNS0_7CommandE+0x68)[0x449668]
> /root/amq/activemq-cpp-2.2.4-src/src/main/.libs/libactivemq-cpp.so.6(_ZN8activem
> q9connector8openwire24OpenWireFormatNegotiator6onewayEPNS_9transport7CommandE+0x
> 53)[0x417f33]
> /root/amq/activemq-cpp-2.2.4-src/src/main/.libs/libactivemq-cpp.so.6(_ZN8activem
> q9connector8openwire17OpenWireConnector6onewayEPNS_9transport7CommandE+0x32)[0x4
> 18cb2]
> /root/amq/activemq-cpp-2.2.4-src/src/main/.libs/libactivemq-cpp.so.6(_ZN8activem
> q9connector8openwire17OpenWireConnector11acknowledgeEPKNS0_11SessionInfoEPKNS0_1
> 2ConsumerInfoEPKN3cms7MessageENS0_9Connector7AckTypeE+0x160)[0x41a4a0]
> /root/amq/activemq-cpp-2.2.4-src/src/main/.libs/libactivemq-cpp.so.6(_ZN8activem
> q4core16ActiveMQConsumer11acknowledgeEPKNS0_15ActiveMQMessageEi+0xbd)[0x3a7e1d]
> /root/amq/activemq-cpp-2.2.4-src/src/main/.libs/libactivemq-cpp.so.6(_ZN8activem
> q4core16ActiveMQConsumer22afterMessageIsConsumedEPNS0_15ActiveMQMessageEb+0x6c)[
> 0x3a828c]
> /root/amq/activemq-cpp-2.2.4-src/src/main/.libs/libactivemq-cpp.so.6(_ZN8activem
> q4core16ActiveMQConsumer8dispatchERNS0_12DispatchDataE+0x9f)[0x3a904f]
> /root/amq/activemq-cpp-2.2.4-src/src/main/.libs/libactivemq-cpp.so.6(_ZN8activem
> q4core23ActiveMQSessionExecutor8dispatchERNS0_12DispatchDataE+0xa5)[0x3c2185]
> /root/amq/activemq-cpp-2.2.4-src/src/main/.libs/libactivemq-cpp.so.6(_ZN8activem
> q4core23ActiveMQSessionExecutor11dispatchAllEv+0xe1)[0x3c37b1]
> /root/amq/activemq-cpp-2.2.4-src/src/main/.libs/libactivemq-cpp.so.6(_ZN8activem
> q4core23ActiveMQSessionExecutor3runEv+0x1f)[0x3c3ddf]
> /root/amq/activemq-cpp-2.2.4-src/src/main/.libs/libactivemq-cpp.so.6(_ZN5decaf4l
> ang6Thread11runCallbackEP12apr_thread_tPv+0x28)[0x499038]
> /root/amq/apr-1.3.3/.libs/libapr-1.so.0[0x132ad6]
> /lib/i686/nosegneg/libpthread.so.0[0xe21542]
> /lib/i686/nosegneg/libc.so.6(clone+0x5e)[0xafbb6e] ======= Memory map:
> ======== 00110000-00113000 r-xp 00000000 08:01 524365 /lib/libuuid.so.1.2
> 00113000-00114000 rw-p 00002000 08:01 524365 /lib/libuuid.so.1.2
> 00114000-00138000 r-xp 00000000 08:01 902025 /root/amq/apr-1.3.3/.libs/libap
> r-1.so.0.3.3 00138000-00139000 rw-p 00023000 08:01 902025
> /root/amq/apr-1.3.3/.libs/libap r-1.so.0.3.3 00139000-0013c000 r-xp 00000000
> 08:01 524383 /lib/libdl-2.7.so 0013c000-0013d000 r--p 00002000 08:01 524383
> /lib/libdl-2.7.so 0013d000-0013e000 rw-p 00003000 08:01 524383
> /lib/libdl-2.7.so 00141000-0015c000 r-xp 00000000 08:01 524338
> /lib/ld-2.7.so 0015c000-0015d000 r--p 0001a000 08:01 524338 /lib/ld-2.7.so
> 0015d000-0015e000 rw-p 0001b000 08:01 524338 /lib/ld-2.7.so
> 0015e000-00165000 r-xp 00000000 08:01 524554 /lib/i686/nosegneg/librt-2.7.so
> 00165000-00166000 r--p 00007000 08:01 524554 /lib/i686/nosegneg/librt-2.7.so
> 00166000-00167000 rw-p 00008000 08:01 524554 /lib/i686/nosegneg/librt-2.7.so
> 00167000-00181000 r-xp 00000000 08:01 902329 /root/amq/apr-util-1.3.4/xml/ex
> pat/lib/.libs/libexpat.so.0.1.0 00181000-00183000 rw-p 00019000 08:01 902329
> /root/amq/apr-util-1.3.4/xml/ex pat/lib/.libs/libexpat.so.0.1.0
> 00183000-001aa000 r-xp 00000000 08:01 524552 /lib/i686/nosegneg/libm-2.7.so
> 001aa000-001ab000 r--p 00026000 08:01 524552 /lib/i686/nosegneg/libm-2.7.so
> 001ab000-001ac000 rw-p 00027000 08:01 524552 /lib/i686/nosegneg/libm-2.7.so
> 001ac000-001b7000 r-xp 00000000 08:01 524396 /lib/libgcc_s-4.1.2-20070925.so
> .1 001b7000-001b8000 rw-p 0000a000 08:01 524396
> /lib/libgcc_s-4.1.2-20070925.so .1 0024c000-0024d000 r-xp 0024c000 00:00 0
> [vdso] 0024d000-006bd000 r-xp 00000000 08:01 917755
> /root/amq/activemq-cpp-2.2.4-sr c/src/main/.libs/libactivemq-cpp.so.6.0.1
> 006bd000-006d6000 rw-p 0046f000 08:01 917755 /root/amq/activemq-cpp-2.2.4-sr
> c/src/main/.libs/libactivemq-cpp.so.6.0.1 006d6000-006d7000 rw-p 006d6000
> 00:00 0 006d7000-007b5000 r-xp 00000000 08:01 1131416
> /usr/lib/libstdc++.so.6.0.8 007b5000-007b8000 r--p 000dd000 08:01 1131416
> /usr/lib/libstdc++.so.6.0.8 007b8000-007ba000 rw-p 000e0000 08:01 1131416
> /usr/lib/libstdc++.so.6.0.8 007ba000-007c0000 rw-p 007ba000 00:00 0
> 00a26000-00b7c000 r-xp 00000000 08:01 524551 /lib/i686/nosegneg/libc-2.7.so
> 00b7c000-00b7e000 r--p 00156000 08:01 524551 /lib/i686/nosegneg/libc-2.7.so
> 00b7e000-00b7f000 rw-p 00158000 08:01 524551 /lib/i686/nosegneg/libc-2.7.so
> 00b7f000-00b82000 rw-p 00b7f000 00:00 0 00bac000-00bb5000 r-xp 00000000
> 08:01 524368 /lib/libcrypt-2.7.so 00bb5000-00bb6000 r--p 00008000 08:01
> 524368 /lib/libcrypt-2.7.so 00bb6000-00bb7000 rw-p 00009000 08:01 524368
> /lib/libcrypt-2.7.so 00bb7000-00bde000 rw-p 00bb7000 00:00 0
> 00e1c000-00e31000 r-xp 00000000 08:01 524553 /lib/i686/nosegneg/libpthread-2
> .7.so 00e31000-00e32000 r--p 00014000 08:01 524553
> /lib/i686/nosegneg/libpthread-2 .7.so 00e32000-00e33000 rw-p 00015000 08:01
> 524553 /lib/i686/nosegneg/libpthread-2 .7.so 00e33000-00e35000 rw-p 00e33000
> 00:00 0 00f96000-00fb1000 r-xp 00000000 08:01 902484
> /root/amq/apr-util-1.3.4/.libs/ libaprutil-1.so.0.3.4 00fb1000-00fb2000 rw-p
> 0001a000 08:01 902484 /root/amq/apr-util-1.3.4/.libs/ libaprutil-1.so.0.3.4
> 08048000-0804b000 r-xp 00000000 08:01 950285 /root/amq/activemq-cpp-2.2.4-sr
> c/src/examples/.libs/lt-simple_async_consumer 0804b000-0804c000 rw-p
> 00002000 08:01 950285 /root/amq/activemq-cpp-2.2.4-sr
> c/src/examples/.libs/lt-simple_async_consumer 09b2a000-09c13000 rw-p
> 09b2a000 00:00 0 b6a00000-b6a21000 rw-p b6a00000 00:00 0 b6a21000-b6b00000
> ---p b6a21000 00:00 0 b6b15000-b6b16000 ---p b6b15000 00:00 0
> b6b16000-b7516000 rw-p b6b16000 00:00 0 b7516000-b7517000 ---p b7516000
> 00:00 0 b7517000-b7f1b000 rw-p b7517000 00:00 0 b7f20000-b7f23000 rw-p
> b7f20000 00:00 0 bfe44000-bfe5a000 rw-p bfe44000 00:00 0 [stack] Aborted 
> 
> Kindly advise me, how to move forward from here.
> 
> Thanks,
> Manu
> 
> 
> Timothy Bish wrote:
> > 
> > On Tue, 2009-04-21 at 20:02 -0700, manua wrote:
> >> Hi All,
> >> 
> >> I am trying to transfer image files/continous data streams using
> >> ActiveMQ-CPP. I tried to use Bytes Messages but was not successful. Could
> >> any obe share a sample code for the same or guide mw if there is any
> >> other
> >> better way through which I can transfer files from my local machines
> >> using
> >> ActiveMQ-CPP.
> >> 
> >> Any help in this regard will be highly appreciated.
> >> 
> >> Thanks,
> >> Manu
> > 
> > What sorts of issues did you run into when attempting to use a
> > BytesMessage?  Currently the BytesMessage is the only way that you could
> > do this with AMQCPP since we don't support BlobMessage at the moment.
> > 
> > Regards
> > Tim.
> > 
> > 
> > -- 
> > Tim Bish
> > http://fusesource.com
> > http://timbish.blogspot.com/
> > 
> > 
> > 
> > 
> > 
> 
-- 
Tim Bish
http://fusesource.com
http://timbish.blogspot.com/




Mime
View raw message