activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From manua <agarwal.m...@gmail.com>
Subject Re: Sending Image Files through ActiveMQ-CPP
Date Wed, 22 Apr 2009 17:23:00 GMT

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. 


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/
> 
> 
> 
> 
> 

-- 
View this message in context: http://www.nabble.com/Sending-Image-Files-through-ActiveMQ-CPP-tp23168851p23175766.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.


Mime
View raw message