compile "kr.jadekim.rxjava:rxjava-websocket-client:$version"

//or

implementation "kr.jadekim.rxjava:rxjava-websocket-client:$version"

public interface TestClient {
    
    @Channel
    Flowable<String> subscribeAll();
    
    @Channel(value="channel1", filter=RemainderFilter.class)
    Observable<ResponseModel> subscribeChannel1(@Name("dividerValue") int dividerValue,
                                                @Name("remainderValue") int remainderValue);
    
    @Channel(
        value="channel2",
        filter=RemainderFilter.class,
        onStart="requestNumber2(interval, start)",
        onStop="stopNumber2(interval, start)"
    )
    @Params(
        @Param(name="interval", value="1")
    )
    Flowable<ResponseModel> subscribeChannel2(@Name("start") int start,
                                              @Name("dividerValue") int dividerValue,
                                              @Name("remainderValue") int remainderValue);
    
    @Message
    Completable sendMessage(String message);
    
    @Message("requestNumber")
    Completable requestNumber(@Name("interval") int interval);
    
    @Message("requestNumber")
    Completable requestNumber2(@Name("interval") int interval,
                               @Name("startNumber") int startNumber);
    
    @Message("stopNumber")
    Completable stopNumber2(@Name("interval") int interval,
                            @Name("startNumber") int startNumber);
    
    // If method name is 'disconnect', it will be working 'disconnect' action
    void disconnect();
}

JWebSocket webSocketClientFactory = new JWebSocket.Builder().build();
TestClient client = webSocketClientFactory.create(TestClient.class, "ws://localhost/ws");
client.subscribeAll().subscribe(msg -> System.out.println(msg));

@WebSocketClient(
    url = "wss://echo.websocket.org"
)
public interface TestClient {...}

TestClient client = JWebSocket.create(TestClient.class);

public class OkHttpConnectionFactory implements ConnectionFactory {
    ...
    public OkHttpConnectionFactory(OkHttpClient okHttpClient) {
        ...
    }
    
    @Override
    public Connection connect(String url, boolean isErrorPropagation, WebSocketEventListener listener) {
        ...
    }
}

OkHttpClient httpClient = new OkHttpClient();
ConnectionFactory connectionFactory = new OkHttpConnectionFactory(httpClient);

public abstract class GsonInboundParser implements InboundParser<JsonElement> {
    ...
    public GsonInboundParser(Gson gson) {
        ...
    }
    
    public abstract String getChannelName(JsonElement data);
    
    @Override
    public Inbound<JsonElement> parse(String message) {
        ...
    }
    
    @Override
    public <Model> Model mapping(JsonElement object, Type modelType) {
        ...
    }
}

Gson gson = new Gson();

InboundParser parser = new GsonInboundParser(gson) {

    @Override
    public String getChannelName(JsonElement data) {
        return data.getAsJsonObject().get("channel").getAsString(); 
    }
};

public class GsonOutboundSerializer implements OutboundSerializer {
    ...
    public GsonOutboundSerializer(Gson gson) {
        ...
    }

    @Override
    public String serialize(String messageType, Map<String, Object> parameterMap) {
        ...
    }
}

Gson gson = new Gson();
OutboundSerializer serializer = new GsonOutboundSerializer(gson);

JWebSocket webSocketClientFactory = new JWebSocket.Builder()
                .connectionFactory(connectionFactory)
                .parser(parser)
                .serializer(serializer)
                .lazy(false)
                .errorPropagation(true)
                .build();
                
TestClient client = webSocketClientFactory.create(TestClient.class, "ws://localhost/ws");

@WebSocketClient(
    url = "wss://echo.websocket.org",
    connectionFactory = OkHttpConnectionFactory.class,
    parser = DefaultInboundParser.class,
    serializer = DefaultOutboundSerializer.class,
    listener = SimpleWebSocketEventListener.class,
    isLazy = false,
    isErrorPropagation = true
)
public interface TestClient {...}

TestClient client = JWebSocket.create(TestClient.class);