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-tp4703724.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Reply via email to