func (mexset *messageExchangeSet) IntrospectState(opts *IntrospectionOptions) ExchangeSetRuntimeState {
	mexset.RLock()
	setState := ExchangeSetRuntimeState{
		Name:  mexset.name,
		Count: len(mexset.exchanges),
	}

	if opts.IncludeExchanges {
		setState.Exchanges = make(map[string]ExchangeRuntimeState, len(mexset.exchanges))
		for k, v := range mexset.exchanges {
			state := ExchangeRuntimeState{
				ID:          k,
				MessageType: v.msgType,
			}
			setState.Exchanges[strconv.Itoa(int(k))] = state
		}
	}

	mexset.RUnlock()
	return setState
}
func (mexset *messageExchangeSet) IntrospectState(opts *IntrospectionOptions) ExchangeSetRuntimeState {
	mexset.RLock()
	setState := ExchangeSetRuntimeState{
		Name:  mexset.name,
		Count: len(mexset.exchanges),
	}

	if opts.IncludeExchanges {
		setState.Exchanges = make(map[string]ExchangeRuntimeState, len(mexset.exchanges))
		for k, v := range mexset.exchanges {
			state := ExchangeRuntimeState{
				ID:          k,
				MessageType: v.msgType,
			}
			setState.Exchanges[strconv.Itoa(int(k))] = state
		}
	}

	mexset.RUnlock()
	return setState
}
func ( mexset * messageExchangeSet ) IntrospectState ( opts * IntrospectionOptions ) ExchangeSetRuntimeState { mexset . RLock ( ) setState := ExchangeSetRuntimeState { Name : mexset . name , Count : len ( mexset . exchanges ) , } if opts . IncludeExchanges { setState . Exchanges = make ( map [ string ] ExchangeRuntimeState , len ( mexset . exchanges ) ) for k , v := range mexset . exchanges { state := ExchangeRuntimeState { ID : k , MessageType : v . msgType , } setState . Exchanges [ strconv . Itoa ( int ( k ) ) ] = state } } mexset . RUnlock ( ) return setState }
// IntrospectState returns the runtime state for this messsage exchange set.
IntrospectState returns the runtime state for this messsage exchange set .