Functions — github.com/daoshenzzg/socket-mqtt

hub / github.com/daoshenzzg/socket-mqtt / functions

Functions418 in github.com/daoshenzzg/socket-mqtt

⨍ Functions 418◇ Types & classes 80

↓ 2 callersMethodsetBody

(Map<String, Object> body)

src/main/java/com/yb/socket/pojo/protocol/ProtocolRequest.java:60

↓ 2 callersMethodsetCenterAddr

(String centerAddr)

src/main/java/com/yb/socket/service/server/Server.java:468

↓ 2 callersMethodsetChannel

(WrappedChannel channel)

src/main/java/com/yb/socket/service/client/BaseClient.java:213

↓ 2 callersMethodsetConnectTimeout

(int connectTimeout)

src/main/java/com/yb/socket/service/client/BaseClient.java:189

↓ 2 callersMethodsetCurChannelNum

(long curChannelNum)

src/main/java/com/yb/socket/count/CountInfo.java:47

↓ 2 callersMethodsetIp

(String ip)

src/main/java/com/yb/socket/service/Service.java:229

↓ 2 callersMethodsetOpenCount

(boolean openCount)

src/main/java/com/yb/socket/service/server/Server.java:440

↓ 2 callersMethodsetPayload

(byte[] payload)

src/main/java/com/yb/socket/pojo/MqttRequest.java:36

↓ 2 callersMethodsetQos

(MqttQoS qos)

src/main/java/com/yb/socket/pojo/MqttRequest.java:58

↓ 2 callersMethodsetReserved

(byte[] reserved)

src/main/java/com/yb/socket/pojo/protocol/ProtocolResponse.java:61

↓ 2 callersMethodsetVersion

(byte version)

src/main/java/com/yb/socket/pojo/protocol/ProtocolResponse.java:37

↓ 2 callersMethodsetVersion

(byte version)

src/main/java/com/yb/socket/pojo/protocol/ProtocolRequest.java:28

↓ 2 callersMethodunSubscribe

取消订阅 @param clientId @param topic

src/test/java/com/yb/socket/push/server/SubscribeServer.java:41

↓ 2 callersMethodwrite

(Object message)

src/main/java/com/yb/socket/service/WrappedChannel.java:264

↓ 1 callersMethodbind

()

src/main/java/com/yb/socket/status/StatusServer.java:46

↓ 1 callersMethodbytesBeforeUnwritable

()

src/main/java/com/yb/socket/service/WrappedChannel.java:345

↓ 1 callersMethodchannelIsValid

(Client client)

src/main/java/com/yb/socket/service/center/ServerStateReportJob.java:74

↓ 1 callersMethodcloseFuture

()

src/main/java/com/yb/socket/service/WrappedChannel.java:124

↓ 1 callersMethodconnect

(WrappedChannel channel, MqttConnectMessage msg)

src/main/java/com/yb/socket/listener/DefaultMqttMessageEventListener.java:52

↓ 1 callersMethodcreateRSAKeyPair

()

src/main/java/com/yb/socket/encrypt/RSAEncrypt.java:50

↓ 1 callersMethodcreateTable

(InputStream is)

src/main/java/com/yb/socket/datasource/HsqlDataSource.java:106

↓ 1 callersMethoddecode

解码 @param buffer @return @throws Exception

src/main/java/com/yb/socket/codec/protocol/Protocol.java:84

↓ 1 callersMethoddecrypt

(byte[] src)

src/main/java/com/yb/socket/encrypt/AESEncrypt.java:34

↓ 1 callersMethodderegister

()

src/main/java/com/yb/socket/service/WrappedChannel.java:154

↓ 1 callersMethoddisConnect

(WrappedChannel channel, MqttMessage msg)

src/main/java/com/yb/socket/listener/DefaultMqttMessageEventListener.java:80

↓ 1 callersMethoddoGetConfig

()

src/main/java/com/yb/socket/status/StatusMessageEventListener.java:106

↓ 1 callersMethoddoGetStatus

()

src/main/java/com/yb/socket/status/StatusMessageEventListener.java:67

↓ 1 callersMethodencode

编码 @param msg @return @throws Exception

src/main/java/com/yb/socket/codec/protocol/Protocol.java:29

↓ 1 callersMethodencrypt

(byte[] src)

src/main/java/com/yb/socket/encrypt/AESEncrypt.java:26

↓ 1 callersMethodencrypt

(byte[] src)

src/main/java/com/yb/socket/encrypt/RSAEncrypt.java:36

↓ 1 callersMethodexceptionCaught

异常捕获 @param ctx @param channel @param cause @return

src/main/java/com/yb/socket/listener/ExceptionEventListener.java:24

↓ 1 callersMethodformatResultMap

(Map<String, Object> resultMap)

src/main/java/com/yb/socket/status/StatusMessageEventListener.java:52

↓ 1 callersMethodgetAddressByCenter

()

src/main/java/com/yb/socket/service/client/Client.java:103

↓ 1 callersMethodgetAllIdleTimeSeconds

()

src/main/java/com/yb/socket/service/Service.java:313

↓ 1 callersMethodgetBody

()

src/main/java/com/yb/socket/pojo/protocol/ProtocolResponse.java:65

↓ 1 callersMethodgetChannelByTopic

根据主题查询订阅者 @param topic @return @throws SQLException

src/test/java/com/yb/socket/push/server/SubscribeServer.java:63

↓ 1 callersMethodgetCorePoolSize

()

src/main/java/com/yb/socket/service/Service.java:265

↓ 1 callersMethodgetCurChannelNum

()

src/main/java/com/yb/socket/count/CountInfo.java:43

↓ 1 callersMethodgetFutures

()

src/main/java/com/yb/socket/service/WrappedChannel.java:81

↓ 1 callersMethodgetMaxChannelNum

()

src/main/java/com/yb/socket/count/CountInfo.java:54

↓ 1 callersMethodgetMaximumPoolSize

()

src/main/java/com/yb/socket/service/Service.java:273

↓ 1 callersMethodgetProxyedConnection

(Object obj, LinkedList<Connection> connectionPool)

src/main/java/com/yb/socket/datasource/HsqlDataSource.java:197

↓ 1 callersMethodgetQos

()

src/main/java/com/yb/socket/pojo/MqttRequest.java:54

↓ 1 callersMethodgetQueueCapacity

()

src/main/java/com/yb/socket/service/Service.java:281

↓ 1 callersMethodgetReserved

()

src/main/java/com/yb/socket/pojo/protocol/ProtocolResponse.java:57

↓ 1 callersMethodgetReserved

()

src/main/java/com/yb/socket/pojo/protocol/ProtocolRequest.java:48

↓ 1 callersMethodgetServiceName

()

src/main/java/com/yb/socket/service/server/Server.java:412

↓ 1 callersMethodgetStartTime

()

src/main/java/com/yb/socket/service/server/Server.java:420

↓ 1 callersMethodgetVersion

()

src/main/java/com/yb/socket/pojo/protocol/ProtocolRequest.java:24

↓ 1 callersMethodgetWriterIdleTimeSeconds

()

src/main/java/com/yb/socket/service/Service.java:305

↓ 1 callersMethodhasRegisteredToCenter

()

src/main/java/com/yb/socket/service/server/Server.java:408

↓ 1 callersMethodinit

()

src/main/java/com/yb/socket/service/client/BaseClient.java:59

↓ 1 callersMethodinit

()

src/main/java/com/yb/socket/service/server/Server.java:128

↓ 1 callersMethodinit

()

src/main/java/com/yb/socket/status/StatusServer.java:32

↓ 1 callersMethodinitMap

()

src/main/java/com/yb/socket/codec/protocol/MessageTypeEnum.java:24

↓ 1 callersMethodinnerClose

()

src/main/java/com/yb/socket/service/WrappedChannel.java:328

↓ 1 callersMethodinsert

(QueryRunner qr)

src/test/java/com/yb/socket/push/database/DatabaseTest.java:39

↓ 1 callersMethodisDup

()

src/main/java/com/yb/socket/pojo/MqttRequest.java:76

↓ 1 callersMethodisKeepAlive

()

src/main/java/com/yb/socket/service/Service.java:233

↓ 1 callersMethodisRetained

()

src/main/java/com/yb/socket/pojo/MqttRequest.java:45

↓ 1 callersMethodisTcpNoDelay

()

src/main/java/com/yb/socket/service/Service.java:241

↓ 1 callersMethodisWritable

()

src/main/java/com/yb/socket/service/WrappedChannel.java:199

↓ 1 callersMethodjsonToMap

(String str)

src/main/java/com/yb/socket/codec/protocol/Protocol.java:142

↓ 1 callersMethodnotifyListener

(InvokeFutureListener listener)

src/main/java/com/yb/socket/future/InvokeFuture.java:54

↓ 1 callersMethodpingReq

(WrappedChannel channel, MqttMessage msg)

src/main/java/com/yb/socket/listener/DefaultMqttMessageEventListener.java:65

↓ 1 callersMethodprocessRequest

(ChannelHandlerContext ctx, WrappedChannel channel, Request request)

src/main/java/com/yb/socket/listener/DefaultMessageEventListener.java:40

↓ 1 callersMethodprocessResponse

(ChannelHandlerContext ctx, Response response, WrappedChannel channel)

src/main/java/com/yb/socket/listener/DefaultMessageEventListener.java:43

↓ 1 callersMethodpublish

(WrappedChannel channel, MqttPublishMessage msg)

src/test/java/com/yb/socket/service/mqtt/EchoMessageEventListener.java:18

↓ 1 callersMethodpublish

(WrappedChannel channel, MqttPublishMessage msg)

src/test/java/com/yb/socket/push/server/TestMqttMessageEventListener.java:83

↓ 1 callersMethodpublish

(WrappedChannel channel, MqttPublishMessage msg)

src/main/java/com/yb/socket/listener/DefaultMqttMessageEventListener.java:90

↓ 1 callersMethodremoteAddress

()

src/main/java/com/yb/socket/service/WrappedChannel.java:249

↓ 1 callersMethodsendWithSync

(Request message)

src/main/java/com/yb/socket/service/client/BaseClient.java:171

↓ 1 callersMethodsetApp

(ApplicationContext app)

src/test/java/com/yb/socket/push/server/ServerContext.java:26

↓ 1 callersMethodsetBodyLength

(int bodyLength)

src/main/java/com/yb/socket/pojo/protocol/ProtocolResponse.java:53

↓ 1 callersMethodsetBodyLength

(int bodyLength)

src/main/java/com/yb/socket/pojo/protocol/ProtocolRequest.java:44

↓ 1 callersMethodsetCause

(Throwable cause)

src/main/java/com/yb/socket/pojo/Response.java:26

↓ 1 callersMethodsetCenterAddr

(String centerAddr)

src/main/java/com/yb/socket/service/client/Client.java:222

↓ 1 callersMethodsetChannel

(Channel channel)

src/main/java/com/yb/socket/future/InvokeFuture.java:139

↓ 1 callersMethodsetDriverClassName

(String driverClassName)

src/main/java/com/yb/socket/datasource/HsqlDataSource.java:233

↓ 1 callersMethodsetKeepAlive

(boolean keepAlive)

src/main/java/com/yb/socket/service/Service.java:237

↓ 1 callersMethodsetLastReceive

(long lastReceive)

src/main/java/com/yb/socket/count/CountInfo.java:74

↓ 1 callersMethodsetLastSent

(long lastSent)

src/main/java/com/yb/socket/count/CountInfo.java:84

↓ 1 callersMethodsetOpenExecutor

(boolean openExecutor)

src/main/java/com/yb/socket/service/Service.java:261

↓ 1 callersMethodsetReserved

(byte[] reserved)

src/main/java/com/yb/socket/pojo/protocol/ProtocolRequest.java:52

↓ 1 callersMethodsetResult

(Object result)

src/main/java/com/yb/socket/future/InvokeFuture.java:94

↓ 1 callersMethodsetServer

(Server server)

src/main/java/com/yb/socket/service/server/ServerContext.java:26

↓ 1 callersMethodsetServerList

(List<SocketAddress> serverList)

src/main/java/com/yb/socket/service/client/Client.java:230

↓ 1 callersMethodsetStatusPort

(int statusPort)

src/main/java/com/yb/socket/service/server/Server.java:448

↓ 1 callersMethodsetTableScript

(String tableScript)

src/main/java/com/yb/socket/datasource/HsqlDataSource.java:253

↓ 1 callersMethodsetTcpNoDelay

(boolean tcpNoDelay)

src/main/java/com/yb/socket/service/Service.java:245

↓ 1 callersMethodsetUrl

(String url)

src/main/java/com/yb/socket/datasource/HsqlDataSource.java:237

↓ 1 callersMethodsetUsername

(String username)

src/main/java/com/yb/socket/datasource/HsqlDataSource.java:241

↓ 1 callersMethodshutdown

()

src/main/java/com/yb/socket/service/client/BaseClient.java:157

↓ 1 callersMethodstartRegister2Center

(final Server server, String centerAddr)

src/main/java/com/yb/socket/service/server/Server.java:276

↓ 1 callersMethodsubscribe

(WrappedChannel channel, MqttSubscribeMessage msg)

src/main/java/com/yb/socket/listener/DefaultMqttMessageEventListener.java:93

↓ 1 callersMethodtryToStartUpStateReportJob

(Server server, Client client)

src/main/java/com/yb/socket/service/server/Server.java:359

↓ 1 callersMethodunSubscribe

(WrappedChannel channel, MqttUnsubscribeMessage msg)

src/main/java/com/yb/socket/listener/DefaultMqttMessageEventListener.java:101

↓ 1 callersMethodunpackJson

(byte[] bodyBytes)

src/main/java/com/yb/socket/codec/protocol/Protocol.java:137

MethodAESEncrypt

(String password, int length)

src/main/java/com/yb/socket/encrypt/AESEncrypt.java:19

MethodAppTest

Create the test case @param testName name of the test case

src/test/java/com/yb/socket/AppTest.java:18

← previous next →101–200 of 418, ranked by callers