Hi Tim,

Thanks for your reply.

PLease find below the part of my code, which I am using for sending and
recieving bytesmessages.

Code snippet from Producer.cpp

char Text[100];

ifstream inFile("abc.txt",ios::in | ios::binary);

int i=0;
while(inFile>>Text[i])
{
        cout<createBytesMessage();
                  message->setBodyBytes((unsigned char*)Text,(size_t)i);

 producer->send( message );

                delete message;


================================================================

Code Snippet from Consumer side,

virtual void onMessage( const Message* message ){

static int count = 0;

        try
        {
            count++;
const BytesMessage* bytesMessage =
                dynamic_cast< const BytesMessage* >( message );

                      char* tempCharArray=new
char(bytesMessage->getBodyLength());
BytesMessage* bytesMessage1 = bytesMessage->clone();
bytesMessage1->reset();

ofstream outFile("abc_out.txt",ios::app | ios::binary);
                
memcpy(tempCharArray,(char*)(bytesMessage1->getBodyBytes()),bytesMessage->getBodyLength());

outFile.write(tempCharArray,bytesMessage->getBodyLength());
            if( clientAck ) {
                message->acknowledge();
            }

            printf( "Message #%d Received: %s\n", count, tempCharArray );
            printf( "\n no. of bytes = %d\n",bytesMessage->getBodyLength());
                delete []tempCharArray;
                tempCharArray=NULL;

        } catch (CMSException& e) {
            e.printStackTrace();
        }
    }

==================================================================

The same code was working fine for text and map messages.

Regarding platform, I am trying it on Amazon ec2 instances of medium size.

PLease let me know your inputs.

Thanks,
Manu

Timothy Bish wrote:
> 
> On Wed, 2009-04-22 at 07:40 -0700, manua wrote:
>> Hi All,
>> 
>> I am trying to send large bytes messages. From the producer end, I ma
>> 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.
> 
> Can you create a simple test case that reproduces this issue?  If you
> could do that and open a new Jira issue and attach the test that would
> be helpful.  
> 
> Also provide any info about your Platform / OS / Compiler.
> 
> Regards
> Tim.
> 
>> 
>> =====================================================
>> 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
> 
> -- 
> Tim Bish
> http://fusesource.com
> http://timbish.blogspot.com/
> 
> 
> 
> 
> 

-- 
View this message in context: 
http://www.nabble.com/Segmentation-fault-while-sending-bytes-messages-tp23175494p23226784.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Reply via email to