Can you tell what version you're using?
At 2013-01-04 21:26:20,gfshaikh <ghulam.sha...@taxware.com> wrote: >Hi - Thanks for responding I tried that but it didn't work. Any other way to >get the properties ? > >From: SuoNayi [via ActiveMQ] [mailto:ml-node+s2283324n4661335...@n4.nabble.com] >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: >http://activemq.2283324.n4.nabble.com/ActiveMQ-Stream-Messaging-amp-JMS-Properties-td4661193.html >I believe you can obtain the properties that carrying the meta data via call >on the getJMSProperties method >of ActiveMQInputStream. >You may see the jira: >https://issues.apache.org/jira/browse/AMQ-4241 > > > >At 2013-01-04 16:17:21,gfshaikh <[hidden >email]</user/SendEmail.jtp?type=node&node=4661335&i=0>> wrote: > >>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. >> >>Sender >>------- >>FileInputStream in = new FileInputStream( >> "C:\\Temp\\FileName.txt"); >> >> String brokerURI = ActiveMQConnectionFactory.DEFAULT_BROKER_URL; >> ActiveMQConnectionFactory connectionFactory = new >>ActiveMQConnectionFactory( >> brokerURI); >> ActiveMQConnection connection = (ActiveMQConnection) connectionFactory >> .createConnection(); >> connection.start(); >> Session session = connection.createSession(false, >>Session.AUTO_ACKNOWLEDGE); >> Queue destination = session.createQueue(QUEUE_NAME); >> >> Map myMap = new HashMap(); >> myMap.put("invocation", "invocation"); >> ActiveMQOutputStream out = >>(ActiveMQOutputStream)connection.createOutputStream(destination, myMap, >>ActiveMQMessage.DEFAULT_DELIVERY_MODE, ActiveMQMessage.DEFAULT_PRIORITY, >>ActiveMQMessage.DEFAULT_TIME_TO_LIVE); >> // now write the file on to ActiveMQ >> byte[] buffer = new byte[1024]; >> while (true) >> { >> int bytesRead = in.read(buffer); >> if (bytesRead == -1) >> { >> break; >> } >> out.write(buffer, 0, bytesRead); >> } >> out.close(); >> >>Receiver >>--------- >>String brokerURI = ActiveMQConnectionFactory.DEFAULT_BROKER_URL; >>ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory( >> brokerURI); >>ActiveMQConnection connection = (ActiveMQConnection) connectionFactory >> .createConnection(); >>connection.start(); >>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"); >>out.write(myString.getBytes()); >> >>Thanks >> >> >> >>-- >>View this message in context: >>http://activemq.2283324.n4.nabble.com/Sending-Meta-Data-over-Active-MQ-Channel-for-Stream-Messages-tp4661318.html >>Sent from the ActiveMQ - User mailing list archive at Nabble.com. > >________________________________ >If you reply to this email, your message will be added to the discussion below: >http://activemq.2283324.n4.nabble.com/Sending-Meta-Data-over-Active-MQ-Channel-for-Stream-Messages-tp4661318p4661335.html >To unsubscribe from Sending Meta Data over Active MQ Channel(for Stream >Messages), click >here<http://activemq.2283324.n4.nabble.com/template/NamlServlet.jtp?macro=unsubscribe_by_code&node=4661318&code=Z2h1bGFtLnNoYWlraEB0YXh3YXJlLmNvbXw0NjYxMzE4fDE3NjE5NDcwMDU=>. >NAML<http://activemq.2283324.n4.nabble.com/template/NamlServlet.jtp?macro=macro_viewer&id=instant_html%21nabble%3Aemail.naml&base=nabble.naml.namespaces.BasicNamespace-nabble.view.web.template.NabbleNamespace-nabble.view.web.template.NodeNamespace&breadcrumbs=notify_subscribers%21nabble%3Aemail.naml-instant_emails%21nabble%3Aemail.naml-send_instant_email%21nabble%3Aemail.naml> > >---------------------------------------------------------------------- >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 ghulam.sha...@taxware.com 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: >http://activemq.2283324.n4.nabble.com/Sending-Meta-Data-over-Active-MQ-Channel-for-Stream-Messages-tp4661318p4661336.html >Sent from the ActiveMQ - User mailing list archive at Nabble.com.
