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

MethodBaseClient

()

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

MethodClientDispatchHandler

(EventDispatcher eventDispatcher)

src/main/java/com/yb/socket/service/client/ClientDispatchHandler.java:21

MethodClientHeartbeatHandler

()

src/main/java/com/yb/socket/service/client/ClientHeartbeatHandler.java:21

MethodConnectionProxy

(Object obj, LinkedList<Connection> connectionPool)

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

MethodEventDispatcher

(Service service)

src/main/java/com/yb/socket/service/EventDispatcher.java:25

MethodHeartbeat

()

src/main/java/com/yb/socket/pojo/Heartbeat.java:23

MethodHsqlDataSource

()

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

MethodInvokeFuture

()

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

MethodMessageTypeEnum

(byte type)

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

MethodMqttRequest

()

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

MethodProtocolResponse

()

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

MethodRSAEncrypt

(KeyPair keyPair)

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

MethodSequence

()

src/main/java/com/yb/socket/util/Sequence.java:17

MethodServer

()

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

MethodServerContext

()

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

MethodServerContext

()

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

MethodServerDispatchHandler

(EventDispatcher eventDispatcher)

src/main/java/com/yb/socket/service/server/ServerDispatchHandler.java:21

MethodServerHeartbeatHandler

()

src/main/java/com/yb/socket/service/server/ServerHeartbeatHandler.java:20

MethodServerStateReportJob

(Server server, Client client)

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

MethodService

()

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

MethodShutdownHook

(Service service)

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

MethodSocketRuntimeException

()

src/main/java/com/yb/socket/exception/SocketRuntimeException.java:10

MethodSocketTimeoutException

()

src/main/java/com/yb/socket/exception/SocketTimeoutException.java:10

MethodStatusServer

()

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

MethodSubscribeServer

(HsqlDataSource dataSource)

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

MethodWrappedChannel

(Channel channel)

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

Methodalloc

()

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

Methodbind

(SocketAddress arg0)

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

MethodbytesBeforeWritable

()

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

Methodcancel

(boolean mayInterruptIfRunning)

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

MethodchannelActive

(ChannelHandlerContext ctx)

src/main/java/com/yb/socket/service/client/ClientDispatchHandler.java:40

MethodchannelActive

(ChannelHandlerContext ctx)

src/main/java/com/yb/socket/service/server/ServerDispatchHandler.java:40

MethodchannelActive

(ChannelHandlerContext ctx)

src/main/java/com/yb/socket/count/CountHandler.java:19

MethodchannelInactive

(ChannelHandlerContext ctx)

src/main/java/com/yb/socket/service/client/ClientDispatchHandler.java:54

MethodchannelInactive

(ChannelHandlerContext ctx)

src/main/java/com/yb/socket/service/server/ServerDispatchHandler.java:52

MethodchannelInactive

(ChannelHandlerContext ctx)

src/main/java/com/yb/socket/count/CountHandler.java:26

MethodchannelRead

(ChannelHandlerContext ctx, WrappedChannel channel, Object msg)

src/test/java/com/yb/socket/service/protocol/ProtocolEchoMessageEventListener.java:22

MethodchannelRead

(ChannelHandlerContext ctx, WrappedChannel channel, Object msg)

src/test/java/com/yb/socket/service/normal/JsonEchoMessageEventListener.java:17

MethodchannelRead

(ChannelHandlerContext ctx, WrappedChannel channel, Object msg)

src/test/java/com/yb/socket/center/CenterMockMessageEventListener.java:22

MethodchannelRead

(ChannelHandlerContext ctx, Object msg)

src/main/java/com/yb/socket/service/client/ClientDispatchHandler.java:30

MethodchannelRead

(ChannelHandlerContext ctx, Object msg)

src/main/java/com/yb/socket/service/server/ServerHeartbeatHandler.java:35

MethodchannelRead

(ChannelHandlerContext ctx, Object msg)

src/main/java/com/yb/socket/service/server/ServerDispatchHandler.java:29

MethodchannelRead

(ChannelHandlerContext ctx, WrappedChannel channel, Object msg)

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

MethodchannelRead

(ChannelHandlerContext ctx, WrappedChannel channel, Object msg)

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

MethodchannelRead

(ChannelHandlerContext ctx, WrappedChannel channel, Object msg)

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

MethodchannelRead

(ChannelHandlerContext ctx, Object msg)

src/main/java/com/yb/socket/count/CountHandler.java:33

MethodclearPayload

()

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

MethodcompareTo

(Channel o)

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

Methodcompress

(byte[] buffer)

src/main/java/com/yb/socket/compression/GzipCompression.java:25

Methodcompress

compress @param buffer @return @throws IOException

src/main/java/com/yb/socket/compression/Compression.java:18

Methodconfig

()

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

Methodconnect

(SocketAddress arg0)

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

MethodconnectComplete

(boolean reconnect, String serverURI)

src/test/java/com/yb/socket/service/mqtt/MqttClientTest2.java:30

MethodconnectComplete

(boolean reconnect, String serverURI)

src/test/java/com/yb/socket/service/mqtt/MqttClientTest1.java:32

MethodconnectComplete

(boolean reconnect, String serverURI)

src/test/java/com/yb/socket/push/server/MqttClientTest.java:32

MethodconnectionLost

(Throwable throwable)

src/test/java/com/yb/socket/service/mqtt/MqttClientTest2.java:41

MethodconnectionLost

(Throwable throwable)

src/test/java/com/yb/socket/service/mqtt/MqttClientTest1.java:43

MethodconnectionLost

(Throwable throwable)

src/test/java/com/yb/socket/push/server/MqttClientTest.java:43

Methoddecode

(ChannelHandlerContext ctx, BinaryWebSocketFrame msg, List<Object> out)

src/main/java/com/yb/socket/codec/MqttWebSocketCodec.java:23

Methoddecode

(ChannelHandlerContext ctx, ByteBuf in, List<Object> out)

src/main/java/com/yb/socket/codec/protocol/ProtocolDecoder.java:21

Methoddecompress

(byte[] buffer)

src/main/java/com/yb/socket/compression/GzipCompression.java:52

Methoddecompress

decompress @param buffer @return @throws IOException

src/main/java/com/yb/socket/compression/Compression.java:27

Methoddecrypt

(String src, String charset)

src/main/java/com/yb/socket/encrypt/BaseEncrypt.java:18

Methoddecrypt

decrypt @param src @return @throws Exception

src/main/java/com/yb/socket/encrypt/Encrypt.java:24

MethoddeliveryComplete

(IMqttDeliveryToken iMqttDeliveryToken)

src/test/java/com/yb/socket/service/mqtt/MqttClientTest2.java:49

MethoddeliveryComplete

(IMqttDeliveryToken iMqttDeliveryToken)

src/test/java/com/yb/socket/service/mqtt/MqttClientTest1.java:51

MethoddeliveryComplete

(IMqttDeliveryToken iMqttDeliveryToken)

src/test/java/com/yb/socket/push/server/MqttClientTest.java:51

MethoddisConnect

(WrappedChannel channel, MqttMessage msg)

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

Methoddisconnect

()

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

Methodencode

(ChannelHandlerContext ctx, BaseMessage msg, List<Object> out)

src/main/java/com/yb/socket/codec/JsonEncoder.java:29

Methodencode

(ChannelHandlerContext ctx, ByteBuf msg, List<Object> out)

src/main/java/com/yb/socket/codec/MqttWebSocketCodec.java:18

Methodencode

(ChannelHandlerContext ctx, BaseMessage msg, ByteBuf out)

src/main/java/com/yb/socket/codec/protocol/ProtocolEncoder.java:16

Methodencrypt

(String src, String charset)

src/main/java/com/yb/socket/encrypt/BaseEncrypt.java:11

Methodencrypt

encrypt @param src @return @throws Exception

src/main/java/com/yb/socket/encrypt/Encrypt.java:15

MethodeventLoop

()

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

MethodexceptionCaught

(ChannelHandlerContext ctx, Throwable cause)

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

MethodexceptionCaught

(ChannelHandlerContext ctx, Throwable cause)

src/main/java/com/yb/socket/service/server/ServerDispatchHandler.java:58

MethodexceptionCaught

(ChannelHandlerContext ctx, WrappedChannel channel, Throwable cause)

src/main/java/com/yb/socket/listener/DefaultExceptionListener.java:15

Methodflush

()

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

MethodgetAttachment

()

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

MethodgetBodyLength

()

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

MethodgetBodyLength

()

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

MethodgetCause

()

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

MethodgetCenterAddr

()

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

MethodgetCenterAddr

()

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

MethodgetCenterReConnectTimerInterval

()

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

MethodgetChannel

()

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

MethodgetChannel

()

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

MethodgetChannelId

()

src/test/java/com/yb/socket/push/server/ChannelDO.java:14

MethodgetClientId

()

src/test/java/com/yb/socket/push/server/ChannelDO.java:22

MethodgetConnectTimeout

()

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

MethodgetCreateTime

()

src/test/java/com/yb/socket/push/server/ChannelDO.java:38

MethodgetErrorFlag

()

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

MethodgetExecutorActiveCount

()

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

MethodgetExecutorCompletedTaskCount

()

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

MethodgetExecutorLargestPoolSize

()

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

MethodgetExecutorPoolSize

()

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

MethodgetExecutorQueueSize

()

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

MethodgetExecutorTaskCount

()

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

MethodgetLogWriter

()

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

← previous next →201–300 of 418, ranked by callers