公開方法(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().