public SIMPIterator getAttatchedRemoteSubscribers()
  {
    if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
      SibTr.entry(tc, "getAttatchedRemoteSubscribers");

    // TODO : This method needs to throw runtime invalid to admin
    SIMPIterator itr = null;
    try
    {
      ProtocolItemStream protocolItemStream =
        ((ProtocolItemStream)_streamSet.getItemStream());
      DestinationHandler destHandler = protocolItemStream.getDestinationHandler();

      itr =
        new BasicSIMPIterator(destHandler.getAOControlAdapterIterator());
    }
    catch (MessageStoreException e)
    {
      FFDCFilter.processException(
          e,
          "com.ibm.ws.sib.processor.runtime.InternalOutputStreamSetControl.getAttatchedRemoteSubscribers",
          "1:613:1.30",
          this);
      SibTr.exception(tc, e);
    }

    if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
      SibTr.exit(tc, "getAttatchedRemoteSubscribers", itr);
    return itr;
  }
public SIMPIterator getAttatchedRemoteSubscribers ( ) { if ( TraceComponent . isAnyTracingEnabled ( ) && tc . isEntryEnabled ( ) ) SibTr . entry ( tc , "getAttatchedRemoteSubscribers" ) ; SIMPIterator itr = null ; try { ProtocolItemStream protocolItemStream = ( ( ProtocolItemStream ) _streamSet . getItemStream ( ) ) ; DestinationHandler destHandler = protocolItemStream . getDestinationHandler ( ) ; itr = new BasicSIMPIterator ( destHandler . getAOControlAdapterIterator ( ) ) ; } catch ( MessageStoreException e ) { FFDCFilter . processException ( e , "com.ibm.ws.sib.processor.runtime.InternalOutputStreamSetControl.getAttatchedRemoteSubscribers" , "1:613:1.30" , this ) ; SibTr . exception ( tc , e ) ; } if ( TraceComponent . isAnyTracingEnabled ( ) && tc . isEntryEnabled ( ) ) SibTr . exit ( tc , "getAttatchedRemoteSubscribers" , itr ) ; return itr ; }
/* (non-Javadoc)
@see com.ibm.ws.sib.processor.runtime.SIMPPubSubOutboundTransmitControllable#getAttatchedRemoteSubscribers