Strange, I have just written a test case to obtain the properties via call on that method and it works fine. I can recall that Christian has done the test as well.
At 2013-01-04 21:30:08,gfshaikh <ghulam.sha...@taxware.com> wrote: >ActiveMQ 5.7 > >From: SuoNayi [via ActiveMQ] [mailto:ml-node+s2283324n4661338...@n4.nabble.com] >Sent: Friday, January 04, 2013 8:29 AM >To: Shaikh-Contractor, Ghulam (CORP) >Subject: Reply:RE: Reply:Sending Meta Data over Active MQ Channel(for Stream >Messages) > >Can you tell what version you're using? > > > > >At 2013-01-04 21:26:20,gfshaikh <[hidden >email]</user/SendEmail.jtp?type=node&node=4661338&i=0>> 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:[hidden >>email]</user/SendEmail.jtp?type=node&node=4661338&i=1>] >>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: >> >>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 [hidden >>email]</user/SendEmail.jtp?type=node&node=4661338&i=2> 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. > >________________________________ >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-tp4661318p4661338.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-tp4661318p4661339.html >Sent from the ActiveMQ - User mailing list archive at Nabble.com.
