Public Member Functions | |
AMgmtListenerChannels () | |
void | ListenerChannelDisconnect (Channel< T > chnlToRemove) |
Disconnect channel. No more messages added to a channel that is disconnected, but the channel can be reconnected in the future. More... | |
void | ListenerChannelDisconnectPermanently (Channel< T > chnlToRemove) |
Disconnect a channel permanently so that it cannot be reconnected. More... | |
Channel< T > | ListenerChannelGetNew (int capacity, MgmtChannelFilterType chnlType, String solicitedMsgId) |
Creates new channel for caller to listen for fully formed JSON msgs. More... | |
Channel< T > | ListenerChannelGetNew (int capacity, MgmtChannelFilterType chnlType) |
void | ListenerChannelConnect (Channel< T > chnlToReconnect, MgmtChannelFilterType chnlType, String solicitedMsgId) |
Connect or reconnect a channel for listening to messages. More... | |
void | ListenerChannelConnect (Channel< T > chnlToReconnect, MgmtChannelFilterType chnlType) |
void | ListenerMsgDeposit (T msgToDeposit, String solicitedMsgId) |
Private Member Functions | |
boolean | AddListenerChannel (Channel< T > chnlToAdd, MgmtChannelFilterType chnlType, String solicitedMsgId) |
void | RemoveListenerFromList (List< Channel< T >> listenerList, Channel< T > chnlToRemove) |
void | AddListenerToList (List< Channel< T >> listenerList, Channel< T > chnlToAdd) |
List< Channel< T > > | MySolicitedChannelList (String solicitedMsgId) |
void | MySolicitedChannelList_Add (String solicitedMsgId, Channel< T > chnlToAdd) |
void | MySolicitedChannelList_Remove (Channel< T > chnlToRemove) |
Map.Entry< String, List< Channel< T > > > | mySolicitedListWithChannel (Channel< T > chnlToSearch) |
String | SolicitedChnlKey (Channel< T > chnlToLookFor) |
void | AddToMsgList (T msgToDeposit, List< Channel< T >> listenerList) |
Private Attributes | |
final Semaphore | _semaphoreListeners = new Semaphore(1) |
final List< Channel< T > > | _msgListeners_AllMsgs = new ArrayList<>() |
final List< Channel< T > > | _msgListeners_Unsolicited = new ArrayList<>() |
final List< Channel< T > > | _msgListeners_AnySolicited = new ArrayList<>() |
final Map< String, List< Channel< T > > > | _mySolicitedListenerTable = new HashMap<>() |
|
private |
|
private |
|
private |
void com.UniPRT.Sdk.Mgmt.AMgmtListenerChannels< T >.ListenerChannelConnect | ( | Channel< T > | chnlToReconnect, |
MgmtChannelFilterType | chnlType | ||
) |
void com.UniPRT.Sdk.Mgmt.AMgmtListenerChannels< T >.ListenerChannelConnect | ( | Channel< T > | chnlToReconnect, |
MgmtChannelFilterType | chnlType, | ||
String | solicitedMsgId | ||
) |
Connect or reconnect a channel for listening to messages.
solicitedMsgId only applies for channels of MgmtChannelFilterType::MY_SOLICITED_MSGS_ONLY or MgmtChannelFilterType::MY_SOLICITED_AND_UNSOLICITED_MSGS type.
Implements com.UniPRT.Sdk.Mgmt.IMgmtMsgListenerChannels< T >.
void com.UniPRT.Sdk.Mgmt.AMgmtListenerChannels< T >.ListenerChannelDisconnect | ( | Channel< T > | chnlToRemove | ) |
Disconnect channel. No more messages added to a channel that is disconnected, but the channel can be reconnected in the future.
Implements com.UniPRT.Sdk.Mgmt.IMgmtMsgListenerChannels< T >.
Referenced by com.UniPRT.Sdk.Mgmt.AMgmtListenerChannels< String >.ListenerChannelDisconnectPermanently().
void com.UniPRT.Sdk.Mgmt.AMgmtListenerChannels< T >.ListenerChannelDisconnectPermanently | ( | Channel< T > | chnlToRemove | ) |
Disconnect a channel permanently so that it cannot be reconnected.
Implements com.UniPRT.Sdk.Mgmt.IMgmtMsgListenerChannels< T >.
Channel<T> com.UniPRT.Sdk.Mgmt.AMgmtListenerChannels< T >.ListenerChannelGetNew | ( | int | capacity, |
MgmtChannelFilterType | chnlType | ||
) |
Channel<T> com.UniPRT.Sdk.Mgmt.AMgmtListenerChannels< T >.ListenerChannelGetNew | ( | int | capacity, |
MgmtChannelFilterType | chnlType, | ||
String | solicitedMsgId | ||
) |
Creates new channel for caller to listen for fully formed JSON msgs.
Channel that holds maximum msgs defined by capacity created where oldest items discarded if unread when newer entries added.
solicitedMsgId only applies for channels of SOLICITED_MSGS_ONLY type.
Implements com.UniPRT.Sdk.Mgmt.IMgmtMsgListenerChannels< T >.
Referenced by com.UniPRT.Sdk.Json.JsonComm.SendAndWaitForResponse().
void com.UniPRT.Sdk.Mgmt.AMgmtListenerChannels< T >.ListenerMsgDeposit | ( | T | msgToDeposit, |
String | solicitedMsgId | ||
) |
Referenced by com.UniPRT.Sdk.Json.JsonComm.SendAndWaitForMsgFrame().
|
private |
|
private |
|
private |
|
private |
|
private |
|
private |
|
private |
|
private |
|
private |
|
private |
Referenced by com.UniPRT.Sdk.Mgmt.AMgmtListenerChannels< String >.MySolicitedChannelList(), com.UniPRT.Sdk.Mgmt.AMgmtListenerChannels< String >.MySolicitedChannelList_Add(), com.UniPRT.Sdk.Mgmt.AMgmtListenerChannels< String >.MySolicitedChannelList_Remove(), com.UniPRT.Sdk.Mgmt.AMgmtListenerChannels< String >.mySolicitedListWithChannel(), and com.UniPRT.Sdk.Mgmt.AMgmtListenerChannels< String >.SolicitedChnlKey().
|
private |
Referenced by com.UniPRT.Sdk.Mgmt.AMgmtListenerChannels< String >.AddListenerChannel(), com.UniPRT.Sdk.Mgmt.AMgmtListenerChannels< String >.AddToMsgList(), com.UniPRT.Sdk.Mgmt.AMgmtListenerChannels< String >.ListenerChannelDisconnect(), and com.UniPRT.Sdk.Mgmt.AMgmtListenerChannels< String >.ListenerChannelDisconnectPermanently().