MessagePushService (muyan-platform 0.23-SNAPSHOT API)

tech.muyan.message.MessagePushService

All Implemented Interfaces and Traits:

org.springframework.boot.ApplicationRunner, MessageListener<Message>
```
@groovy.util.logging.Slf4j
class MessagePushService
extends java.lang.Object
implements org.springframework.boot.ApplicationRunner, MessageListener<Message>
```
date:
28/9/21

Authors:
Xiang Qian Liu(xiangqian.liu@muyan.cloud)

Nested Class Summary

Nested classes
Modifiers	Name	Description
`class`	`MessagePushService.1`

Field Summary

Fields
Modifiers	Name	Description
`static long`	`MessagePushBundleTimeInMS`
`static ConcurrentHashMap<java.lang.String, java.lang.Long>`	`lastPushTime`
`static ConcurrentHashMap<java.lang.String, java.util.Collection<Message>>`	`pendingMessages`
`static ConcurrentHashMap<java.lang.String, java.util.Collection<WebSocketSession>>`	`sessions`	对于用户打开多个浏览器窗口或者 tab, 每个浏览器的窗口或者 tab 是一个 webSocket Session 推送时, 所有的浏览器窗口或者 tab 都会收到消息推送

Properties Summary

Properties
Type	Name and description
`MessageDataService`	`messageDataService`
`RedissonService`	`redissonService`
`UserDataService`	`userDataService`

Constructor Summary

Constructors
Constructor and description
`MessagePushService ()`

Methods Summary

Methods
Type Params	Return Type	Name and description
	`static java.lang.String`	`getGroupKey(java.lang.String username, java.io.Serializable tenantId)`
	`java.util.Map<java.lang.String, java.lang.Object>`	`getSummary(java.lang.String username, java.io.Serializable tenantId)`
	`void`	`internalPush(java.lang.String username, java.io.Serializable tenant)`
	`void`	`onMessage(java.lang.CharSequence channel, Message message)`
	`void`	`registerNewSession(WebSocketContext context, org.springframework.web.socket.WebSocketSession webSocketSession)`
	`void`	`removeSession(org.springframework.web.socket.WebSocketSession session)`
	`void`	`run(org.springframework.boot.ApplicationArguments args)`

Inherited Methods Summary

Inherited Methods
Methods inherited from class	Name
`class java.lang.Object`	`java.lang.Object#getClass(), java.lang.Object#wait(), java.lang.Object#wait(long), java.lang.Object#wait(long, int), java.lang.Object#hashCode(), java.lang.Object#equals(java.lang.Object), java.lang.Object#notifyAll(), java.lang.Object#toString(), java.lang.Object#notify()`

- Field Detail
  - public static final long MessagePushBundleTimeInMS
  - public static final ConcurrentHashMap<java.lang.String, java.lang.Long> lastPushTime
  - public static final ConcurrentHashMap<java.lang.String, java.util.Collection<Message>> pendingMessages
  - public static final ConcurrentHashMap<java.lang.String, java.util.Collection<WebSocketSession>> sessions
    
    对于用户打开多个浏览器窗口或者 tab, 每个浏览器的窗口或者 tab 是一个 webSocket Session 推送时, 所有的浏览器窗口或者 tab 都会收到消息推送
- Property Detail
  - MessageDataService messageDataService
  - RedissonService redissonService
  - UserDataService userDataService
- Constructor Detail
  - MessagePushService()
- Method Detail
  - static java.lang.String getGroupKey(java.lang.String username, java.io.Serializable tenantId)
  - java.util.Map<java.lang.String, java.lang.Object> getSummary(java.lang.String username, java.io.Serializable tenantId)
  - void internalPush(java.lang.String username, java.io.Serializable tenant)
  - @java.lang.Override void onMessage(java.lang.CharSequence channel, Message message)
  - void registerNewSession(WebSocketContext context, org.springframework.web.socket.WebSocketSession webSocketSession)
  - void removeSession(org.springframework.web.socket.WebSocketSession session)
  - @java.lang.Override @java.lang.SuppressWarnings(value: unchecked) void run(org.springframework.boot.ApplicationArguments args)

Groovy Documentation

[Groovy] Class MessagePushService

Nested Class Summary

Field Summary

Properties Summary

Constructor Summary

Methods Summary

Inherited Methods Summary

Field Detail

public static final long MessagePushBundleTimeInMS

public static final ConcurrentHashMap<java.lang.String, java.lang.Long> lastPushTime

public static final ConcurrentHashMap<java.lang.String, java.util.Collection<Message>> pendingMessages

public static final ConcurrentHashMap<java.lang.String, java.util.Collection<WebSocketSession>> sessions

Property Detail

MessageDataService messageDataService

RedissonService redissonService

UserDataService userDataService

Constructor Detail

MessagePushService()

Method Detail

static java.lang.String getGroupKey(java.lang.String username, java.io.Serializable tenantId)

java.util.Map<java.lang.String, java.lang.Object> getSummary(java.lang.String username, java.io.Serializable tenantId)

void internalPush(java.lang.String username, java.io.Serializable tenant)

@java.lang.Override void onMessage(java.lang.CharSequence channel, Message message)

void registerNewSession(WebSocketContext context, org.springframework.web.socket.WebSocketSession webSocketSession)

void removeSession(org.springframework.web.socket.WebSocketSession session)

@java.lang.Override @java.lang.SuppressWarnings(value: unchecked) void run(org.springframework.boot.ApplicationArguments args)