This commit is contained in:
parent
0865c8b1d7
commit
c676be8f0d
2 changed files with 9 additions and 1 deletions
|
|
@ -143,7 +143,7 @@ public class GatewayService extends QueueConsumer implements InitializingBean {
|
|||
if (requestInfoUpdate != null) return;
|
||||
|
||||
AssetOperationRequest assetOperationRequest = request.getRequestPayload();
|
||||
Map<String, Object> content = Map.of("direction", "IN",
|
||||
Map<String, Object> content = Map.of("direction", assetOperationRequest.getDirection(),
|
||||
"amount", assetOperationRequest.getAmount(),
|
||||
"code", assetOperationRequest.getCode(),
|
||||
"asset", assetOperationRequest.getSecuritySymbol(),
|
||||
|
|
|
|||
|
|
@ -57,4 +57,12 @@ public class AssetOperationRequest {
|
|||
public void setTradingCode(String tradingCode) {
|
||||
this.tradingCode = tradingCode;
|
||||
}
|
||||
|
||||
public String getDirection() {
|
||||
return direction;
|
||||
}
|
||||
|
||||
public void setDirection(String direction) {
|
||||
this.direction = direction;
|
||||
}
|
||||
}
|
||||
|
|
|
|||
Loading…
Add table
Reference in a new issue