Retrieves the MQLink's PubSubBridge ItemStream

@param name of the MQLink
344293
@Override
    public ItemStream getMQLinkPubSubBridgeItemStream(String mqLinkUuidStr)
                    throws SIException
    {
        MQLinkHandler mqLinkHandler = null;
        ItemStream mqLinkPubSubBridgeItemStream = null;

        if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
            SibTr.entry(
                        tc,
                        "getMQLinkPubSubBridgeItemStream", mqLinkUuidStr);

        // See if this connection has been closed
        checkNotClosed();

        if (mqLinkUuidStr == null)
        {
            SIIncorrectCallException e =
                            new SIIncorrectCallException(
                                            nls.getFormattedMessage(
                                                                    "MISSING_PARAM_ERROR_CWSIP0029",
                                                                    new Object[] { "1:5583:1.347.1.25" },
                                                                    null));
            if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
            {
                SibTr.exception(tc, e);
                SibTr.exit(tc, "getMQLinkPubSubBridgeItemStream", e);
            }
            throw e;
        }

        SIBUuid8 mqLinkUuid = new SIBUuid8(mqLinkUuidStr);

        // Get the destination. It must be localised on this ME
        mqLinkHandler = _destinationManager.getMQLinkLocalization(mqLinkUuid, false);

        // Check the destination type
        if (mqLinkHandler == null)
        {
            if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
                SibTr.exit(tc, "getMQLinkPubSubBridgeItemStream", "SINotPossibleInCurrentConfigurationException");
            throw new SINotPossibleInCurrentConfigurationException(
                            nls.getFormattedMessage(
                                                    "MQLINK_PSB_ERROR_CWSIP0027",
                                                    new Object[] {
                                                                  mqLinkUuid,
                                                                  _messageProcessor.getMessagingEngineName() },
                                                    null));
        }

        // Got the right kind of handler, now get its itemstream
        mqLinkPubSubBridgeItemStream = mqLinkHandler.getMqLinkPubSubBridgeItemStream();

        if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
            SibTr.exit(tc, "getMQLinkPubSubBridgeItemStream", mqLinkPubSubBridgeItemStream);

        return mqLinkPubSubBridgeItemStream;
    }
1128454
@Override
	public Service getService(String name) {
		Service service = null;
		long stamp = lock.tryOptimisticRead();
		if (stamp != 0) {
			try {
				service = services.get(name);
			} catch (Exception modified) {
				stamp = 0;
			}
		}
		if (!lock.validate(stamp) || stamp == 0) {
			stamp = lock.readLock();
			try {
				service = services.get(name);
			} finally {
				lock.unlockRead(stamp);
			}
		}
		if (service == null) {
			throw new ServiceNotFoundError(nodeID, name);
		}
		return service;
	}
946171
public Object getAttribute(String name)
    throws IOException
  {
    if (_stream != null)
      return _stream.getAttribute(name);
    else
      return null;
  }
858447
static Map<String, Object> simplePayload(final String name) {
		if (name == null) {
			return null;
		}
		Map<String, Object> payload = new LinkedHashMap<>();
		payload.put("message", MSG_PREFIX + name);
		return payload;
	}
14764
public static netbridge_binding get(nitro_service service, String name) throws Exception{
		netbridge_binding obj = new netbridge_binding();
		obj.set_name(name);
		netbridge_binding response = (netbridge_binding) obj.get_resource(service);
		return response;
	}
883313
public PubSubMessageItemStream getPublishPoint()
    {
        if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
        {
            SibTr.entry(tc, "getPublishPoint");
            SibTr.exit(tc, "getPublishPoint", _pubsubMessageItemStream);
        }

        return _pubsubMessageItemStream;
    }
472331
public InputStream getResourceAsStream(final String name) {
        for ( final ClassLoader classLoader : this.classLoaders ) {
            InputStream stream = classLoader.getResourceAsStream( name );
            if ( stream != null ) {
                return stream;
            }
        }

        return null;
    }
1282054
public MessageArg get(String name) {
    return map == null ? null : map.get(name);
  }
490289
public static netbridge_iptunnel_binding[] get(nitro_service service, String name) throws Exception{
		netbridge_iptunnel_binding obj = new netbridge_iptunnel_binding();
		obj.set_name(name);
		netbridge_iptunnel_binding response[] = (netbridge_iptunnel_binding[]) obj.get_resources(service);
		return response;
	}
465253
public static MessageBatcher getBatcher(String name) {
		MessageBatcher batcher = batcherMap.get(name);
		return batcher;
	}
1349484
public static InputStream getResourceAsStream(String name) {
		// try with caller classloader
		ClassLoader loader = getClassLoaderContextAt(3);
		InputStream in = (loader == null) ? null : loader.getResourceAsStream(name);
		if (in == null) {
			// try with context classloader if set & different
			ClassLoader contextLoader = Thread.currentThread().getContextClassLoader();
			if (contextLoader != null && contextLoader != loader) {
				in = contextLoader.getResourceAsStream(name);
			}
		}
		return in;
	}
274125
private PublishMqDemoObject create(final String name, final ExecutionContext executionContext) {
        return executionContext.addResult(this, publishmqDemoObjects.create(name));
    }
43372
public static appflowpolicy_appflowpolicylabel_binding[] get(nitro_service service, String name) throws Exception{
		appflowpolicy_appflowpolicylabel_binding obj = new appflowpolicy_appflowpolicylabel_binding();
		obj.set_name(name);
		appflowpolicy_appflowpolicylabel_binding response[] = (appflowpolicy_appflowpolicylabel_binding[]) obj.get_resources(service);
		return response;
	}
851391
public T get(final String name) {
        for (final T i : this) {
            if (i.getName().equals(name)) {
                return i;
            }
        }
        return null;
    }
696688
public CassandraSink<IN> name(String name) {
		if (useDataStreamSink) {
			getSinkTransformation().setName(name);
		} else {
			getStreamTransformation().setName(name);
		}
		return this;
	}
1172066
public static SerializationFormat getInputFormat(String name) {
        for (SerializationFormat ft : Instance.serializationFormats) {
            if (ft.isAcceptedAsInput(name)) {
                return ft;
            }
        }
        return null;
    }
186745
public static String getTransferQueue(String name) {
        LOG.debug("对于需要保序的情况，只应该启动单个中转节点，目前启动多个节点原节点会被挤掉线,但是由于重连机制，会轮着挤掉线");
        return IdManager.generateStaticQueueId(buildTransferName(name));
    }