public class CollectorRequestDTO extends Object implements RpcRequest
TAG_CLASS_NAME, TAG_DESCRIPTION, TAG_IP_ADDRESS, TAG_NODE_ID, TAG_NODE_LABEL
Constructor and Description |
---|
CollectorRequestDTO() |
Modifier and Type | Method and Description |
---|---|
void |
addAttribute(String key,
Object value) |
void |
addAttributes(Map<String,Object> attributes) |
void |
addTracingInfo(String key,
String value) |
boolean |
equals(Object obj) |
CollectionAgent |
getAgent() |
List<CollectionAttributeDTO> |
getAttributes() |
Boolean |
getAttributesNeedUnmarshaling() |
String |
getClassName() |
String |
getLocation()
Used to route the request to the appropriate location.
|
Map<String,Object> |
getParameters(ServiceCollector collector) |
io.opentracing.Span |
getSpan() |
String |
getSystemId()
Used to route the request to a particular system at the given location.
|
Long |
getTimeToLiveMs()
When using JMS, the request will fail if no response was received in this
many milliseconds.
|
Map<String,String> |
getTracingInfo()
RPC clients expose tracing info as tags there by giving more context to each RPC trace.
|
int |
hashCode() |
void |
setAgent(CollectionAgent agent) |
void |
setAttributes(List<CollectionAttributeDTO> attributes) |
void |
setAttributesNeedUnmarshaling(Boolean attributesNeedUnmarshaling) |
void |
setClassName(String className) |
void |
setLocation(String location) |
void |
setSystemId(String systemId) |
void |
setTimeToLiveMs(Long timeToLiveMs) |
public CollectionAgent getAgent()
public void setAgent(CollectionAgent agent)
public void setLocation(String location)
public String getLocation()
RpcRequest
getLocation
in interface RpcRequest
public void setSystemId(String systemId)
public String getSystemId()
RpcRequest
getSystemId
in interface RpcRequest
public void setClassName(String className)
public String getClassName()
public void setTimeToLiveMs(Long timeToLiveMs)
public Long getTimeToLiveMs()
RpcRequest
getTimeToLiveMs
in interface RpcRequest
public Map<String,String> getTracingInfo()
RpcRequest
getTracingInfo
in interface RpcRequest
public io.opentracing.Span getSpan()
getSpan
in interface RpcRequest
public Boolean getAttributesNeedUnmarshaling()
public void setAttributesNeedUnmarshaling(Boolean attributesNeedUnmarshaling)
public List<CollectionAttributeDTO> getAttributes()
public void setAttributes(List<CollectionAttributeDTO> attributes)
public Map<String,Object> getParameters(ServiceCollector collector)
Copyright © 2021. All rights reserved.