Skip to main content

PullTaskCallback

Trait PullTaskCallback 

Source
pub trait PullTaskCallback:
    Send
    + Sync
    + 'static {
    // Provided method
    fn do_pull_task<'a>(
        &'a self,
        _message_queue: &'a MessageQueue,
        _context: &'a mut PullTaskContext,
    ) -> Pin<Box<dyn Future<Output = ClientResult<()>> + Send + 'a>> { ... }
}
👎Deprecated since 0.9.0:

Java PullTaskCallback is deprecated with MQPullConsumerScheduleService

Provided Methods§

Source

fn do_pull_task<'a>( &'a self, _message_queue: &'a MessageQueue, _context: &'a mut PullTaskContext, ) -> Pin<Box<dyn Future<Output = ClientResult<()>> + Send + 'a>>

👎Deprecated since 0.9.0:

Java PullTaskCallback is deprecated with MQPullConsumerScheduleService

Runs one scheduled pull task for a currently readable queue.

The callback may set the next delay through context. Returning an error applies the schedule service’s bounded retry delay.

Dyn Compatibility§

This trait is dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety".

Implementors§