List of basicConsume() Examples

Examples of basicConsume()

com.rabbitmq.client.Channel.basicConsume()
Start a non-nolocal, non-exclusive consumer, with explicit acknowledgement and a server-generated consumerTag. @param queue the name of the queue @param callback an interface to the consumer object @return the consumerTag generated by the server @throws java.io.IOException if an error is encountered @see com.rabbitmq.client.AMQP.Basic.Consume @see com.rabbitmq.client.AMQP.Basic.ConsumeOk @see #basicAck @see #basicConsume(String,boolean,String,boolean,boolean,Map,Consumer)
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
org.springframework.amqp.rabbit.support.PublisherCallbackChannelImpl.basicConsume()

Examples of com.rabbitmq.client.Channel.basicConsume()


        LatencyExperimentConsumer callback = new LatencyExperimentConsumer(channel, queueName);
        callback._autoAck = this._autoAck;


        channel.basicConsume(queueName, _autoAck, callback);
        channel.basicConsume(completionQueue, true, "completion", callback);
        callback.report(_writeStats);


        System.out.println("Deleting test queue.");
        channel.queueDelete(queueName);

View Full Code Here

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

        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 ();

View Full Code Here

Examples of org.springframework.amqp.rabbit.support.PublisherCallbackChannelImpl.basicConsume()

    assertTrue(waitForAll3AcksLatch.await(10, TimeUnit.SECONDS));
    assertEquals(3, acks.get());




    // 3.3.1 client
    channel.basicConsume("foo", false, (Map) null, null);
    verify(mockChannel).basicConsume("foo", false, (Map) null, null);


    channel.basicQos(3, false);
    verify(mockChannel).basicQos(3, false);

View Full Code Here

0 1 2 3 4 5

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.