activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From SuoNayi <>
Subject Reply:RE: Reply:Sending Meta Data over Active MQ Channel(for Stream Messages)
Date Fri, 04 Jan 2013 13:28:41 GMT
Can you tell what version you're using?

At 2013-01-04 21:26:20,gfshaikh <> wrote:
>Hi - Thanks for responding I tried that but it didn't work. Any other way to get the properties
>From: SuoNayi [via ActiveMQ] []
>Sent: Friday, January 04, 2013 8:25 AM
>To: Shaikh-Contractor, Ghulam (CORP)
>Subject: Reply:Sending Meta Data over Active MQ Channel(for Stream Messages)
>Hi, you have posted the issue some days ago, here is the link:
>I believe you can obtain the properties that carrying the meta data via call on the getJMSProperties
>of ActiveMQInputStream.
>You may see the jira:
>At 2013-01-04 16:17:21,gfshaikh <[hidden email]</user/SendEmail.jtp?type=node&node=4661335&i=0>>
>>Hi All
>>I am trying to figure out this issue for a POC we are doing with ActiveMQ.
>>We are using Output and InputStreams to copy files across from producer to
>>consumer. The files get copied acrosss correctly however we also need to
>>pass some meta data in the form of file names so that the file can be named
>>correctly at the recepient end.
>>The following is some sample code which I am using, appreciate some feedback
>>if someone has a working solution for this issue.
>>FileInputStream in = new FileInputStream(
>>      "C:\\Temp\\FileName.txt");
>>    String brokerURI = ActiveMQConnectionFactory.DEFAULT_BROKER_URL;
>>    ActiveMQConnectionFactory connectionFactory = new
>>      brokerURI);
>>    ActiveMQConnection connection = (ActiveMQConnection) connectionFactory
>>      .createConnection();
>>    connection.start();
>>    Session session = connection.createSession(false,
>>    Queue destination = session.createQueue(QUEUE_NAME);
>>    Map myMap = new HashMap();
>>    myMap.put("invocation", "invocation");
>>    ActiveMQOutputStream out =
>>(ActiveMQOutputStream)connection.createOutputStream(destination, myMap,
>>    // now write the file on to ActiveMQ
>>    byte[] buffer = new byte[1024];
>>    while (true)
>>    {
>>      int bytesRead =;
>>      if (bytesRead == -1)
>>      {
>>        break;
>>      }
>>      out.write(buffer, 0, bytesRead);
>>    }
>>    out.close();
>>String brokerURI = ActiveMQConnectionFactory.DEFAULT_BROKER_URL;
>>ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory(
>>      brokerURI);
>>ActiveMQConnection connection = (ActiveMQConnection) connectionFactory
>>      .createConnection();
>>Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
>>// we want be be an exclusive consumer
>>String exclusiveQueueName = QUEUE_NAME + "?consumer.exclusive=true";
>>Queue destination = session.createQueue(exclusiveQueueName);
>>InputStream in = connection.createInputStream(destination);
>>String myString = IOUtils.toString(in);
>>FileOutputStream out = new FileOutputStream(
>>      "C:\\Temp\\NeedTargetFileName.txt");
>>View this message in context:
>>Sent from the ActiveMQ - User mailing list archive at
>If you reply to this email, your message will be added to the discussion below:
>To unsubscribe from Sending Meta Data over Active MQ Channel(for Stream Messages), click
>This message and any attachments thereto contain information that may be privileged, confidential
or otherwise protected from disclosure and is the property of Taxware, LLC. It is intended
only for the person to whom it is addressed. If you are not the intended recipient, you are
not authorized to read, print, retain, copy, disseminate, distribute, or use this message,
any attachments thereto or any part thereof. If you receive this message in error, please
notify me at  and delete all copies of this message and attachments.
Taxware, LLC. has implemented anti-virus software on its computers and servers, however, it
is the recipient's own responsibility to ensure that all attachments are scanned for viruses
prior to usage.
>View this message in context:
>Sent from the ActiveMQ - User mailing list archive at

  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message