Examples of eu.mosaic_cloud.drivers.queue.amqp.AmqpDriver.basicConsume()

eu.mosaic_cloud.drivers.queue.amqp.AmqpDriver.basicConsume()

Start a message consumer. @param queue the name of the queue @param consumer a client-generated consumer tag to establish context @param exclusive true if this is an exclusive consumer @param autoAck true if the server should consider messages acknowledged once delivered; false if the server should expect explicit acknowledgments @param extra @param consumeCallback the consumer callback (this will called when the queuing system will send Consume messages) @param complHandler handlers to be called when the operation finishes @return the client-generated consumer tag to establish context

        autoAck = cop.getAutoAck ();
        AmqpStub.logger.trace ("AmqpStub - Received request for CONSUME"); // $NON-NLS-1$
        // NOTE: execute operation
        final DriverOperationFinishedHandler consHandler = new DriverOperationFinishedHandler (token, session);
        final IAmqpConsumer consumeCallback = new ConsumerHandler (session);
        resultString = driver.basicConsume (queue, consumer, exclusive, autoAck, consumeCallback, consHandler);
        consHandler.setDetails (AmqpOperations.CONSUME, resultString);
        break;
      case GET_REQUEST :
        final AmqpPayloads.GetRequest gop = (GetRequest) message.payload;
        token = gop.getToken ();

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.