lib/src/main/java/edu/utexas/tacc/tapis/files/lib/services/TransfersService.java
public Flux<AcknowledgableDelivery> streamChildMessages() {
        ConsumeOptions options = new ConsumeOptions();
        options.qos(1000);
        QueueSpecification childSpec = QueueSpecification.queue(CHILD_QUEUE)
            .durable(true)
            .autoDelete(false);
        return receiver.consumeManualAck(CHILD_QUEUE, options)
            .delaySubscription(sender.declareQueue(childSpec));
    }
/**
     * This method listens on the CHILD_QUEUE and creates a Flux<AcknowledgableDelivery> that
     * we can push through the transfers workflow
     *
     * @return A flux of messages
     */
This method listens on the CHILD_QUEUE and creates a Flux that
we can push through the transfers workflow

@return A flux of messages
This method listens on the CHILD_QUEUE and creates a Flux that we can push through the transfers workflow @return A flux of messages
public Flux<AcknowledgableDelivery> streamChildMessages() {
        ConsumeOptions options = new ConsumeOptions();
        options.qos(1000);
        QueueSpecification childSpec = QueueSpecification.queue(CHILD_QUEUE)
            .durable(true)
            .autoDelete(false);
        return receiver.consumeManualAck(CHILD_QUEUE, options)
            .delaySubscription(sender.declareQueue(childSpec));
    }
public Flux < AcknowledgableDelivery > streamChildMessages ( ) { ConsumeOptions options = new ConsumeOptions ( ) ; options . qos ( 1000 ) ; QueueSpecification childSpec = QueueSpecification . queue ( CHILD_QUEUE ) . durable ( true ) . autoDelete ( false ) ; return receiver . consumeManualAck ( CHILD_QUEUE , options ) . delaySubscription ( sender . declareQueue ( childSpec ) ) ; }
This method listens on the CHILD_QUEUE and creates a Flux<AcknowledgableDelivery> that
 we can push through the transfers workflow
This method listens on the CHILD_QUEUE and creates a Flux<AcknowledgableDelivery > that we can push through the transfers workflow