Merge pull request #2 from muverystrong/feat/add-queue-config-api

feat: add queue config get api

Author: nil4u

api/src/main/java/com/theokanning/openai/queue/EventbusConfig.java

@@ -0,0 +1,28 @@
+package com.theokanning.openai.queue;
+
+import com.fasterxml.jackson.annotation.JsonProperty;
+import lombok.AllArgsConstructor;
+import lombok.Builder;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+
+/**
+ * Event bus configuration for queue message publishing and subscription
+ */
+@Data
+@Builder
+@AllArgsConstructor
+@NoArgsConstructor
+public class EventbusConfig {
+
+    /**
+     * Event bus url
+     */
+    private String url;
+
+    /**
+     * Topic name for message routing and subscription
+     */
+    private String topic;
+
+}

client/src/main/java/com/theokanning/openai/client/OpenAiApi.java

@@ -42,6 +42,7 @@
 import com.theokanning.openai.model.Model;
 import com.theokanning.openai.moderation.ModerationRequest;
 import com.theokanning.openai.moderation.ModerationResult;
+import com.theokanning.openai.queue.EventbusConfig;
 import com.theokanning.openai.queue.Register;
 import com.theokanning.openai.queue.Put;
 import com.theokanning.openai.queue.Take;
@@ -378,6 +379,9 @@ public interface OpenAiApi {
     @POST("v1/queue/register")
     Single<String> registerQueue(@Body Register register);
 
+    @GET("v1/queue/eventbus")
+    Single<EventbusConfig> getEventbus();
+
     @POST("v1/queue/put")
     Single<Object> putTask(@Body Put put);
 

service/src/main/java/com/theokanning/openai/service/OpenAiService.java

@@ -51,6 +51,7 @@
 import com.theokanning.openai.model.Model;
 import com.theokanning.openai.moderation.ModerationRequest;
 import com.theokanning.openai.moderation.ModerationResult;
+import com.theokanning.openai.queue.EventbusConfig;
 import com.theokanning.openai.queue.Put;
 import com.theokanning.openai.queue.Register;
 import com.theokanning.openai.queue.Take;
@@ -754,6 +755,10 @@ public String registerQueue(Register register) {
         return execute(api.registerQueue(register));
     }
 
+    public EventbusConfig getEventbus() {
+        return execute(api.getEventbus());
+    }
+
     public Object putTask(Put put) {
         return execute(api.putTask(put));
     }