UniPRT SDK  v1.0.0.0
com.UniPRT.Sdk.Mgmt.Channel< T > Class Template Reference

Public Member Functions

 Channel (int capacity)
 
 Channel ()
 
void Write (T message) throws InterruptedException
 
Read () throws InterruptedException
 
boolean TryWrite (T message)
 
boolean TryRead (T[] item)
 
void Disconnect ()
 
boolean Offer (T msgToDeposit)
 
Poll (long timeout, TimeUnit unit) throws InterruptedException
 
Take () throws InterruptedException
 
int Size ()
 

Private Attributes

BlockingQueue< T > queue
 

Constructor & Destructor Documentation

◆ Channel() [1/2]

com.UniPRT.Sdk.Mgmt.Channel< T >.Channel ( int  capacity)

◆ Channel() [2/2]

Member Function Documentation

◆ Disconnect()

void com.UniPRT.Sdk.Mgmt.Channel< T >.Disconnect ( )

◆ Offer()

boolean com.UniPRT.Sdk.Mgmt.Channel< T >.Offer ( msgToDeposit)

◆ Poll()

T com.UniPRT.Sdk.Mgmt.Channel< T >.Poll ( long  timeout,
TimeUnit  unit 
) throws InterruptedException

◆ Read()

T com.UniPRT.Sdk.Mgmt.Channel< T >.Read ( ) throws InterruptedException

◆ Size()

◆ Take()

◆ TryRead()

boolean com.UniPRT.Sdk.Mgmt.Channel< T >.TryRead ( T[]  item)

◆ TryWrite()

◆ Write()

void com.UniPRT.Sdk.Mgmt.Channel< T >.Write ( message) throws InterruptedException

Member Data Documentation

◆ queue


The documentation for this class was generated from the following file: