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

MethodgetLoginTimeout

()

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

MethodgetMessageType

()

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

MethodgetMessageType

()

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

MethodgetParentLogger

()

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

MethodgetQr

()

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

MethodgetReConnecting

()

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

MethodgetRegistered

()

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

MethodgetRetryTimes

()

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

MethodgetServerList

()

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

MethodgetSocketType

()

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

MethodgetStatusPort

()

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

MethodgetSyncInvokeTimeout

()

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

MethodgetTopic

()

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

MethodgetUnit

()

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

MethodgetWorkerCount

()

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

MethodhasAttr

(AttributeKey<T> arg0)

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

MethodinitChannel

(SocketChannel ch)

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

MethodinitChannel

(SocketChannel ch)

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

MethodinitChannel

(SocketChannel ch)

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

Methodinvoke

(Object proxy, Method method, Object[] args)

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

MethodisCancelled

()

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

MethodisMutable

()

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

MethodisOpen

()

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

MethodisOpenCount

()

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

MethodisOpenStatus

()

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

MethodisRegistered

()

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

MethodisWrapperFor

(Class<?> clz)

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

MethodlocalAddress

()

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

Methodmain

(String[] args)

src/test/java/com/yb/socket/service/protocol/ClientTest.java:21

Methodmain

(String[] args)

src/test/java/com/yb/socket/service/protocol/ServerTest.java:14

Methodmain

(String[] args)

src/test/java/com/yb/socket/service/mqttws/MqttWsServerTest.java:21

Methodmain

(String[] args)

src/test/java/com/yb/socket/service/normal/ClientTest.java:19

Methodmain

(String[] args)

src/test/java/com/yb/socket/service/normal/ServerTest.java:19

Methodmain

(String[] args)

src/test/java/com/yb/socket/service/mqtt/MqttServerTest.java:19

Methodmain

(String[] args)

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

Methodmain

(String[] args)

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

Methodmain

(String[] args)

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

Methodmain

(String[] args)

src/test/java/com/yb/socket/push/server/MqttServerTest.java:23

Methodmain

(String[] args)

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

Methodmain

(String[] args)

src/test/java/com/yb/socket/center/ClientTest.java:15

Methodmain

(String[] args)

src/test/java/com/yb/socket/center/CenterMock1.java:13

Methodmain

(String[] args)

src/test/java/com/yb/socket/center/CenterMock2.java:13

Methodmain

(String[] args)

src/test/java/com/yb/socket/center/Server1.java:12

Methodmain

(String[] args)

src/test/java/com/yb/socket/center/Server2.java:12

Methodmain

(String[] args)

src/main/java/com/yb/socket/App.java:8

Methodmain

(String[] args)

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

Methodmain

(String[] args)

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

MethodmessageArrived

(String topic, MqttMessage mqttMessage)

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

MethodmessageArrived

(String topic, MqttMessage mqttMessage)

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

MethodmessageArrived

(String topic, MqttMessage mqttMessage)

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

Methodmetadata

()

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

MethodnewFailedFuture

(Throwable arg0)

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

MethodnewProgressivePromise

()

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

MethodnewPromise

()

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

MethodnewSucceededFuture

()

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

MethodnewThread

(Runnable r)

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

Methodparent

()

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

MethodparsePort

@param portArray @return int[] 返回类型 @Title: parsePort @Description: 解析端口

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

Methodrun

()

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

Methodrun

()

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

Methodrun

()

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

Methodsend

(Object message)

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

Methodsend

(Object message)

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

MethodsetAllIdleTimeSeconds

(int allIdleTimeSeconds)

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

MethodsetAttachment

(Object attachment)

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

MethodsetCenterReConnectTimerInterval

(int centerReConnectTimerInterval)

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

MethodsetChannelId

(String channelId)

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

MethodsetChannels

(ConcurrentHashMap<String, WrappedChannel> channels)

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

MethodsetClientId

(String clientId)

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

MethodsetCorePoolSize

(int corePoolSize)

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

MethodsetCountInfo

(CountInfo countInfo)

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

MethodsetCreateTime

(int createTime)

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

MethodsetCurServer

(SocketAddress curServer)

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

MethodsetDup

(boolean dup)

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

MethodsetErrorFlag

(AtomicBoolean errorFlag)

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

MethodsetExecutor

(ExecutorService executor)

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

MethodsetHandlers

(LinkedHashMap<String, ChannelHandlerFunc> handlers)

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

MethodsetListeners

(List<EventListener> listeners)

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

MethodsetLogWriter

(PrintWriter out)

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

MethodsetLoginTimeout

(int seconds)

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

MethodsetMaximumPoolSize

(int maximumPoolSize)

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

MethodsetMessageId

(int messageId)

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

MethodsetMessageType

(byte messageType)

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

MethodsetMessageType

(byte messageType)

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

MethodsetMutable

(boolean mutable)

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

MethodsetPoolSize

(int poolSize)

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

MethodsetQr

(QueryRunner qr)

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

MethodsetQueueCapacity

(int queueCapacity)

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

MethodsetReConnecting

(AtomicBoolean reConnecting)

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

MethodsetReaderIdleTimeSeconds

(int readerIdleTimeSeconds)

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

MethodsetRegistered

(AtomicBoolean registered)

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

MethodsetRetained

(boolean retained)

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

MethodsetRetryTimes

(AtomicInteger retryTimes)

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

MethodsetServiceName

(String serviceName)

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

MethodsetServiceName

(String serviceName)

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

MethodsetStartTime

(long startTime)

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

MethodsetSyncInvokeTimeout

(int syncInvokeTimeout)

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

MethodsetTimeout

(int timeout)

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

MethodsetTopic

(String topic)

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

MethodsetType

(byte type)

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

← previous next →301–400 of 418, ranked by callers