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

↓ 33 callersMethodget

(byte type)

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

↓ 21 callersMethodaddChannelHandler

(String key, ChannelHandlerFunc handler)

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

↓ 16 callersMethodclose

()

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

↓ 16 callersMethodgetCountInfo

()

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

↓ 14 callersMethodgetSequence

()

src/main/java/com/yb/socket/pojo/BaseMessage.java:14

↓ 14 callersMethodid

()

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

↓ 14 callersMethodsetSequence

(int sequence)

src/main/java/com/yb/socket/pojo/BaseMessage.java:17

↓ 14 callersMethodwriteAndFlush

(Object message)

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

↓ 13 callersMethodaddEventListener

(EventListener listener)

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

↓ 12 callersMethodsetPort

(int port)

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

↓ 12 callersMethodtoString

()

src/main/java/com/yb/socket/pojo/Request.java:24

↓ 11 callersMethodgetChannels

()

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

↓ 11 callersMethodsetCheckHeartbeat

(boolean checkHeartbeat)

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

↓ 10 callersMethodgetService

()

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

↓ 9 callersMethodbind

()

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

↓ 9 callersMethodgetChannel

(String channelId)

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

↓ 9 callersMethodgetContext

()

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

↓ 9 callersMethodgetInstance

()

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

↓ 8 callersMethodaddListener

(InvokeFutureListener listener)

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

↓ 8 callersMethodgetMessage

()

src/main/java/com/yb/socket/pojo/Request.java:16

↓ 8 callersMethodgetServer

()

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

↓ 8 callersMethodisSuccess

()

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

↓ 7 callersMethodsetMessage

(Object message)

src/main/java/com/yb/socket/pojo/Request.java:20

↓ 6 callersMethodgetChannel

()

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

↓ 6 callersMethodgetServiceName

()

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

↓ 5 callersMethodisDone

()

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

↓ 5 callersMethodisOpenExecutor

()

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

↓ 4 callersMethodattr

(AttributeKey<T> arg0)

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

↓ 4 callersMethodchannelRead

接收消息 @param ctx @param channel @param msg @return

src/main/java/com/yb/socket/listener/MessageEventListener.java:23

↓ 4 callersMethodconnect

()

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

↓ 4 callersMethoddispatchChannelEvent

(final ChannelHandlerContext ctx, final WrappedChannel channel)

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

↓ 4 callersMethoddispatchExceptionCaught

(final ChannelHandlerContext ctx, final WrappedChannel channel, final Throwable cause)

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

↓ 4 callersMethodgetContext

()

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

↓ 4 callersMethodgetCurServer

()

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

↓ 4 callersMethodgetIp

()

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

↓ 4 callersMethodgetPayload

()

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

↓ 4 callersMethodinit

()

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

↓ 4 callersMethodisActive

()

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

↓ 4 callersMethodsubscribe

订阅主题 @param clientId @param channelId @param topic @throws SQLException

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

↓ 4 callersMethodtoString

()

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

↓ 3 callersMethodchannelActive

通道连接 @param ctx @param channel @return

src/main/java/com/yb/socket/listener/ChannelEventListener.java:23

↓ 3 callersMethodchannelInactive

通道关闭 @param ctx @param channel @return

src/main/java/com/yb/socket/listener/ChannelEventListener.java:32

↓ 3 callersMethodcheckMutable

()

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

↓ 3 callersMethodconnect

(WrappedChannel channel, MqttConnectMessage msg)

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

↓ 3 callersMethoddecode

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

src/main/java/com/yb/socket/codec/JsonDecoder.java:28

↓ 3 callersMethoddoConnect

(final SocketAddress socketAddress, boolean sync)

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

↓ 3 callersMethodgetApp

()

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

↓ 3 callersMethodgetCode

()

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

↓ 3 callersMethodgetEventListeners

()

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

↓ 3 callersMethodgetHandlers

()

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

↓ 3 callersMethodgetHeartbeatNum

()

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

↓ 3 callersMethodgetMessageId

()

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

↓ 3 callersMethodgetSingleton

()

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

↓ 3 callersMethodnewInstance

新建一个实例 @return

src/main/java/com/yb/socket/service/ChannelHandlerFunc.java:16

↓ 3 callersMethodpipeline

()

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

↓ 3 callersMethodreConnect

断线重连

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

↓ 3 callersMethodsend

(Object message)

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

↓ 3 callersMethodsend

(WrappedChannel channel, String topic, MqttRequest request)

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

↓ 3 callersMethodsendWithSync

(Request message)

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

↓ 3 callersMethodsetCause

(Throwable cause)

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

↓ 3 callersMethodsetCode

(int code)

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

↓ 3 callersMethodsetOpenStatus

(boolean openStatus)

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

↓ 3 callersMethodsetPassword

(String password)

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

↓ 3 callersMethodsetResult

(Object result)

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

↓ 3 callersMethodsetSocketType

(SocketType socketType)

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

↓ 3 callersMethodshutdown

shutdown

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

↓ 3 callersMethoduseEpoll

()

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

↓ 2 callersMethodaddAndGet

(String sequenceName)

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

↓ 2 callersMethodcloseChannel

(ChannelHandlerContext ctx)

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

↓ 2 callersMethodcloseChannel

(ChannelHandlerContext ctx)

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

↓ 2 callersMethodconnect

(final SocketAddress socketAddress)

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

↓ 2 callersMethoddecrypt

(byte[] src)

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

↓ 2 callersMethoddispatchMessageEvent

(final ChannelHandlerContext ctx, final WrappedChannel channel, final Object msg)

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

↓ 2 callersMethoddoChannelEvent

(final ChannelHandlerContext ctx, final WrappedChannel channel)

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

↓ 2 callersMethoddoExceptionEvent

(final ChannelHandlerContext ctx, final WrappedChannel channel, final Throwable cause)

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

↓ 2 callersMethoddoMessageEvent

(final ChannelHandlerContext ctx, final WrappedChannel channel, final Object msg)

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

↓ 2 callersMethodgetBody

()

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

↓ 2 callersMethodgetCause

()

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

↓ 2 callersMethodgetConnection

()

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

↓ 2 callersMethodgetLastReceive

()

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

↓ 2 callersMethodgetLastSent

()

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

↓ 2 callersMethodgetLocalIp

()

src/main/java/com/yb/socket/util/AddressUtil.java:16

↓ 2 callersMethodgetPort

()

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

↓ 2 callersMethodgetReaderIdleTimeSeconds

()

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

↓ 2 callersMethodgetReceiveNum

()

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

↓ 2 callersMethodgetResult

()

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

↓ 2 callersMethodgetResult

()

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

↓ 2 callersMethodgetSentNum

()

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

↓ 2 callersMethodgetType

()

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

↓ 2 callersMethodgetVersion

()

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

↓ 2 callersMethodinit

初始化datasource，datasource使用前必须初始化

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

↓ 2 callersMethodisCheckHeartbeat

()

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

↓ 2 callersMethodnotifyListeners

()

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

↓ 2 callersMethodoperationComplete

完成操作 @param future @throws Exception

src/main/java/com/yb/socket/future/InvokeFutureListener.java:16

↓ 2 callersMethodpackJson

(Map<String, Object> body)

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

↓ 2 callersMethodparseAddress

(String addressArray)

src/main/java/com/yb/socket/util/AddressUtil.java:26

↓ 2 callersMethodquery

(QueryRunner qr)

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

↓ 2 callersMethodread

()

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

↓ 2 callersMethodsendSync

(final Request message, int timeout)

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

↓ 2 callersMethodsetBody

(Map<String, Object> body)

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

next →1–100 of 418, ranked by callers