import com.imou.open.inbox.sdk.*;
import java.io.IOException;

public class MyApp {
    public static void main(String[] args) throws Exception {
        String appId = "你的开发者appId";
        String appSecret = "你的开发者appSecret";
        String gatewayUrl = "https://openapi.lechange.cn/openapi";
        String group = "group1";
        int limit = 100;
        boolean autoCommit = false;
        long intervalMs = 1000L;

        MessageHandler handler = new MessageHandler(autoCommit);
        InboxConsumer consumer = InboxConsumer.builder()
                .appId(appId)
                .appSecret(appSecret)
                .gatewayUrl(gatewayUrl)
                .group(group)
                .limit(limit)
                .autoCommit(autoCommit)
                .intervalMs(intervalMs)
                .messageHandler(handler)
                .build();
        handler.bind(consumer);

        consumer.start();
        Runtime.getRuntime().addShutdownHook(new Thread(consumer::stop));
        Thread.currentThread().join();
    }

    static class MessageHandler implements IMessageHandler {
        private final boolean autoCommit;
        private InboxConsumer consumer;

        MessageHandler(boolean autoCommit) {
            this.autoCommit = autoCommit;
        }

        void bind(InboxConsumer consumer) {
            this.consumer = consumer;
        }

        @Override
        public void onMessages(InboxPullResult pullResult) {
            if (pullResult.isOffsetReset()) {
                // 位点已重置，超过保留期的历史消息可能无法消费
            }
            if (autoCommit) {
                // 异步处理，避免阻塞拉取线程（示例略）
                return;
            }
            for (InboxMessage msg : pullResult.getMessages()) {
                // 按 msg.getMsgType() 处理 msg.getMsgBody()
            }
            // hasMore / count 可按需用于监控或背压
            boolean hasMore = pullResult.isHasMore();
            int count = pullResult.getCount();
            try {
                consumer.commitOffset();
            } catch (IOException | InterruptedException e) {
                throw new IllegalStateException("commitOffset failed", e);
            }
        }
    }
}

String appId = "你的开发者appId";
String appSecret = "你的开发者appSecret";
String gatewayUrl = "https://openapi.lechange.cn/openapi";
String group = "group1";
int limit = 100;
boolean autoCommit = false;   // 联调可改为 true
long intervalMs = 1000L;