Search
Preparing search index...
The search index is not available
Documentation
Options
All
Public
Public/Protected
All
Inherited
Externals
Menu
Documentation
@cisl/io-celio-transcript
<internal>
ConfirmChannel
Interface ConfirmChannel
Hierarchy
<internal>
.
Channel
ConfirmChannel
Index
Properties
connection
Methods
close
assert
Queue
check
Queue
delete
Queue
purge
Queue
bind
Queue
unbind
Queue
assert
Exchange
check
Exchange
delete
Exchange
bind
Exchange
unbind
Exchange
consume
cancel
get
ack
ack
All
nack
nack
All
reject
prefetch
recover
publish
send
To
Queue
wait
For
Confirms
add
Listener
on
once
remove
Listener
off
remove
All
Listeners
set
Max
Listeners
get
Max
Listeners
listeners
raw
Listeners
emit
listener
Count
prepend
Listener
prepend
Once
Listener
event
Names
Properties
connection
connection
:
<internal>
.
Connection
Methods
close
close
(
)
:
Promise
<
void
>
Returns
Promise
<
void
>
assert
Queue
assert
Queue
(
queue
:
string
, options
?:
<internal>
.
AssertQueue
)
:
Promise
<
<internal>
.
AssertQueue
>
Parameters
queue:
string
Optional
options:
<internal>
.
AssertQueue
Returns
Promise
<
<internal>
.
AssertQueue
>
check
Queue
check
Queue
(
queue
:
string
)
:
Promise
<
<internal>
.
AssertQueue
>
Parameters
queue:
string
Returns
Promise
<
<internal>
.
AssertQueue
>
delete
Queue
delete
Queue
(
queue
:
string
, options
?:
<internal>
.
DeleteQueue
)
:
Promise
<
<internal>
.
DeleteQueue
>
Parameters
queue:
string
Optional
options:
<internal>
.
DeleteQueue
Returns
Promise
<
<internal>
.
DeleteQueue
>
purge
Queue
purge
Queue
(
queue
:
string
)
:
Promise
<
<internal>
.
PurgeQueue
>
Parameters
queue:
string
Returns
Promise
<
<internal>
.
PurgeQueue
>
bind
Queue
bind
Queue
(
queue
:
string
, source
:
string
, pattern
:
string
, args
?:
any
)
:
Promise
<
<internal>
.
Empty
>
Parameters
queue:
string
source:
string
pattern:
string
Optional
args:
any
Returns
Promise
<
<internal>
.
Empty
>
unbind
Queue
unbind
Queue
(
queue
:
string
, source
:
string
, pattern
:
string
, args
?:
any
)
:
Promise
<
<internal>
.
Empty
>
Parameters
queue:
string
source:
string
pattern:
string
Optional
args:
any
Returns
Promise
<
<internal>
.
Empty
>
assert
Exchange
assert
Exchange
(
exchange
:
string
, type
:
string
, options
?:
<internal>
.
AssertExchange
)
:
Promise
<
<internal>
.
AssertExchange
>
Parameters
exchange:
string
type:
string
Optional
options:
<internal>
.
AssertExchange
Returns
Promise
<
<internal>
.
AssertExchange
>
check
Exchange
check
Exchange
(
exchange
:
string
)
:
Promise
<
<internal>
.
Empty
>
Parameters
exchange:
string
Returns
Promise
<
<internal>
.
Empty
>
delete
Exchange
delete
Exchange
(
exchange
:
string
, options
?:
<internal>
.
DeleteExchange
)
:
Promise
<
<internal>
.
Empty
>
Parameters
exchange:
string
Optional
options:
<internal>
.
DeleteExchange
Returns
Promise
<
<internal>
.
Empty
>
bind
Exchange
bind
Exchange
(
destination
:
string
, source
:
string
, pattern
:
string
, args
?:
any
)
:
Promise
<
<internal>
.
Empty
>
Parameters
destination:
string
source:
string
pattern:
string
Optional
args:
any
Returns
Promise
<
<internal>
.
Empty
>
unbind
Exchange
unbind
Exchange
(
destination
:
string
, source
:
string
, pattern
:
string
, args
?:
any
)
:
Promise
<
<internal>
.
Empty
>
Parameters
destination:
string
source:
string
pattern:
string
Optional
args:
any
Returns
Promise
<
<internal>
.
Empty
>
consume
consume
(
queue
:
string
, onMessage
:
(
(
msg
:
<internal>
.
ConsumeMessage
)
=>
void
)
, options
?:
<internal>
.
Consume
)
:
Promise
<
<internal>
.
Consume
>
Parameters
queue:
string
onMessage:
(
(
msg
:
<internal>
.
ConsumeMessage
)
=>
void
)
(
msg
:
<internal>
.
ConsumeMessage
)
:
void
Parameters
msg:
<internal>
.
ConsumeMessage
Returns
void
Optional
options:
<internal>
.
Consume
Returns
Promise
<
<internal>
.
Consume
>
cancel
cancel
(
consumerTag
:
string
)
:
Promise
<
<internal>
.
Empty
>
Parameters
consumerTag:
string
Returns
Promise
<
<internal>
.
Empty
>
get
get
(
queue
:
string
, options
?:
<internal>
.
Get
)
:
Promise
<
false
|
<internal>
.
GetMessage
>
Parameters
queue:
string
Optional
options:
<internal>
.
Get
Returns
Promise
<
false
|
<internal>
.
GetMessage
>
ack
ack
(
message
:
<internal>
.
Message
, allUpTo
?:
boolean
)
:
void
Parameters
message:
<internal>
.
Message
Optional
allUpTo:
boolean
Returns
void
ack
All
ack
All
(
)
:
void
Returns
void
nack
nack
(
message
:
<internal>
.
Message
, allUpTo
?:
boolean
, requeue
?:
boolean
)
:
void
Parameters
message:
<internal>
.
Message
Optional
allUpTo:
boolean
Optional
requeue:
boolean
Returns
void
nack
All
nack
All
(
requeue
?:
boolean
)
:
void
Parameters
Optional
requeue:
boolean
Returns
void
reject
reject
(
message
:
<internal>
.
Message
, requeue
?:
boolean
)
:
void
Parameters
message:
<internal>
.
Message
Optional
requeue:
boolean
Returns
void
prefetch
prefetch
(
count
:
number
, global
?:
boolean
)
:
Promise
<
<internal>
.
Empty
>
Parameters
count:
number
Optional
global:
boolean
Returns
Promise
<
<internal>
.
Empty
>
recover
recover
(
)
:
Promise
<
<internal>
.
Empty
>
Returns
Promise
<
<internal>
.
Empty
>
publish
publish
(
exchange
:
string
, routingKey
:
string
, content
:
<internal>
.
Buffer
, options
?:
<internal>
.
Publish
, callback
?:
(
(
err
:
any
, ok
:
<internal>
.
Empty
)
=>
void
)
)
:
boolean
Parameters
exchange:
string
routingKey:
string
content:
<internal>
.
Buffer
Optional
options:
<internal>
.
Publish
Optional
callback:
(
(
err
:
any
, ok
:
<internal>
.
Empty
)
=>
void
)
(
err
:
any
, ok
:
<internal>
.
Empty
)
:
void
Parameters
err:
any
ok:
<internal>
.
Empty
Returns
void
Returns
boolean
send
To
Queue
send
To
Queue
(
queue
:
string
, content
:
<internal>
.
Buffer
, options
?:
<internal>
.
Publish
, callback
?:
(
(
err
:
any
, ok
:
<internal>
.
Empty
)
=>
void
)
)
:
boolean
Parameters
queue:
string
content:
<internal>
.
Buffer
Optional
options:
<internal>
.
Publish
Optional
callback:
(
(
err
:
any
, ok
:
<internal>
.
Empty
)
=>
void
)
(
err
:
any
, ok
:
<internal>
.
Empty
)
:
void
Parameters
err:
any
ok:
<internal>
.
Empty
Returns
void
Returns
boolean
wait
For
Confirms
wait
For
Confirms
(
)
:
Promise
<
void
>
Returns
Promise
<
void
>
add
Listener
add
Listener
(
event
:
string
|
symbol
, listener
:
(
(
...
args
:
any
[]
)
=>
void
)
)
:
<internal>
.
ConfirmChannel
Parameters
event:
string
|
symbol
listener:
(
(
...
args
:
any
[]
)
=>
void
)
(
...
args
:
any
[]
)
:
void
Parameters
Rest
...
args:
any
[]
Returns
void
Returns
<internal>
.
ConfirmChannel
on
on
(
event
:
string
|
symbol
, listener
:
(
(
...
args
:
any
[]
)
=>
void
)
)
:
<internal>
.
ConfirmChannel
Parameters
event:
string
|
symbol
listener:
(
(
...
args
:
any
[]
)
=>
void
)
(
...
args
:
any
[]
)
:
void
Parameters
Rest
...
args:
any
[]
Returns
void
Returns
<internal>
.
ConfirmChannel
once
once
(
event
:
string
|
symbol
, listener
:
(
(
...
args
:
any
[]
)
=>
void
)
)
:
<internal>
.
ConfirmChannel
Parameters
event:
string
|
symbol
listener:
(
(
...
args
:
any
[]
)
=>
void
)
(
...
args
:
any
[]
)
:
void
Parameters
Rest
...
args:
any
[]
Returns
void
Returns
<internal>
.
ConfirmChannel
remove
Listener
remove
Listener
(
event
:
string
|
symbol
, listener
:
(
(
...
args
:
any
[]
)
=>
void
)
)
:
<internal>
.
ConfirmChannel
Parameters
event:
string
|
symbol
listener:
(
(
...
args
:
any
[]
)
=>
void
)
(
...
args
:
any
[]
)
:
void
Parameters
Rest
...
args:
any
[]
Returns
void
Returns
<internal>
.
ConfirmChannel
off
off
(
event
:
string
|
symbol
, listener
:
(
(
...
args
:
any
[]
)
=>
void
)
)
:
<internal>
.
ConfirmChannel
Parameters
event:
string
|
symbol
listener:
(
(
...
args
:
any
[]
)
=>
void
)
(
...
args
:
any
[]
)
:
void
Parameters
Rest
...
args:
any
[]
Returns
void
Returns
<internal>
.
ConfirmChannel
remove
All
Listeners
remove
All
Listeners
(
event
?:
string
|
symbol
)
:
<internal>
.
ConfirmChannel
Parameters
Optional
event:
string
|
symbol
Returns
<internal>
.
ConfirmChannel
set
Max
Listeners
set
Max
Listeners
(
n
:
number
)
:
<internal>
.
ConfirmChannel
Parameters
n:
number
Returns
<internal>
.
ConfirmChannel
get
Max
Listeners
get
Max
Listeners
(
)
:
number
Returns
number
listeners
listeners
(
event
:
string
|
symbol
)
:
Function
[]
Parameters
event:
string
|
symbol
Returns
Function
[]
raw
Listeners
raw
Listeners
(
event
:
string
|
symbol
)
:
Function
[]
Parameters
event:
string
|
symbol
Returns
Function
[]
emit
emit
(
event
:
string
|
symbol
,
...
args
:
any
[]
)
:
boolean
Parameters
event:
string
|
symbol
Rest
...
args:
any
[]
Returns
boolean
listener
Count
listener
Count
(
type
:
string
|
symbol
)
:
number
Parameters
type:
string
|
symbol
Returns
number
prepend
Listener
prepend
Listener
(
event
:
string
|
symbol
, listener
:
(
(
...
args
:
any
[]
)
=>
void
)
)
:
<internal>
.
ConfirmChannel
Parameters
event:
string
|
symbol
listener:
(
(
...
args
:
any
[]
)
=>
void
)
(
...
args
:
any
[]
)
:
void
Parameters
Rest
...
args:
any
[]
Returns
void
Returns
<internal>
.
ConfirmChannel
prepend
Once
Listener
prepend
Once
Listener
(
event
:
string
|
symbol
, listener
:
(
(
...
args
:
any
[]
)
=>
void
)
)
:
<internal>
.
ConfirmChannel
Parameters
event:
string
|
symbol
listener:
(
(
...
args
:
any
[]
)
=>
void
)
(
...
args
:
any
[]
)
:
void
Parameters
Rest
...
args:
any
[]
Returns
void
Returns
<internal>
.
ConfirmChannel
event
Names
event
Names
(
)
:
(
string
|
symbol
)
[]
Returns
(
string
|
symbol
)
[]
Modules
@cisl/io-
celio-
speaker
@cisl/io-
celio-
transcript
<internal>
IORedis
Event
Emitter
internal
@cisl/io-
display
@cisl/io-
speaker
@cisl/io
Confirm
Channel
connection
close
assert
Queue
check
Queue
delete
Queue
purge
Queue
bind
Queue
unbind
Queue
assert
Exchange
check
Exchange
delete
Exchange
bind
Exchange
unbind
Exchange
consume
cancel
get
ack
ack
All
nack
nack
All
reject
prefetch
recover
publish
send
To
Queue
wait
For
Confirms
add
Listener
on
once
remove
Listener
off
remove
All
Listeners
set
Max
Listeners
get
Max
Listeners
listeners
raw
Listeners
emit
listener
Count
prepend
Listener
prepend
Once
Listener
event
Names
Generated using
TypeDoc