# java-ws-stomp

**Repository Path**: cyms/java-ws-stomp

## Basic Information

- **Project Name**: java-ws-stomp
- **Description**: Java for Web Socket Stomp Protocol Library.
- **Primary Language**: Unknown
- **License**: MIT
- **Default Branch**: master
- **Homepage**: None
- **GVP Project**: No

## Statistics

- **Stars**: 1
- **Forks**: 1
- **Created**: 2021-05-10
- **Last Updated**: 2021-09-26

## Categories & Tags

**Categories**: Uncategorized

**Tags**: None

## README

# Web Socket Stomp Protocol For Java

## Connect
```
StompClient client = new StompClientBuilder()
    .url("...")                 // 服务地址
    .heartbeat(0, 0)            // 心跳配置
    .isRetry(true)              // 是否断开后重连
    .connectHeaders(...)        // 连接头配置
    .disconnectHeaders(...)     // 断开头配置
    .onConnected(message -> {
        String body = MessageConvertor.fromMessage(message);
        ...
    })                          // 连接成功回调
    .onDisconnected(() -> {})   // 断开成功回调
    .onError(ex -> {})          // 发生错误回调
    .build();
// connect {@link StompHeaders}
client.connect(headers);
```

## Disconnect
```
client.disconnect(headers)
```

## Subscribe / Unsubscribe
```
StompSubscription topicSubscription = this.client.subscribe("/topic/{Initail-}/msg", getHeaders(), response -> {
    LOG.info("/topic/msg response: ");
    LOG.info("command: {}", response.getCommand());
    LOG.info("headers: {}", response.getHeaders().toString());
    LOG.info("payload: {}", StringMessageConverter.fromMessage(response));
});
topicSubscription.unsubscribe(headers);
```