http://docs.oracle.com/javaee/5/api/javax/jms/MessageProducer.html#setPriority(int)
On Tue, Mar 4, 2014 at 11:57 AM, Li Li <fancye...@gmail.com> wrote:
> I am using the following code snippet to send messages to a queue. How
> to make priority queue enabled?
> class Producer{
> private ActiveMQConnection conn;
> private QueueSender sender;
> private QueueSession session;
> public Producer() throws JMSException{
> ActiveMQConnectionFactory connectionFactory = new
> ActiveMQConnectionFactory(
> "tcp://localhost:61616");
> conn = (ActiveMQConnection) connectionFactory.createConnection();
> conn.start();
> session = conn.createQueueSession(false, Session.AUTO_ACKNOWLEDGE);
>
> Queue queue = session.createQueue("TEST.QUEUE");
>
> sender = session.createSender(queue);
> sender.setDeliveryMode(DeliveryMode.PERSISTENT);
> }
> public void sendMsgs(int max) throws JMSException{
> //sender.setTimeToLive(10000);
> for(int i=0;i<max;i++){
> Message msg=session.createTextMessage("msg"+i);
> sender.send(msg);
> }
> }
> public void close(){
> if(this.session!=null){
> try {
> session.close();
> } catch (JMSException e) {
> e.printStackTrace();
> }
> }
> if(this.conn!=null){
> try {
> this.conn.close();
> } catch (JMSException e) {
> e.printStackTrace();
> }
> }
> }
> }
>
> On Mon, Mar 3, 2014 at 9:59 PM, Christian Posta
> <christian.po...@gmail.com> wrote:
> > If you build your broker using the java API you can do this by
> > creating the policy entry and using its setters directly.
> >
> > Is that what you're asking? Otherwise you set the priority on a
> > message by using the JMS APIs.
> >
> > On Mon, Mar 3, 2014 at 3:39 AM, Li Li <fancye...@gmail.com> wrote:
> >> as in http://activemq.apache.org/how-can-i-support-priority-queues.html
> ,
> >> I should enable queue priority by xml configuration. is it possible to
> >> use java api to configure this?
> >
> >
> >
> > --
> > Christian Posta
> > http://www.christianposta.com/blog
> > twitter: @christianposta
>
