exchange.process(transferEvent -> {
                TransferEvent.EventType type = transferEvent.getType();
                try {
                    switch (type) {
                        case INITIATED:
                            delegate.transferInitiated(transferEvent);
                            break;
                        case STARTED:
                            delegate.transferStarted(transferEvent);

                                            <th><la:message key="labels.user_initials"/></th>
                                            <td>${f:h(attributes.initials)}<la:hidden
                                                    property="attributes.initials"/></td>
                                        </tr>
                                        <tr>

  private volatile StateSnapshot snapshot = new StateSnapshot(NEW);

  /** Constructor for use by subclasses. */
  protected AbstractService() {}

  /**
   * This method is called by {@link #startAsync} to initiate service startup. The invocation of
   * this method should cause a call to {@link #notifyStarted()}, either during this method's run,
   * or after it has returned. If startup fails, the invocation should cause a call to {@link

  private volatile StateSnapshot snapshot = new StateSnapshot(NEW);

  /** Constructor for use by subclasses. */
  protected AbstractService() {}

  /**
   * This method is called by {@link #startAsync} to initiate service startup. The invocation of
   * this method should cause a call to {@link #notifyStarted()}, either during this method's run,
   * or after it has returned. If startup fails, the invocation should cause a call to {@link

	}

	if target.natsConn != nil {
		target.natsConn.Close()
	}

	return nil
}

func (target *NATSTarget) init() error {
	return target.initOnce.Do(target.initNATS)
}

func (target *NATSTarget) initNATS() error {
	args := target.args

	var err error
	if args.Streaming.Enable {

labels.user_facsimileTelephoneNumber=Numéro de télécopieur
labels.facsimileTelephoneNumber=Numéro de télécopieur
labels.user_postOfficeBox=Boîte postale
labels.postOfficeBox=Boîte postale
labels.user_initials=Initiales
labels.initials=Initiales
labels.user_carLicense=Permis de conduire
labels.carLicense=Permis de conduire
labels.user_mobile=Mobile
labels.mobile=Mobile
labels.user_postalAddress=Adresse postale

	// Name of the object.
	Object string

	// Upload ID identifying the multipart upload whose parts are being listed.
	UploadID string

	// Date and time at which the multipart upload was initiated.
	Initiated time.Time

	// Any metadata set during InitMultipartUpload, including encryption headers.
	UserDefined map[string]string
}

// ListPartsInfo - represents list of all parts.
type ListPartsInfo struct {

labels.employeeType=Werknemerstype
labels.user_facsimileTelephoneNumber=Faxnummer
labels.facsimileTelephoneNumber=Faxnummer
labels.user_postOfficeBox=Postbus
labels.postOfficeBox=Postbus
labels.user_initials=Initialen
labels.initials=Initialen
labels.user_carLicense=Rijbewijs
labels.carLicense=Rijbewijs
labels.user_mobile=Mobiel
labels.mobile=Mobiel
labels.user_postalAddress=Postadres
labels.postalAddress=Postadres

  internal var errorException: IOException? = null

  init {
    if (headers != null) {
      check(!isLocallyInitiated) { "locally-initiated streams shouldn't have headers yet" }
      headersQueue += headers
    } else {
      check(isLocallyInitiated) { "remotely-initiated streams should have headers" }
    }
  }

  /**
   * Returns true if this stream is open. A stream is open until either:
   *

labels.user_facsimileTelephoneNumber=Número de fax
labels.facsimileTelephoneNumber=Número de fax
labels.user_postOfficeBox=Apartado de correos
labels.postOfficeBox=Apartado de correos
labels.user_initials=Iniciales
labels.initials=Iniciales
labels.user_carLicense=Licencia de conducir
labels.carLicense=Licencia de conducir
labels.user_mobile=Teléfono móvil
labels.mobile=Teléfono móvil
labels.user_postalAddress=Dirección postal