Class CollectorRequestDTO

  • All Implemented Interfaces:
    RpcRequest

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

      • CollectorRequestDTO

        public CollectorRequestDTO()
    • Method Detail

      • 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
      • setClassName

        public void setClassName​(java.lang.String className)
      • getClassName

        public java.lang.String getClassName()
      • 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)
      • getAttributesNeedUnmarshaling

        public java.lang.Boolean getAttributesNeedUnmarshaling()
      • setAttributesNeedUnmarshaling

        public void setAttributesNeedUnmarshaling​(java.lang.Boolean attributesNeedUnmarshaling)
      • addAttribute

        public void addAttribute​(java.lang.String key,
                                 java.lang.Object value)
      • addAttributes

        public void addAttributes​(java.util.Map<java.lang.String,​java.lang.Object> attributes)
      • getParameters

        public java.util.Map<java.lang.String,​java.lang.Object> getParameters​(ServiceCollector collector)
      • 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