Public 成员函数 | |
AMgmtListenerChannels () | |
void | ListenerChannelDisconnect (Channel< T > chnlToRemove) |
断开通道。断开的通道不会再接收讯息,但未来可以重新连接。 更多... | |
void | ListenerChannelDisconnectPermanently (Channel< T > chnlToRemove) |
永久断开通道,使其无法重新连接。 更多... | |
Channel< T > | ListenerChannelGetNew (int capacity, MgmtChannelFilterType chnlType, String solicitedMsgId) |
创建新通道供调用者监听完整的JSON讯息。 更多... | |
Channel< T > | ListenerChannelGetNew (int capacity, MgmtChannelFilterType chnlType) |
void | ListenerChannelConnect (Channel< T > chnlToReconnect, MgmtChannelFilterType chnlType, String solicitedMsgId) |
连接或重新连接通道以接收讯息。 更多... | |
void | ListenerChannelConnect (Channel< T > chnlToReconnect, MgmtChannelFilterType chnlType) |
void | ListenerMsgDeposit (T msgToDeposit, String solicitedMsgId) |
Private 成员函数 | |
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 属性 | |
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 | ||
) |
连接或重新连接通道以接收讯息。
solicitedMsgId 仅适用于 MgmtChannelFilterType::MY_SOLICITED_MSGS_ONLY 或 MgmtChannelFilterType::MY_SOLICITED_AND_UNSOLICITED_MSGS 类型的通道。
void com.UniPRT.Sdk.Mgmt.AMgmtListenerChannels< T >.ListenerChannelDisconnect | ( | Channel< T > | chnlToRemove | ) |
断开通道。断开的通道不会再接收讯息,但未来可以重新连接。
实现了 com.UniPRT.Sdk.Mgmt.IMgmtMsgListenerChannels< T >.
被这些函数引用 com.UniPRT.Sdk.Mgmt.AMgmtListenerChannels< String >.ListenerChannelDisconnectPermanently().
void com.UniPRT.Sdk.Mgmt.AMgmtListenerChannels< T >.ListenerChannelDisconnectPermanently | ( | Channel< T > | chnlToRemove | ) |
永久断开通道,使其无法重新连接。
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 | ||
) |
创建新通道供调用者监听完整的JSON讯息。
通道中最多能容纳由 capacity 定义的讯息,若未读取时新增讯息,最旧的项目会被丢弃。 solicitedMsgId 仅适用于 SOLICITED_MSGS_ONLY 类型的通道。
实现了 com.UniPRT.Sdk.Mgmt.IMgmtMsgListenerChannels< T >.
被这些函数引用 com.UniPRT.Sdk.Json.JsonComm.SendAndWaitForResponse().
void com.UniPRT.Sdk.Mgmt.AMgmtListenerChannels< T >.ListenerMsgDeposit | ( | T | msgToDeposit, |
String | solicitedMsgId | ||
) |
|
private |
|
private |
|
private |
|
private |
|
private |
|
private |
|
private |
|
private |
|
private |
|
private |
被这些函数引用 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() , 以及 com.UniPRT.Sdk.Mgmt.AMgmtListenerChannels< String >.SolicitedChnlKey().
|
private |
被这些函数引用 com.UniPRT.Sdk.Mgmt.AMgmtListenerChannels< String >.AddListenerChannel(), com.UniPRT.Sdk.Mgmt.AMgmtListenerChannels< String >.AddToMsgList(), com.UniPRT.Sdk.Mgmt.AMgmtListenerChannels< String >.ListenerChannelDisconnect() , 以及 com.UniPRT.Sdk.Mgmt.AMgmtListenerChannels< String >.ListenerChannelDisconnectPermanently().