以下是基于您提供的内容整理的完整示例代码，包含消息发布和订阅重放流的完整实现：

use rusteron_archive::*;
use std::time::Duration;

// 自定义消息处理回调
struct MessageHandler;
impl AeronSubscriptionCallback for MessageHandler {
    fn handle_aeron_subscription(&mut self, msg: &[u8], header: &AeronHeader) {
        println!("Received message: {:?}", msg);
        println!("Header details: {:?}", header);
    }
}

// 错误处理回调
struct ErrorLogger;
impl AeronErrorHandlerCallback for ErrorLogger {
    fn handle_aeron_error_handler(&mut self, errcode: i32, message: &str) {
        eprintln!("Aeron Error ({}): {}", errcode, message);
    }
}

fn main() -> Result<(), AeronCError> {
    // 1. 初始化Aeron上下文
    let aeron = Aeron::new("aeron:ipc")?;
    
    // 2. 初始化归档上下文
    let archive = AeronArchive::new(&aeron, "aeron:ipc")?;
    
    // 3. 设置错误处理程序
    let error_handler = Handlers::leak(ErrorLogger);
    archive.set_error_handler(error_handler)?;
    
    // 4. 开始记录流
    let channel = "aeron:ipc";
    let stream_id = 10;
    let recording_id = archive.start_recording(channel, stream_id)?;
    println!("Started recording with ID: {}", recording_id);
    
    // 5. 创建发布者并发布消息
    let publication = aeron.add_publication(channel, stream_id)?;
    
    // 发布10条测试消息
    for i in 0..10 {
        let message = format!("Test message {}", i).into_bytes();
        match publication.offer(&message) {
            Ok(position) => println!("Message {} published at position {}", i, position),
            Err(AeronCError { error_type: AeronErrorType::PublicationBackPressured, .. }) => {
                println!("Back pressured, retrying...");
                std::thread::sleep(Duration::from_millis(100));
                continue;
            }
            Err(e) => return Err(e),
        }
    }
    
    // 6. 停止记录
    archive.stop_recording(recording_id)?;
    println!("Stopped recording");
    
    // 7. 定位记录
    let recording_descriptor = archive.find_recording(recording_id)?;
    println!("Found recording: {:?}", recording_descriptor);
    
    // 8. 设置重放
    let replay_channel = "aeron:ipc";
    let replay_stream_id = 20;
    let replay_session_id = archive.start_replay(
        recording_id,
        0,          // 起始位置
        u64::MAX,   // 结束位置
        replay_channel,
        replay_stream_id
    )?;
    println!("Started replay with session ID: {}", replay_session_id);
    
    // 9. 订阅重放流
    let subscription = aeron.add_subscription(replay_channel, replay_stream_id)?;
    let message_handler = Handlers::leak(MessageHandler);
    subscription.set_handler(message_handler)?;
    
    // 10. 轮询接收消息
    println!("Waiting for replayed messages...");
    for _ in 0..10 {
        subscription.poll(Duration::from_secs(1))?;
    }
    
    // 11. 清理资源
    subscription.release_handler()?;
    aeron.remove_publication(publication)?;
    aeron.remove_subscription(subscription)?;
    
    Ok(())
}

这个完整示例展示了以下工作流程：

1. 初始化Aeron和归档上下文
2. 设置错误处理程序
3. 开始记录指定通道和流的消息
4. 创建发布者并发布10条测试消息
5. 停止记录
6. 定位并查询记录信息
7. 设置重放参数(起始/结束位置、目标通道和流ID)
8. 订阅重放流并设置消息处理回调
9. 轮询接收重放的消息
10. 最后清理资源

关键点说明：

• 使用了完整的消息发布/订阅流程
• 处理了背压(back pressure)情况
• 包含了资源清理逻辑
• 使用Duration控制轮询超时
• 展示了错误处理的完整模式

当运行此程序时，您将看到:

1. 10条消息被成功发布
2. 相同的10条消息被重放并接收
3. 每个消息的详细信息和头部信息会被打印出来