公開方法(Public Methods) | |
| 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 Methods) | |
| 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) |
私有屬性 | |
| 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 類型的通道。
| 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().