Documentation ¶
Index ¶
- Variables
- func HandleErrMsg(pbsData sendmodel.SendPayload, op *kafka.KafkaOpreations)
- func OFI_Camt026(sendPayload camt026pbstruct.SendPayload, op *kafka.KafkaOpreations)
- func OFI_Camt029(data camt029pbstruct.SendPayload, op *kafka.KafkaOpreations)
- func OFI_Ibwf001(data ibwf001pbstruct.SendPayload, op *kafka.KafkaOpreations)
- func OFI_Pacs002(data pacs002Pbstruct.SendPayload, op *kafka.KafkaOpreations)
- func RFI_Camt056(data camt056pbstruct.SendPayload, op *kafka.KafkaOpreations)
- func RFI_Camt087(data camt087pbstruct.SendPayload, op *kafka.KafkaOpreations)
- func RFI_Ibwf002(data ibwfPbStruct.SendPayload, op *kafka.KafkaOpreations)
- func RFI_Pacs008(sendPayload pbstruct.SendPayload, op *kafka.KafkaOpreations)
- func RFI_Pacs009(data pacs009Pbstruct.SendPayload, op *kafka.KafkaOpreations)
- type FbTrxLog
- type PaymentOperations
- func (op *PaymentOperations) Camt026(camt026 message_converter.Camt026) ([]byte, error)
- func (op *PaymentOperations) Camt029(camt029 message_converter.Camt029) ([]byte, error)
- func (op *PaymentOperations) Camt056(camt056 message_converter.Camt056) ([]byte, error)
- func (op *PaymentOperations) Camt087(camt087 message_converter.Camt087) ([]byte, error)
- func (op *PaymentOperations) Ibwf001(ibwf001 message_converter.Ibwf001) ([]byte, error)
- func (op *PaymentOperations) Ibwf002(ibwf002 message_converter.Ibwf002) ([]byte, error)
- func (op *PaymentOperations) Iso20022Validator(data []byte, bic, messageType, target string) ([]byte, error)
- func (op *PaymentOperations) Pacs002(pacs002 message_converter.Pacs002, target, BIC string) ([]byte, error)
- func (op *PaymentOperations) Pacs004_Cancellation(pacs004 message_converter.Pacs004) ([]byte, error)
- func (op *PaymentOperations) Pacs004_Rdo(pacs004 message_converter.Pacs004) ([]byte, error)
- func (op *PaymentOperations) Pacs008(pacs008 message_converter.Pacs008) ([]byte, error)
- func (op *PaymentOperations) Pacs009(pacs009 message_converter.Pacs009) ([]byte, error)
- func (op *PaymentOperations) ValidateRequest(raw *http.Request, bic, target string) ([]byte, []byte, string, error)
Constants ¶
This section is empty.
Variables ¶
var LOGGER = logging.MustGetLogger("message-handler")
Functions ¶
func HandleErrMsg ¶
func HandleErrMsg(pbsData sendmodel.SendPayload, op *kafka.KafkaOpreations)
Sending the error message back to Kafka when there's a error on the other side
func OFI_Camt026 ¶
func OFI_Camt026(sendPayload camt026pbstruct.SendPayload, op *kafka.KafkaOpreations)
camt.26 message handler at OFI side
func OFI_Camt029 ¶
func OFI_Camt029(data camt029pbstruct.SendPayload, op *kafka.KafkaOpreations)
if message type is camt.029
func OFI_Ibwf001 ¶
func OFI_Ibwf001(data ibwf001pbstruct.SendPayload, op *kafka.KafkaOpreations)
ibwf.001 message handler at OFI side
func OFI_Pacs002 ¶
func OFI_Pacs002(data pacs002Pbstruct.SendPayload, op *kafka.KafkaOpreations)
pacs.002 message handler at OFI side
func RFI_Camt056 ¶
func RFI_Camt056(data camt056pbstruct.SendPayload, op *kafka.KafkaOpreations)
if message type is camt.056
func RFI_Camt087 ¶
func RFI_Camt087(data camt087pbstruct.SendPayload, op *kafka.KafkaOpreations)
if message type is camt.087
func RFI_Ibwf002 ¶
func RFI_Ibwf002(data ibwfPbStruct.SendPayload, op *kafka.KafkaOpreations)
if message type is ibwf.002
func RFI_Pacs008 ¶
func RFI_Pacs008(sendPayload pbstruct.SendPayload, op *kafka.KafkaOpreations)
pacs.008 message handler at RFI side
func RFI_Pacs009 ¶
func RFI_Pacs009(data pacs009Pbstruct.SendPayload, op *kafka.KafkaOpreations)
pacs.009 message handler at RFI side
Types ¶
type PaymentOperations ¶
type PaymentOperations struct { XsdSchemas []*xsd.Schema KafkaActor *kafka.KafkaOpreations DbClient *DB.PostgreDatabaseClient ResponseHandler *parse.ResponseHandler // contains filtered or unexported fields }
func InitiatePaymentOperations ¶
func InitiatePaymentOperations() (PaymentOperations, error)
func (*PaymentOperations) Camt026 ¶
func (op *PaymentOperations) Camt026(camt026 message_converter.Camt026) ([]byte, error)
camt.26 message handler at RFI side
func (*PaymentOperations) Camt029 ¶
func (op *PaymentOperations) Camt029(camt029 message_converter.Camt029) ([]byte, error)
func (*PaymentOperations) Camt056 ¶
func (op *PaymentOperations) Camt056(camt056 message_converter.Camt056) ([]byte, error)
camt.056.001.08 FIToFIPaymentCancellationRequest The FIToFIPaymentCancellationRequest message supports both the request for cancellation (the instructed agent - or assignee - has not yet processed and forwarded the payment instruction) as well as the request for refund (payment has been fully processed already by the instructed agent - or assignee). A FIToFIPaymentCancellationRequest message concerns one and only one original payment instruction at a time. [Mandatory fields] Assignment - Identifies the assignment of an investigation case from an assigner to an assignee. Usage: The assigner must be the sender of this confirmation and the assignee must be the receiver. Underlying - Identifies the payment instruction to be cancelled.
func (*PaymentOperations) Camt087 ¶
func (op *PaymentOperations) Camt087(camt087 message_converter.Camt087) ([]byte, error)
func (*PaymentOperations) Ibwf001 ¶
func (op *PaymentOperations) Ibwf001(ibwf001 message_converter.Ibwf001) ([]byte, error)
ibwf.001 message handler at RFI side
func (*PaymentOperations) Ibwf002 ¶
func (op *PaymentOperations) Ibwf002(ibwf002 message_converter.Ibwf002) ([]byte, error)
func (*PaymentOperations) Iso20022Validator ¶
func (op *PaymentOperations) Iso20022Validator(data []byte, bic, messageType, target string) ([]byte, error)
validate signature & xml payload
func (*PaymentOperations) Pacs002 ¶
func (op *PaymentOperations) Pacs002(pacs002 message_converter.Pacs002, target, BIC string) ([]byte, error)
pacs.002 message handler at RFI side
func (*PaymentOperations) Pacs004_Cancellation ¶
func (op *PaymentOperations) Pacs004_Cancellation(pacs004 message_converter.Pacs004) ([]byte, error)
pacs.004.001.08 PaymentReturn The PaymentReturn message is sent by an agent to the previous agent in the payment chain to undo a payment previously settled.
The PaymentReturn message is exchanged between agents to return funds after settlement of credit transfer instructions (i.e. FIToFICustomerCreditTransfer message and FinancialInstitutionCreditTransfer message) or direct debit instructions (FIToFICustomerDirectDebit message).
func (*PaymentOperations) Pacs004_Rdo ¶
func (op *PaymentOperations) Pacs004_Rdo(pacs004 message_converter.Pacs004) ([]byte, error)
pacs.004.001.08 PaymentReturn
func (*PaymentOperations) Pacs008 ¶
func (op *PaymentOperations) Pacs008(pacs008 message_converter.Pacs008) ([]byte, error)
pacs.008 message handler at OFI side
func (*PaymentOperations) Pacs009 ¶
func (op *PaymentOperations) Pacs009(pacs009 message_converter.Pacs009) ([]byte, error)
pacs.009 message handler at OFI side
func (*PaymentOperations) ValidateRequest ¶
func (op *PaymentOperations) ValidateRequest(raw *http.Request, bic, target string) ([]byte, []byte, string, error)
validate incoming request