Fixed api name
This commit is contained in:
parent
cf2e7ffc77
commit
41b3acf147
|
@ -390,7 +390,7 @@ open class Server<CONNECTION : Connection>(config: ServerConfiguration = ServerC
|
||||||
* @param function clientAddress: not-null when UDP connection, null when IPC connection
|
* @param function clientAddress: not-null when UDP connection, null when IPC connection
|
||||||
* tagName: the connection tag name
|
* tagName: the connection tag name
|
||||||
*/
|
*/
|
||||||
fun enablePendingMessages(function: (clientAddress: InetAddress?, tagName: String) -> Boolean) {
|
fun enableBufferedMessages(function: (clientAddress: InetAddress?, tagName: String) -> Boolean) {
|
||||||
listenerManager.enableBufferedMessages(function)
|
listenerManager.enableBufferedMessages(function)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
|
@ -597,7 +597,7 @@ class ConnectionFilterTest : BaseTest() {
|
||||||
val server: Server<Connection> = Server(configuration)
|
val server: Server<Connection> = Server(configuration)
|
||||||
addEndPoint(server)
|
addEndPoint(server)
|
||||||
|
|
||||||
server.enablePendingMessages { clientAddress, tagName ->
|
server.enableBufferedMessages { clientAddress, tagName ->
|
||||||
false
|
false
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
Loading…
Reference in New Issue