Class EchoRequest

  • All Implemented Interfaces:
    RpcRequest

    public class EchoRequest
    extends java.lang.Object
    implements RpcRequest
    • Constructor Detail

      • EchoRequest

        public EchoRequest()
      • EchoRequest

        public EchoRequest​(java.lang.String message)
    • Method Detail

      • setId

        public void setId​(java.lang.Long id)
      • getId

        public java.lang.Long getId()
      • setMessage

        public void setMessage​(java.lang.String message)
      • getMessage

        public java.lang.String getMessage()
      • getBody

        public java.lang.String getBody()
      • setBody

        public void setBody​(java.lang.String body)
        Set body when there is large message typically >500KB
        Parameters:
        body - set body
      • setLocation

        public void setLocation​(java.lang.String location)
      • getLocation

        public java.lang.String getLocation()
        Description copied from interface: RpcRequest
        Used to route the request to the appropriate location.
        Specified by:
        getLocation in interface RpcRequest
      • setSystemId

        public void setSystemId​(java.lang.String systemId)
      • getSystemId

        public java.lang.String getSystemId()
        Description copied from interface: RpcRequest
        Used to route the request to a particular system at the given location.
        Specified by:
        getSystemId in interface RpcRequest
      • setTimeToLiveMs

        public void setTimeToLiveMs​(java.lang.Long timeToLiveMs)
      • getTimeToLiveMs

        public java.lang.Long getTimeToLiveMs()
        Description copied from interface: RpcRequest
        When using JMS, the request will fail if no response was received in this many milliseconds.
        Specified by:
        getTimeToLiveMs in interface RpcRequest
      • getTracingInfo

        public java.util.Map<java.lang.String,​java.lang.String> getTracingInfo()
        Description copied from interface: RpcRequest
        RPC clients expose tracing info as tags there by giving more context to each RPC trace. Implementations should add tags defined above if they are available.
        Specified by:
        getTracingInfo in interface RpcRequest
      • getSpan

        public io.opentracing.Span getSpan()
        Specified by:
        getSpan in interface RpcRequest
      • addTracingInfo

        public void addTracingInfo​(java.lang.String key,
                                   java.lang.String value)
      • setDelay

        public void setDelay​(java.lang.Long delay)
      • getDelay

        public java.lang.Long getDelay()
      • shouldThrow

        public void shouldThrow​(boolean shouldThrow)
      • shouldThrow

        public boolean shouldThrow()
      • hashCode

        public int hashCode()
        Overrides:
        hashCode in class java.lang.Object
      • equals

        public boolean equals​(java.lang.Object obj)
        Overrides:
        equals in class java.lang.Object
      • toString

        public java.lang.String toString()
        Overrides:
        toString in class java.lang.Object