Package com.bytedesk.core.message

Class MessageSocketService

java.lang.Object

com.bytedesk.core.message.MessageSocketService

@Service
public class MessageSocketService
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
private final MqttMessageIdService	mqttMessageIdService
private final MqttSessionService	mqttSessionService
private final org.springframework.messaging.simp.SimpMessagingTemplate	simpMessagingTemplate
private final TopicService	topicService

Constructor Summary

Constructors

Constructor	Description
MessageSocketService()

Method Summary

Modifier and Type	Method	Description
private void	doSendMessage(String topic, MessageProto.Message messageProto, String clientId)
private void	doSendToSubscribers(String topic, MessageProto.Message messageProto)
void	sendJsonMessage(String messageJson)
void	sendProtoMessage(MessageProto.Message messageProto)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

simpMessagingTemplate

private final org.springframework.messaging.simp.SimpMessagingTemplate simpMessagingTemplate

mqttMessageIdService

private final MqttMessageIdService mqttMessageIdService

mqttSessionService

private final MqttSessionService mqttSessionService

topicService

private final TopicService topicService

Constructor Details

MessageSocketService

public MessageSocketService()

Method Details

sendJsonMessage

public void sendJsonMessage(@NonNull
 String messageJson)

sendProtoMessage

public void sendProtoMessage(@NonNull
 MessageProto.Message messageProto)

doSendToSubscribers

private void doSendToSubscribers(String topic,
 @NonNull
 MessageProto.Message messageProto)

doSendMessage

private void doSendMessage(String topic,
 @NonNull
 MessageProto.Message messageProto,
 String clientId)