qpid-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ricardlf <rilo...@dsic.upv.es>
Subject Re: Message and MessageTransfer
Date Tue, 28 Jul 2009 06:50:57 GMT

Hi Jonathan,
I'm using AMQP API because I need to declare exchanges and I didn't find out
how to do this using the JMS interface, if it were possible to declare
exchanges with JMS I'll use it.

Ricard.
 

Jonathan Robie wrote:
> 
> Ricard,
> 
> The Java AMQP API is not widely used, most Java programmers are using 
> the Java JMS interface. It is also not well documented, grepping for 
> "Properties" in the examples can help give you an overview if you really 
> want to use this API (see below).
> 
> I haven't tried this, but I imagine MessageProperties are handled the 
> same way as DeliveryProperties:
> 
> public void message(Session ssn, MessageTransfer xfr)
> {
> DeliveryProperties dp = xfr.getHeader().get(DeliveryProperties.class);
> System.out.println("Message: " + xfr + " with routing_key " + 
> dp.getRoutingKey());
> }
> 
> Here is the overview for handling properties that I got by using grep on 
> the examples:
> 
> $ pwd
> /home/jrobie/qpid/java/client/example/src/main/java/org/apache/qpid/example/amqpexample
> 
> $ grep Properties */*.java
> direct/DirectProducer.java:import 
> org.apache.qpid.transport.DeliveryProperties;
> direct/DirectProducer.java: DeliveryProperties deliveryProps = new 
> DeliveryProperties();
> fanout/FannoutProducer.java:import 
> org.apache.qpid.transport.DeliveryProperties;
> fanout/FannoutProducer.java: DeliveryProperties deliveryProps = new 
> DeliveryProperties();
> headers/Producer.java: DeliveryProperties deliveryProps = new 
> DeliveryProperties();
> headers/Producer.java: MessageProperties messageProperties = new 
> MessageProperties();
> headers/Producer.java: 
> messageProperties.setApplicationHeaders(messageHeaders);
> headers/Producer.java: Header header = new Header(deliveryProps, 
> messageProperties);
> headers/Producer.java: messageProperties = new MessageProperties();
> headers/Producer.java: 
> messageProperties.setApplicationHeaders(messageHeaders);
> headers/Producer.java: header = new Header(deliveryProps, 
> messageProperties);
> lvq/Producer.java: DeliveryProperties deliveryProps = new 
> DeliveryProperties();
> lvq/Producer.java: MessageProperties messageProperties = new 
> MessageProperties();
> lvq/Producer.java:
> messageProperties.setApplicationHeaders(messageHeaders);
> lvq/Producer.java: Header header = new Header(deliveryProps, 
> messageProperties);
> pubsub/TopicListener.java:import 
> org.apache.qpid.transport.DeliveryProperties;
> pubsub/TopicListener.java: DeliveryProperties dp = 
> xfr.getHeader().get(DeliveryProperties.class);
> pubsub/TopicPublisher.java:import 
> org.apache.qpid.transport.DeliveryProperties;
> pubsub/TopicPublisher.java: DeliveryProperties deliveryProps = new 
> DeliveryProperties();
> pubsub/TopicPublisher.java: new Header(new 
> DeliveryProperties().setRoutingKey("control")),
> 
> Hope this helps!
> 
> Jonathan
> 
> 
> ricardlf wrote:
>> Hi,
>> I'm starting to get used to Qpid but there is still something that is not
>> completely clear to me. How do I get message properties of a message? I
>> mean, in the java amqp examples, when the producer sends a message and
>> when
>> the consumer gets it, both use MessageTransfer class objects for sending
>> and
>> getting the message, but this class doesn't have getMessageProperties, so
>> I
>> don't know how to get for example replyTo propertie from an object of
>> this
>> class.
>> I've seen that qpid has a class called Message, but this class doesn't
>> have
>> a body propertie, so I don't know how to put some content in it, and I
>> don't
>> know even if I can send an instance of Message using
>> session.MessageTransfer.
>> Please, could anyone help me with this confussion or tell me where I can
>> find an explanation? Thank you so much.
>>
>> Ricard.
>>   
> 
> 
> ---------------------------------------------------------------------
> Apache Qpid - AMQP Messaging Implementation
> Project:      http://qpid.apache.org
> Use/Interact: mailto:users-subscribe@qpid.apache.org
> 
> 
> 

-- 
View this message in context: http://n2.nabble.com/Message-and-MessageTransfer-tp3333616p3339707.html
Sent from the Apache Qpid users mailing list archive at Nabble.com.

---------------------------------------------------------------------
Apache Qpid - AMQP Messaging Implementation
Project:      http://qpid.apache.org
Use/Interact: mailto:users-subscribe@qpid.apache.org


Mime
View raw message