As getProducerSIDestinationAddress() but for the consumer view of the destination.

@return SIDestinationAddress
@throws JMSException
979468
protected SIDestinationAddress getConsumerSIDestinationAddress() throws JMSException {
        if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
            SibTr.entry(this, tc, "getConsumerSIDestinationAddress");

        if (consumerDestinationAddress == null) {
            if (TraceComponent.isAnyTracingEnabled() && tc.isDebugEnabled())
                SibTr.debug(this, tc, "No cached value - create a new one.");

            // This variable should be initialised already since it is set up in the static
            // init for the class, which must have been run by the time we get to access it.

            // Establish whether this producer should be scoped to a local queue point only.
            boolean localOnly = isLocalOnly();

            // The consumer details are those that we use as the 'big' destination information.
            consumerDestinationAddress = JmsMessageImpl.destAddressFactory.createSIDestinationAddress(getConsumerDestName(), localOnly, getBusName());
        }

        if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
            SibTr.exit(this, tc, "getConsumerSIDestinationAddress", consumerDestinationAddress);
        return consumerDestinationAddress;
    }
749985
public String[] getArray()
  {
    
    // Create a copy to return to provide isolation.
    String[] newArray = null;
        
    // Returning a list of the destination names excluding the
    // 'big' destination name.
    newArray = new String[fullMsgPath.size()-1];
    for (int i = 0; i < newArray.length; i++)
    {
      newArray[i] = ((SIDestinationAddress)fullMsgPath.get(i)).getDestinationName();
    }//for
    
    return newArray;
  }
1066443
public final List<SIDestinationAddress> getReverseRoutingPath() {
        List<String> fNames = (List<String>) getHdr2().getField(JsHdr2Access.REVERSEROUTINGPATH_DESTINATIONNAME);
        List<byte[]> fMEs = (List<byte[]>) getHdr2().getField(JsHdr2Access.REVERSEROUTINGPATH_MEID);
        byte[] fLos = (byte[]) getHdr2().getField(JsHdr2Access.REVERSEROUTINGPATHLOCALONLY);
        List<String> fBuses = (List<String>) getHdr2().getField(JsHdr2Access.REVERSEROUTINGPATH_BUSNAME);
        return new RoutingPathList(fNames, fLos, fMEs, fBuses);
    }
262697
@Override
    public final Set<String> getPropertyNameSet() {
        if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
            SibTr.entry(this, tc, "getPropertyNameSet");

        /* Get the names of the real properties in the JMS Property Maps */
        Set<String> names = getNonSmokeAndMirrorsPropertyNameSet();

        /* Maelstrom's transportVersion may be in the specific variant field */
        if (isTransportVersionSet())
            names.add(MfpConstants.PRP_TRANSVER);

        /* JMSXAppId */
        if (getHdr2().getChoiceField(JsHdr2Access.XAPPID) != JsHdr2Access.IS_XAPPID_EMPTY) {
            names.add(SIProperties.JMSXAppID);
        }

        /* JMSXUserID */
        if (getUserid() != null) {
            names.add(SIProperties.JMSXUserID);
        }

        /* JMSXDeliveryCount is considered set if the message has been sent */
        if (isSent()) {
            names.add(SIProperties.JMSXDeliveryCount);
        }

        /* ARM Correlator */
        if (getARMCorrelator() != null) {
            names.add(SIProperties.JMS_IBM_ArmCorrelator);
            names.add(SIProperties.JMS_TOG_ARM_Correlator);
        }

        /* If any Exception field is set, all must be */
        if (getHdr2().getChoiceField(JsHdr2Access.EXCEPTION) != JsHdr2Access.IS_EXCEPTION_EMPTY) {
            names.add(SIProperties.JMS_IBM_ExceptionReason);
            names.add(SIProperties.JMS_IBM_ExceptionTimestamp);
            names.add(SIProperties.JMS_IBM_ExceptionMessage);
            /* ... but JMS_IBM_ExceptionProblemDestination could be set to null */
            if (getExceptionProblemDestination() != null) {
                names.add(SIProperties.JMS_IBM_ExceptionProblemDestination);
            }
            /* ... but JMS_IBM_ExceptionSubscription could also be set to null */
            if (getExceptionProblemSubscription() != null) {
                names.add(SIProperties.JMS_IBM_ExceptionProblemSubscription);
            }
        }

        /* If the SystemMessageId has been set, JMS_IBM_System_MessageID exists */
        if (getSystemMessageId() != null) {
            names.add(SIProperties.JMS_IBM_System_MessageID);
        }

        /* JMS_IBM_Feedback */
        if ((getApi().getChoiceField(JsApiAccess.REPORTFEEDBACK) != JsApiAccess.IS_REPORTFEEDBACK_UNSET) ||
            (getApi().getChoiceField(JsApiAccess.REPORTFEEDBACKINT) != JsApiAccess.IS_REPORTFEEDBACKINT_UNSET)) {
            names.add(SIProperties.JMS_IBM_Feedback);
        }

        /* JMS_IBM_Report_Xxxxxx */
        if (getHdr2().getChoiceField(JsHdr2Access.REPORTEXPIRY) != JsHdr2Access.IS_REPORTEXPIRY_UNSET) {
            names.add(SIProperties.JMS_IBM_Report_Expiration);
        }
        if (getHdr2().getChoiceField(JsHdr2Access.REPORTCOD) != JsHdr2Access.IS_REPORTCOD_UNSET) {
            names.add(SIProperties.JMS_IBM_Report_COD);
        }
        if (getHdr2().getChoiceField(JsHdr2Access.REPORTCOA) != JsHdr2Access.IS_REPORTCOA_UNSET) {
            names.add(SIProperties.JMS_IBM_Report_COA);
        }
        if (getApi().getChoiceField(JsApiAccess.REPORTEXCEPTION) != JsApiAccess.IS_REPORTEXCEPTION_UNSET) {
            names.add(SIProperties.JMS_IBM_Report_Exception);
        }
        if (getApi().getChoiceField(JsApiAccess.REPORTPAN) != JsApiAccess.IS_REPORTPAN_UNSET) {
            names.add(SIProperties.JMS_IBM_Report_PAN);
        }
        if (getApi().getChoiceField(JsApiAccess.REPORTNAN) != JsApiAccess.IS_REPORTNAN_UNSET) {
            names.add(SIProperties.JMS_IBM_Report_NAN);
        }
        if (getApi().getChoiceField(JsApiAccess.REPORTPASSMSGID) != JsApiAccess.IS_REPORTPASSMSGID_UNSET) {
            names.add(SIProperties.JMS_IBM_Report_Pass_Msg_ID);
        }
        if (getApi().getChoiceField(JsApiAccess.REPORTPASSCORRELID) != JsApiAccess.IS_REPORTPASSCORRELID_UNSET) {
            names.add(SIProperties.JMS_IBM_Report_Pass_Correl_ID);
        }
        if (getApi().getChoiceField(JsApiAccess.REPORTDISCARDMSG) != JsApiAccess.IS_REPORTDISCARDMSG_UNSET) {
            names.add(SIProperties.JMS_IBM_Report_Discard_Msg);
        }

        if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
            SibTr.exit(this, tc, "getPropertyNameSet", names);
        return names;

    }
1153800
@Override
    public void setProducerDoesNotModifyPayloadAfterSet(String propertyValue) throws JMSException {
        if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
            SibTr.entry(this, tc, "setProducerDoesNotModifyPayloadAfterSet", propertyValue);

        // First of all, convert null and empty to mean the default.
        if ((propertyValue == null) || ("".equals(propertyValue))) {
            jcaManagedConnectionFactory.setProducerDoesNotModifyPayloadAfterSet(ApiJmsConstants.MIGHT_MODIFY_PAYLOAD);
        }
        // Check for valid values
        else if (propertyValue.equalsIgnoreCase(ApiJmsConstants.MIGHT_MODIFY_PAYLOAD) ||
                 propertyValue.equalsIgnoreCase(ApiJmsConstants.WILL_NOT_MODIFY_PAYLOAD)) {
            jcaManagedConnectionFactory.setProducerDoesNotModifyPayloadAfterSet(propertyValue);
        }
        else {
            // This is not a legal value -> throw a JMS exception
            throw (JMSException) JmsErrorUtils.newThrowable(
                                                            JMSException.class, "INVALID_VALUE_CWSIA0261",
                                                            new Object[] { "producerDoesNotModifyPayloadAfterSet", propertyValue },
                                                            tc);
        }

        if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
            SibTr.exit(this, tc, "setProducerDoesNotModifyPayloadAfterSet");
    }
512910
@Override
	public com.liferay.commerce.model.CommerceAddress addCommerceAddress(
		com.liferay.commerce.model.CommerceAddress commerceAddress) {
		return _commerceAddressLocalService.addCommerceAddress(commerceAddress);
	}
1171038
@VisibleForTesting
  static ProcessIdentifier getProcessIdentifier(String jvmName, Timestamp censusTimestamp) {
    String hostname;
    int pid;
    // jvmName should be something like '<pid>@<hostname>', at least in Oracle and OpenJdk JVMs
    int delimiterIndex = jvmName.indexOf('@');
    if (delimiterIndex < 1) {
      // Not the expected format, generate a random number.
      try {
        hostname = InetAddress.getLocalHost().getHostName();
      } catch (UnknownHostException e) {
        hostname = "localhost";
      }
      // Generate a random number as the PID.
      pid = new SecureRandom().nextInt();
    } else {
      hostname = jvmName.substring(delimiterIndex + 1, jvmName.length());
      try {
        pid = Integer.parseInt(jvmName.substring(0, delimiterIndex));
      } catch (NumberFormatException e) {
        // Generate a random number as the PID if format is unexpected.
        pid = new SecureRandom().nextInt();
      }
    }

    return ProcessIdentifier.newBuilder()
        .setHostName(hostname)
        .setPid(pid)
        .setStartTimestamp(MetricsProtoUtils.toTimestampProto(censusTimestamp))
        .build();
  }
554568
@Override
	@Transactional(enabled = false)
	public CommerceAddress createCommerceAddress(long commerceAddressId) {
		return commerceAddressPersistence.create(commerceAddressId);
	}
119195
@Override
    public EndpointReferenceType getAddressWithId(String id) {
        EndpointReferenceType ref = null;

        if (isMultiplexWithAddress()) {
            String address = EndpointReferenceUtils.getAddress(reference);
            ref = EndpointReferenceUtils.duplicate(reference);
            if (address.endsWith("/")) {
                EndpointReferenceUtils.setAddress(ref, address + id);
            } else {
                EndpointReferenceUtils.setAddress(ref, address + "/" + id);
            }
        } else {
            ref = super.getAddressWithId(id);
        }
        return ref;
    }
82281
private function _calculateOrderTotalBasedOnBuyerDestinationAddress() 
    {
        $response = $this->callStepAndCheckForException('getOrderReferenceDetails');
        printGetOrderReferenceDetailsResponse($response);
        
        $orderTotalPreTaxAndShipping 
             = $this->_getPreTaxAndShippingOrderAmountFromStdIn();
        $shippingType = $this->_getShippingTypeFromStdIn();

        return $this->exampleClass->calculateOrderTotalBasedOnBuyerDetails(
            $response->getGetOrderReferenceDetailsResult()->getOrderReferenceDetails(),
            $orderTotalPreTaxAndShipping, 
            $shippingType
        );
    }
417962
private Destination getDestination(Session session, String queueName) throws JMSException {
    	return new DynamicDestinationResolver().resolveDestinationName(session, queueName, false);
	}
621835
public JmsDestinationType<ApplicationType<T>> getOrCreateJmsDestination()
   {
      List<Node> nodeList = childNode.get("jms-destination");
      if (nodeList != null &&  nodeList.size() > 0)
      {
         return new JmsDestinationTypeImpl<ApplicationType<T>>(this, "jms-destination", childNode, nodeList.get(0));
      }
      return createJmsDestination();
   }
1039276
public function getDeliveryAddress()
    {
        try {
            return AddressQuery::create()->findPk(
                $this->getRequest()->getSession()->getOrder()->getChoosenDeliveryAddress()
            );
        } catch (\Exception $ex) {
            throw new \LogicException("Failed to get delivery address (" . $ex->getMessage() . ")");
        }
    }
1046973
@Pure
	public LegalTrafficSide getLegalTrafficSide() {
		final String side;
		try {
			side = getAttributeAsString("LEGAL_TRAFFIC_SIDE"); //$NON-NLS-1$
			LegalTrafficSide sd;
			try {
				sd = LegalTrafficSide.valueOf(side);
			} catch (Throwable exception) {
				sd = null;
			}
			if (sd != null) {
				return sd;
			}
		} catch (Throwable exception) {
			//
		}
		return RoadNetworkConstants.getPreferredLegalTrafficSide();
	}
371276
public Address getRemoteParty() {
		if(sessionCreatingDialog != null) {
			return new AddressImpl(sessionCreatingDialog.getRemoteParty(), null, ModifiableRule.NotModifiable);
		} else if (sessionCreatingTransactionRequest != null){
			try {
				if(!isSessionCreatingTransactionServer) {
					ToHeader toHeader = (ToHeader)sessionCreatingTransactionRequest.getMessage().getHeader(ToHeader.NAME);
					return new AddressImpl(toHeader.getAddress(), AddressImpl.getParameters((Parameters)toHeader),  ModifiableRule.NotModifiable);
				} else {
					FromHeader fromHeader = (FromHeader)sessionCreatingTransactionRequest.getMessage().getHeader(FromHeader.NAME);
					return new AddressImpl(fromHeader.getAddress(), AddressImpl.getParameters((Parameters)fromHeader),  ModifiableRule.NotModifiable);
				}
			} catch(Exception e) {
				throw new IllegalArgumentException("Error creating Address", e);
			}
		} else {
			return remoteParty;
		}
	}
265501
@Override
    public SIDestinationAddress createTemporaryDestination(Distribution distribution,
                                                           String destinationPrefix)

                    throws SIConnectionUnavailableException, SIConnectionDroppedException,
                    SIResourceException, SIConnectionLostException, SILimitExceededException,
                    SIErrorException,
                    SINotAuthorizedException,
                    SIInvalidDestinationPrefixException
    {
        if (TraceComponent.isAnyTracingEnabled() && CoreSPIConnection.tc.isEntryEnabled())
            SibTr.entry(CoreSPIConnection.tc, "createTemporaryDestination",
                        new Object[] { this, destinationPrefix, distribution });

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

        // Check to make sure that the destination prefix is valid. 
        // If it's not, then we can't continue.
        String result = SICoreUtils.isDestinationPrefixValid(destinationPrefix);
        if (!result.equals(SICoreUtils.VALID)) // if its not valid there is something wrong
        {
            if (result.equals(SICoreUtils.MAX_LENGTH_EXCEEDED)) {// prefix length might have been exceeded
                if (TraceComponent.isAnyTracingEnabled() && CoreSPIConnection.tc.isEntryEnabled())
                    SibTr.exit(CoreSPIConnection.tc, "createTemporaryDestination", "SIInvalidDestinationPrefixException");
                throw new SIInvalidDestinationPrefixException(
                                nls.getFormattedMessage(
                                                        "INVALID_DESTINATION_PREFIX_MAX_LENGTH_ERROR_CWSIP0039",
                                                        null,
                                                        null));
            } else { // an invalid character is there in the prefix 

                if (TraceComponent.isAnyTracingEnabled() && CoreSPIConnection.tc.isEntryEnabled())
                    SibTr.exit(CoreSPIConnection.tc, "createTemporaryDestination", "SIInvalidDestinationPrefixException");
                throw new SIInvalidDestinationPrefixException(
                                nls.getFormattedMessage(
                                                        "INVALID_DESTINATION_PREFIX_CHAR_ERROR_CWSIP0040",
                                                        new Object[] { destinationPrefix, result },
                                                        null));
            }
        }

        SIDestinationAddress address = null;

        // Synchronize on the close object, we don't want the connection closing
        // while we try to add the temporary destination.
        synchronized (this)
        {
            // Check authority to create destination
            // If security is disabled then we'll bypass the check
            checkTempDestinationCreation((destinationPrefix == null ? "" : destinationPrefix), distribution);

            // Synchronize on the temporaryDestinations list object so that we can't collide
            // on creations. This will also ensure list integrity.
            synchronized (_temporaryDestinations)
            {
                //pass this on to the destination manager
                try
                {
                    address =
                                    _destinationManager.createTemporaryDestination(distribution, destinationPrefix);
                } catch (SIMPDestinationAlreadyExistsException e)
                {
                    // FFDC
                    FFDCFilter.processException(
                                                e,
                                                "com.ibm.ws.sib.processor.impl.ConnectionImpl.createTemporaryDestination",
                                                "1:3712:1.347.1.25",
                                                this);

                    SibTr.error(tc, "INTERNAL_MESSAGING_ERROR_CWSIP0002",
                                new Object[] {
                                              "com.ibm.ws.sib.processor.impl.ConnectionImpl",
                                              "1:3718:1.347.1.25",
                                              e });

                    // This should never be thrown
                    if (TraceComponent.isAnyTracingEnabled() && CoreSPIConnection.tc.isEntryEnabled())
                        SibTr.exit(CoreSPIConnection.tc, "createTemporaryDestination", "SIErrorException");
                    throw new SIErrorException(
                                    nls.getFormattedMessage(
                                                            "INTERNAL_MESSAGING_ERROR_CWSIP0002",
                                                            new Object[] {
                                                                          "com.ibm.ws.sib.processor.impl.ConnectionImpl",
                                                                          "1:3729:1.347.1.25",
                                                                          e },
                                                            null),
                                    e);
                }

                //add to list
                _temporaryDestinations.add(address.getDestinationName());
            }
        }

        if (TraceComponent.isAnyTracingEnabled() && CoreSPIConnection.tc.isEntryEnabled())
            SibTr.exit(CoreSPIConnection.tc, "createTemporaryDestination", address);

        return address;
    }
96109
@Override
	public com.liferay.commerce.model.CommerceAddress createCommerceAddress(
		long commerceAddressId) {
		return _commerceAddressLocalService.createCommerceAddress(commerceAddressId);
	}