package gw.plugin.messaging.impl

uses gw.plugin.messaging.MessageTransport
uses gw.api.system.PLLoggerCategory
uses com.guidewire.pl.system.entity.KeyUtil
uses org.slf4j.Logger
uses gw.pl.persistence.core.Key

class ConsoleMessageTransportNoAck implements MessageTransport {
  var _logger : Logger as readonly LOGGER = PLLoggerCategory.MESSAGING
  protected var _destinationID : int

  construct()
  {
    _logger.info("The ConsoleMessageTransport for destination " + _destinationID + " is initialized.")
  }

  override function send( message: Message, transformedPayload: String ) : void
  {
    _logger.info("\nDestination=" + message.DestinationID + " Msg ID=" + message.ID
       + " Primary=" + encode(message.PrimaryObjectKey)
       + " Root=" + encode(message.MessageRoot.ID)
       + " Payload=\"" + transformedPayload + "\"");
  }

  private function encode(key : Key) : String {
    if (key == null) {
      return "null"
    }
    return key.Type.RelativeName + ":" + key.Value
  }
  override function resume() : void
  {
    _logger.info("MessageTransport Destination " + _destinationID + " RESUME")
  }

  override property set DestinationID( destinationID: int ) : void
  {
    _destinationID = destinationID
  }

  override function shutdown() : void
  {
    _logger.info("MessageTransport Destination " + _destinationID + " SHUTDOWN")
  }

  override function suspend() : void
  {
    _logger.info("MessageTransport Destination " + _destinationID + " SUSPEND")
  }

}