CMS cannot receive the file content from JMS create BlobMessage contains file content

[MathxH]

System Enviroment: 

1.ActiveMQ broker version is 5.9.1   
2.CMS  version is 3.9.0  ---------------this version support BlobMessage 
3.JMS version is 1.1 


4. (1)java version is 1.8.0_40 
    (2)java TM  SE rumtime enviroment (build 1.8.0_40-b26) 
    (3)java HotSpot b4-bit server VM (build 25.40-b25,mixed mode) 

*************************************************************** 

Here is details: 

I need to  transfer big files between different language clients (JMS and
CMS) with ActiveMQ,then, the issue comes to show: 
    I use JMS create BlobMessage to send it with file.(producer) and use CMS
receive this BlobMessage(consumer) , CMS cannot get the file content.  I am
pretty sure that BlobMessage has sent to broker successfully and CMS can
receive this blobmessage (because I can get related Message Properties from
JMS),BUT!!,    CMS cannot get file Content. 

JMS code snippet as follows: 

 *       BlobMessage blobMessage = session.createBlobMessage(file); 
  
        blobMessage.setStringProperty("FILE.NAME", file.getName()); 
  
        blobMessage.setLongProperty("FILE.SIZE", file.length()); 
  
        System.out.println("start send file：" + file.getName() + "，file
size：" 
  
                + file.length() + " bytes"); 
  
        producer.send(blobMessage); 
  
        System.out.println("send complete：" + file.getName()); 
  
        producer.close(); 
  
        session.close(); 
  
        connection.close(); 
*

CMS code snippet as follows: 

*
void onMessage( const Message* message ) { 
  
      commands::ActiveMQBlobMessage* blobMessage =
dynamic_cast<commands::ActiveMQBlobMessage*>(message); 

                if (blobMessage) 
                { 
                        commands::Message* cmdMsg =
(commands::Message*)blobMessage; 
                        if (cmdMsg) 
                        { 
                                std::vector<unsigned char> properties =
cmdMsg->getMarshalledProperties(); 
                                LIST_PROPERTIES  lstProperties; 
                                int nErr = ParseProperties(properties,
lstProperties); 
                                if (nErr == 0) 
                                { 
                                        // get related properties 
                                        getMessageHeader(lstProperties,
header, nFileSize); 

                                        
                                        if (nFileSize > 0) 
                                        { 
                                                // get file content,but 
vector fileContent size is always 
zero    
                                                std::vector<unsigned char>
fileContent; 
                                                fileContent =
blobMessage->getContent(); 
                                        } 
                                } 
                        } 
                } 
    } 
*



--
View this message in context: 
http://activemq.2283324.n4.nabble.com/CMS-cannot-receive-the-file-content-from-JMS-create-BlobMessage-contains-file-content-tp4703725.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.