List of messageTransfer() Examples

Examples of messageTransfer()

org.apache.qpid.nclient.MessagePartListener.messageTransfer()
Inform the listener of the message transfer @param xfr the message transfer object
org.apache.qpid.nclient.Session.messageTransfer()
Transfer a message to a specified exchange.

This transfer provides a complete message using a single method. The method is internally mapped to messageTransfer() and headers() followed by data() and endData(). This method should only be used by small messages.
@param destination The exchange the message is being sent to. @param msg The Message to be sent. @param confirmMode
- on ( {@link Session#TRANSFER_CONFIRM_MODE_REQUIRED}): an acquired message is not considered transferred until the original transfer is complete. A complete transfer is signaled by execution.complete.
@param acquireMode
- no-acquire ( {@link Session#TRANSFER_ACQUIRE_MODE_NO_ACQUIRE}): the message must be explicitly acquired.
- pre-acquire ( {@link Session#TRANSFER_ACQUIRE_MODE_PRE_ACQUIRE}): the message is acquired when the transfer starts.
@throws java.io.IOException If transferring a message fails due to some internal communication error, an exception is thrown.
org.apache.qpid.nclient.util.MessagePartListenerAdapter.messageTransfer()
org.apache.qpid.transport.Session.messageTransfer()

Examples of org.apache.qpid.nclient.MessagePartListener.messageTransfer()

    // --------------------------------------------
    @Override public void messageTransfer(Session session, MessageTransfer xfr)
    {
        MessagePartListener listener = ((ClientSession)session).getMessageListeners()
            .get(xfr.getDestination());
        listener.messageTransfer(xfr);
    }


    @Override public void messageReject(Session session, MessageReject struct)
    {
        for (Range range : struct.getTransfers())

View Full Code Here

Examples of org.apache.qpid.nclient.Session.messageTransfer()

        DeliveryProperties deliveryProps = new DeliveryProperties();
        deliveryProps.setRoutingKey("routing_key");


        for (int i=0; i<10; i++)
        {
            session.messageTransfer("amq.fanout", MessageAcceptMode.EXPLICIT, MessageAcquireMode.PRE_ACQUIRED,
                                    new Header(deliveryProps), "Message " + i);
        }


        session.messageTransfer("amq.fanout", MessageAcceptMode.EXPLICIT, MessageAcquireMode.PRE_ACQUIRED,
                                new Header(deliveryProps),

View Full Code Here

Examples of org.apache.qpid.nclient.Session.messageTransfer()

        {
            session.messageTransfer("amq.fanout", MessageAcceptMode.EXPLICIT, MessageAcquireMode.PRE_ACQUIRED,
                                    new Header(deliveryProps), "Message " + i);
        }


        session.messageTransfer("amq.fanout", MessageAcceptMode.EXPLICIT, MessageAcquireMode.PRE_ACQUIRED,
                                new Header(deliveryProps),
                                "That's all, folks!");


        // confirm completion
        session.sync();

View Full Code Here

Examples of org.apache.qpid.nclient.Session.messageTransfer()

        DeliveryProperties deliveryProps = new DeliveryProperties();
        deliveryProps.setRoutingKey("routing_key");


        for (int i=0; i<10; i++)
        {
            session.messageTransfer("amq.direct", MessageAcceptMode.EXPLICIT,MessageAcquireMode.PRE_ACQUIRED,
                                    new Header(deliveryProps),
                                    "Message " + i);
        }


        session.messageTransfer("amq.direct", MessageAcceptMode.EXPLICIT, MessageAcquireMode.PRE_ACQUIRED,

View Full Code Here

Examples of org.apache.qpid.nclient.Session.messageTransfer()

            session.messageTransfer("amq.direct", MessageAcceptMode.EXPLICIT,MessageAcquireMode.PRE_ACQUIRED,
                                    new Header(deliveryProps),
                                    "Message " + i);
        }


        session.messageTransfer("amq.direct", MessageAcceptMode.EXPLICIT, MessageAcquireMode.PRE_ACQUIRED,
                                new Header(deliveryProps),
                                "That's all, folks!");


        // confirm completion
        session.sync();

View Full Code Here

Examples of org.apache.qpid.nclient.Session.messageTransfer()

        ssn.sync();


        ssn.messageSubscribe("queue1", "myDest", (short)0, (short)0,createAdapter(), null);


        // queue
        ssn.messageTransfer("amq.direct", MessageAcceptMode.NONE, MessageAcquireMode.PRE_ACQUIRED,
                            new Header(new DeliveryProperties().setRoutingKey("queue1"),
                                       new MessageProperties().setMessageId(UUID.randomUUID())),
                            ByteBuffer.wrap("this is the data".getBytes()));


        //reject

View Full Code Here

Examples of org.apache.qpid.nclient.Session.messageTransfer()

                            new Header(new DeliveryProperties().setRoutingKey("queue1"),
                                       new MessageProperties().setMessageId(UUID.randomUUID())),
                            ByteBuffer.wrap("this is the data".getBytes()));


        //reject
        ssn.messageTransfer("amq.direct", MessageAcceptMode.NONE, MessageAcquireMode.PRE_ACQUIRED,
                            new Header(new DeliveryProperties().setRoutingKey("stocks")),
                            ByteBuffer.wrap("this should be rejected".getBytes()));
        ssn.sync();


        // topic subs

View Full Code Here

Examples of org.apache.qpid.nclient.Session.messageTransfer()

        ssn.queueDeclare("topic3", null, null);
        ssn.exchangeBind("topic3", "amq.topic", "stock.us.rh",null);
        ssn.sync();


        // topic
        ssn.messageTransfer("amq.topic", MessageAcceptMode.NONE, MessageAcquireMode.PRE_ACQUIRED,
                            new Header(new DeliveryProperties().setRoutingKey("stock.us.ibm"),
                                       new MessageProperties().setMessageId(UUID.randomUUID())),
                            ByteBuffer.wrap("Topic message".getBytes()));
    }

View Full Code Here

Examples of org.apache.qpid.nclient.util.MessagePartListenerAdapter.messageTransfer()

        {
            LOGGER.error("unhandled message: %s", xfr);
        }
        else
        {
            l.messageTransfer(xfr);
        }
    }


    
    public void exception(Session ssn, SessionException exc)

View Full Code Here

Examples of org.apache.qpid.nclient.util.MessagePartListenerAdapter.messageTransfer()

        {
            LOGGER.error("unhandled message: %s", xfr);
        }
        else
        {
            l.messageTransfer(xfr);
        }
    }


    
    public void exception(Session ssn, SessionException exc)

View Full Code Here

0 1

TOP

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.