activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From gfshaikh <ghulam.sha...@taxware.com>
Subject RE: Reply:RE: Reply:Sending Meta Data over Active MQ Channel(for Stream Messages)
Date Fri, 04 Jan 2013 13:30:08 GMT
ActiveMQ  5.7

From: SuoNayi [via ActiveMQ] [mailto:ml-node+s2283324n4661338h89@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.Shaikh@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.
Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message