\Client

Summary

Methods
Properties
Constants
registerClientFactory()
tryRegisterClientFactory()
create()
__construct()
__destruct()
close()
getTimeout()
setTimeout()
getRetry()
setRetry()
isIdempotent()
setIdempotent()
isFailswitch()
setFailswitch()
getFailround()
isByref()
setByref()
isSimple()
setSimple()
getFilter()
setFilter()
addFilter()
removeFilter()
getUriList()
setUriList()
useService()
inputFilter()
retry()
decode()
__call()
__get()
invokeHandler()
beforeFilterHandler()
afterFilterHandler()
invoke()
getId()
getTopic()
subscribe()
unsubscribe()
isSubscribed()
subscribedList()
addInvokeHandler()
addBeforeFilterHandler()
addAfterFilterHandler()
isFullDuplex()
setFullDuplex()
getReadBuffer()
setReadBuffer()
getWriteBuffer()
setWriteBuffer()
getMaxPoolSize()
setMaxPoolSize()
setNoDelay()
isNoDelay()
setKeepAlive()
isKeepAlive()
getOptions()
setOptions()
set()
loop()
$uri
$filters
$timeout
$retry
$idempotent
$failswitch
$failround
$byref
$simple
$onError
$onFailswitch
$fullDuplex
$readBuffer
$writeBuffer
$maxPoolSize
$noDelay
$keepAlive
$options
No constants found
setUri()
wait()
getNextInvokeHandler()
getNextFilterHandler()
sendAndReceive()
$async
$invokeHandler
$beforeFilterHandler
$afterFilterHandler
N/A
initClientFactories()
outputFilter()
failswitch()
encode()
getContext()
asyncInvokeHandler()
syncInvokeHandler()
asyncBeforeFilterHandler()
syncBeforeFilterHandler()
autoId()
delTopic()
$index
$uriList
$methodCache
$clientFactories
$clientFactoriesInited
$topics
$id
$invokeHandlers
$beforeFilterHandlers
$afterFilterHandlers
$defaultInvokeHandler
$defaultBeforeFilterHandler
$defaultAfterFilterHandler
$hdtrans
$fdtrans
N/A

Properties

$uri

$uri : 

Type

$filters

$filters : 

Type

$timeout

$timeout : 

Type

$retry

$retry : 

Type

$idempotent

$idempotent : 

Type

$failswitch

$failswitch : 

Type

$failround

$failround : 

Type

$byref

$byref : 

Type

$simple

$simple : 

Type

$onError

$onError : 

Type

$onFailswitch

$onFailswitch : 

Type

$fullDuplex

$fullDuplex : 

Type

$readBuffer

$readBuffer : 

Type

$writeBuffer

$writeBuffer : 

Type

$maxPoolSize

$maxPoolSize : 

Type

$noDelay

$noDelay : 

Type

$keepAlive

$keepAlive : 

Type

$options

$options : 

Type

$async

$async : 

Type

$invokeHandler

$invokeHandler : 

Type

$beforeFilterHandler

$beforeFilterHandler : 

Type

$afterFilterHandler

$afterFilterHandler : 

Type

$index

$index : 

Type

$uriList

$uriList : 

Type

$methodCache

$methodCache : 

Type

$clientFactories

$clientFactories : 

Type

$clientFactoriesInited

$clientFactoriesInited : 

Type

$topics

$topics : 

Type

$id

$id : 

Type

$invokeHandlers

$invokeHandlers : 

Type

$beforeFilterHandlers

$beforeFilterHandlers : 

Type

$afterFilterHandlers

$afterFilterHandlers : 

Type

$defaultInvokeHandler

$defaultInvokeHandler : 

Type

$defaultBeforeFilterHandler

$defaultBeforeFilterHandler : 

Type

$defaultAfterFilterHandler

$defaultAfterFilterHandler : 

Type

$hdtrans

$hdtrans : 

Type

$fdtrans

$fdtrans : 

Type

Methods

registerClientFactory()

registerClientFactory(  $scheme,   $clientFactory) 

Parameters

$scheme
$clientFactory

tryRegisterClientFactory()

tryRegisterClientFactory(  $scheme,   $clientFactory) 

Parameters

$scheme
$clientFactory

create()

create(  $uriList,   $async = true) 

Parameters

$uriList
$async

__construct()

__construct(  $uris = null,   $async = true) 

Parameters

$uris
$async

__destruct()

__destruct() 

close()

close() 

getTimeout()

getTimeout() 

setTimeout()

setTimeout(  $timeout) 

Parameters

$timeout

getRetry()

getRetry() 

setRetry()

setRetry(  $retry) 

Parameters

$retry

isIdempotent()

isIdempotent() 

setIdempotent()

setIdempotent(  $idempotent) 

Parameters

$idempotent

isFailswitch()

isFailswitch() 

setFailswitch()

setFailswitch(  $failswitch) 

Parameters

$failswitch

getFailround()

getFailround() 

isByref()

isByref() 

setByref()

setByref(  $byref) 

Parameters

$byref

isSimple()

isSimple() 

setSimple()

setSimple(  $simple = true) 

Parameters

$simple

getFilter()

getFilter() 

setFilter()

setFilter(\Filter  $filter) 

Parameters

\Filter $filter

addFilter()

addFilter(\Filter  $filter) 

Parameters

\Filter $filter

removeFilter()

removeFilter(\Filter  $filter) 

Parameters

\Filter $filter

getUriList()

getUriList() 

setUriList()

setUriList(  $uriList) 

Parameters

$uriList

useService()

useService(  $uriList = array(),   $namespace = '') 

Parameters

$uriList
$namespace

inputFilter()

inputFilter(  $response, \stdClass  $context) 

Parameters

$response
\stdClass $context

retry()

retry(  $request, \stdClass  $context) 

Parameters

$request
\stdClass $context

decode()

decode(  $response, array  $args, \stdClass  $context) 

Parameters

$response
array $args
\stdClass $context

__call()

__call(  $name, array  $args) 

Parameters

$name
array $args

__get()

__get(  $name) 

Parameters

$name

invokeHandler()

invokeHandler(  $name, array  $args, \stdClass  $context) 

Parameters

$name
array $args
\stdClass $context

beforeFilterHandler()

beforeFilterHandler(  $request, \stdClass  $context) 

Parameters

$request
\stdClass $context

afterFilterHandler()

afterFilterHandler(  $request, \stdClass  $context) 

Parameters

$request
\stdClass $context

invoke()

invoke(  $name, array  $args = array(),   $callback = null, \InvokeSettings  $settings = null) 

Parameters

$name
array $args
$callback
\InvokeSettings $settings

getId()

getId() 

getTopic()

getTopic(  $name,   $id) 

Parameters

$name
$id

subscribe()

subscribe(  $name,   $id = null,   $callback = null,   $timeout = null,   $failswitch = false) 

Parameters

$name
$id
$callback
$timeout
$failswitch

unsubscribe()

unsubscribe(  $name,   $id = null,   $callback = null) 

Parameters

$name
$id
$callback

isSubscribed()

isSubscribed(  $name) 

Parameters

$name

subscribedList()

subscribedList() 

addInvokeHandler()

addInvokeHandler(  $handler) 

Parameters

$handler

addBeforeFilterHandler()

addBeforeFilterHandler(  $handler) 

Parameters

$handler

addAfterFilterHandler()

addAfterFilterHandler(  $handler) 

Parameters

$handler

isFullDuplex()

isFullDuplex() 

setFullDuplex()

setFullDuplex(  $fullDuplex) 

Parameters

$fullDuplex

getReadBuffer()

getReadBuffer() 

setReadBuffer()

setReadBuffer(  $size) 

Parameters

$size

getWriteBuffer()

getWriteBuffer() 

setWriteBuffer()

setWriteBuffer(  $size) 

Parameters

$size

getMaxPoolSize()

getMaxPoolSize() 

setMaxPoolSize()

setMaxPoolSize(  $maxPoolSize) 

Parameters

$maxPoolSize

setNoDelay()

setNoDelay(  $value) 

Parameters

$value

isNoDelay()

isNoDelay() 

setKeepAlive()

setKeepAlive(  $value) 

Parameters

$value

isKeepAlive()

isKeepAlive() 

getOptions()

getOptions() 

setOptions()

setOptions(array  $options) 

Parameters

array $options

set()

set(  $key,   $value) 

Parameters

$key
$value

loop()

loop() 

setUri()

setUri(  $uri) 

Parameters

$uri

wait()

wait(  $interval,   $callback) 

Parameters

$interval
$callback

getNextInvokeHandler()

getNextInvokeHandler(\Closure  $next,   $handler) 

Parameters

\Closure $next
$handler

getNextFilterHandler()

getNextFilterHandler(\Closure  $next,   $handler) 

Parameters

\Closure $next
$handler

sendAndReceive()

sendAndReceive(  $request, \stdClass  $context) 

Parameters

$request
\stdClass $context

initClientFactories()

initClientFactories() 

outputFilter()

outputFilter(  $request, \stdClass  $context) 

Parameters

$request
\stdClass $context

failswitch()

failswitch() 

encode()

encode(  $name, array  $args, \stdClass  $context) 

Parameters

$name
array $args
\stdClass $context

getContext()

getContext(\InvokeSettings  $settings) 

Parameters

\InvokeSettings $settings

asyncInvokeHandler()

asyncInvokeHandler(  $name, array  $args, \stdClass  $context) 

Parameters

$name
array $args
\stdClass $context

syncInvokeHandler()

syncInvokeHandler(  $name, array  $args, \stdClass  $context) 

Parameters

$name
array $args
\stdClass $context

asyncBeforeFilterHandler()

asyncBeforeFilterHandler(  $request, \stdClass  $context) 

Parameters

$request
\stdClass $context

syncBeforeFilterHandler()

syncBeforeFilterHandler(  $request, \stdClass  $context) 

Parameters

$request
\stdClass $context

autoId()

autoId() 

delTopic()

delTopic(  $topics,   $id,   $callback) 

Parameters

$topics
$id
$callback