public PtoPMessageItemStream addNewRemotePtoPLocalization(
    TransactionCommon transaction,
    SIBUuid8 messagingEngineUuid,
    LocalizationDefinition destinationLocalizationDefinition,
    boolean queuePoint,
    AbstractRemoteSupport remoteSupport) throws SIResourceException
  {
    if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
      SibTr.entry(
        tc,
        "addNewRemotePtoPLocalization",
        new Object[] {
          transaction,
          messagingEngineUuid,
          destinationLocalizationDefinition,
          Boolean.valueOf(queuePoint),
          remoteSupport });

    PtoPMessageItemStream newMsgItemStream = null;

    // Add to the MessageStore
    try
    {

        if (queuePoint)
        {
          newMsgItemStream =
            new PtoPXmitMsgsItemStream(_baseDestinationHandler, messagingEngineUuid);
        }

      transaction.registerCallback(
        new LocalizationAddTransactionCallback(newMsgItemStream));

      Transaction msTran = _messageProcessor.resolveAndEnlistMsgStoreTransaction(transaction);
      _baseDestinationHandler.addItemStream(newMsgItemStream, msTran);

      // Set the default limits
      newMsgItemStream.setDefaultDestLimits();
      // Setup any message depth interval checking (510343)
      newMsgItemStream.setDestMsgInterval();

      attachRemotePtoPLocalisation(newMsgItemStream, remoteSupport);
    }
    catch (OutOfCacheSpace e)
    {
      // No FFDC code needed

      SibTr.exception(tc, e);

      if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
        SibTr.exit(tc, "addNewRemotePtoPLocalization", "SIResourceException");

      throw new SIResourceException(e);
    }
    catch (MessageStoreException e)
    {
      // MessageStoreException shouldn't occur so FFDC.
      FFDCFilter.processException(
        e,
        "com.ibm.ws.sib.processor.impl.destination.LocalisationManager.addNewRemotePtoPLocalization",
        "1:1562:1.30",
        this);

      SibTr.exception(tc, e);

      if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
        SibTr.exit(tc, "addNewRemotePtoPLocalization", e);

      throw new SIResourceException(e);
    }

    if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
      SibTr.exit(tc, "addNewRemotePtoPLocalization", newMsgItemStream);

    return newMsgItemStream;
  }
public PtoPMessageItemStream addNewRemotePtoPLocalization ( TransactionCommon transaction , SIBUuid8 messagingEngineUuid , LocalizationDefinition destinationLocalizationDefinition , boolean queuePoint , AbstractRemoteSupport remoteSupport ) throws SIResourceException { if ( TraceComponent . isAnyTracingEnabled ( ) && tc . isEntryEnabled ( ) ) SibTr . entry ( tc , "addNewRemotePtoPLocalization" , new Object [ ] { transaction , messagingEngineUuid , destinationLocalizationDefinition , Boolean . valueOf ( queuePoint ) , remoteSupport } ) ; PtoPMessageItemStream newMsgItemStream = null ; try { if ( queuePoint ) { newMsgItemStream = new PtoPXmitMsgsItemStream ( _baseDestinationHandler , messagingEngineUuid ) ; } transaction . registerCallback ( new LocalizationAddTransactionCallback ( newMsgItemStream ) ) ; Transaction msTran = _messageProcessor . resolveAndEnlistMsgStoreTransaction ( transaction ) ; _baseDestinationHandler . addItemStream ( newMsgItemStream , msTran ) ; newMsgItemStream . setDefaultDestLimits ( ) ; newMsgItemStream . setDestMsgInterval ( ) ; attachRemotePtoPLocalisation ( newMsgItemStream , remoteSupport ) ; } catch ( OutOfCacheSpace e ) { SibTr . exception ( tc , e ) ; if ( TraceComponent . isAnyTracingEnabled ( ) && tc . isEntryEnabled ( ) ) SibTr . exit ( tc , "addNewRemotePtoPLocalization" , "SIResourceException" ) ; throw new SIResourceException ( e ) ; } catch ( MessageStoreException e ) { FFDCFilter . processException ( e , "com.ibm.ws.sib.processor.impl.destination.LocalisationManager.addNewRemotePtoPLocalization" , "1:1562:1.30" , this ) ; SibTr . exception ( tc , e ) ; if ( TraceComponent . isAnyTracingEnabled ( ) && tc . isEntryEnabled ( ) ) SibTr . exit ( tc , "addNewRemotePtoPLocalization" , e ) ; throw new SIResourceException ( e ) ; } if ( TraceComponent . isAnyTracingEnabled ( ) && tc . isEntryEnabled ( ) ) SibTr . exit ( tc , "addNewRemotePtoPLocalization" , newMsgItemStream ) ; return newMsgItemStream ; }
Method addNewRemotePtoPLocalisation
<p> Suppports the addition of a new remote PtoP Localisation of a
destination.
@param transaction
@param messagingEngineUuid
@param destinationLocalizationDefinition
@param queuePoint
@return
@throws SIResourceException