Golang NewMessage示例

说明

golang newmessage示例是从最受好评的开源项目中提取的实现代码,你可以参考下面示例的使用方式。

编程语言: Golang

命名空间/包名称: github.com/quickfixgo/quickfix

示例#1
文件: unmarshal_test.go 项目: dbudworth/quickfix

func TestUnmarshal_Components(t *testing.T) {
	type Component1 struct {
		StringField string `fix:"8"`
	}
	type Component2 struct {
		IntField int `fix:"1"`
	}

	type Message struct {
		FIXMsgType string `fix:"0"`
		Component1
		StringField string `fix:"112"`
		*Component2
	}

	fixMsg := quickfix.NewMessage()
	fixMsg.Body.SetField(quickfix.Tag(8), quickfix.FIXString("hello"))
	fixMsg.Body.SetField(quickfix.Tag(112), quickfix.FIXString("world"))

	var msgOut Message
	quickfix.Unmarshal(fixMsg, &msgOut)

	if msgOut.Component1.StringField != "hello" {
		t.Errorf("Expected '%v' got '%v'", "hello", msgOut.Component1.StringField)
	}

	if msgOut.StringField != "world" {
		t.Errorf("Expected '%v' got '%v'", "world", msgOut.StringField)
	}
}

示例#2
文件: SecurityStatus.go 项目: jfyuen/quickfix

//New returns an initialized Message with specified required fields for SecurityStatus.
func New() Message {
	builder := Message{Message: quickfix.NewMessage()}
	builder.Header.Set(field.NewBeginString(enum.BeginStringFIXT11))
	builder.Header.Set(field.NewDefaultApplVerID(enum.ApplVerID_FIX50SP1))
	builder.Header.Set(field.NewMsgType("f"))
	return builder
}

示例#3
文件: AssignmentReport.go 项目: jfyuen/quickfix

//New returns an initialized Message with specified required fields for AssignmentReport.
func New(
	asgnrptid *field.AsgnRptIDField,
	accounttype *field.AccountTypeField,
	settlprice *field.SettlPriceField,
	settlpricetype *field.SettlPriceTypeField,
	underlyingsettlprice *field.UnderlyingSettlPriceField,
	assignmentmethod *field.AssignmentMethodField,
	openinterest *field.OpenInterestField,
	exercisemethod *field.ExerciseMethodField,
	settlsessid *field.SettlSessIDField,
	settlsesssubid *field.SettlSessSubIDField,
	clearingbusinessdate *field.ClearingBusinessDateField) Message {
	builder := Message{Message: quickfix.NewMessage()}
	builder.Header.Set(field.NewBeginString(enum.BeginStringFIX44))
	builder.Header.Set(field.NewMsgType("AW"))
	builder.Body.Set(asgnrptid)
	builder.Body.Set(accounttype)
	builder.Body.Set(settlprice)
	builder.Body.Set(settlpricetype)
	builder.Body.Set(underlyingsettlprice)
	builder.Body.Set(assignmentmethod)
	builder.Body.Set(openinterest)
	builder.Body.Set(exercisemethod)
	builder.Body.Set(settlsessid)
	builder.Body.Set(settlsesssubid)
	builder.Body.Set(clearingbusinessdate)
	return builder
}

示例#4
文件: unmarshal_test.go 项目: dbudworth/quickfix

func TestUnmarshal_HeaderTrailer(t *testing.T) {
	type Header struct {
		StringField string `fix:"49"`
	}
	type Trailer struct {
		IntField int `fix:"89"`
	}

	type Message struct {
		FIXMsgType  string `fix:"0"`
		StringField string `fix:"112"`
		Header
		Trailer
	}

	fixMsg := quickfix.NewMessage()
	fixMsg.Header.SetField(quickfix.Tag(35), quickfix.FIXString("0"))
	fixMsg.Header.SetField(quickfix.Tag(49), quickfix.FIXString("hello"))
	fixMsg.Body.SetField(quickfix.Tag(112), quickfix.FIXString("world"))
	fixMsg.Trailer.SetField(quickfix.Tag(89), quickfix.FIXInt(3))

	var msgOut Message
	quickfix.Unmarshal(fixMsg, &msgOut)

	if msgOut.Header.StringField != "hello" {
		t.Errorf("Expected '%v' got '%v'", "hello", msgOut.Header.StringField)
	}
	if msgOut.Trailer.IntField != 3 {
		t.Errorf("Expected '%v' got '%v'", 3, msgOut.Trailer.IntField)
	}

}

示例#5
文件: ExecutionReport.go 项目: jfyuen/quickfix

//New returns an initialized Message with specified required fields for ExecutionReport.
func New(
	orderid *field.OrderIDField,
	execid *field.ExecIDField,
	exectranstype *field.ExecTransTypeField,
	exectype *field.ExecTypeField,
	ordstatus *field.OrdStatusField,
	symbol *field.SymbolField,
	side *field.SideField,
	leavesqty *field.LeavesQtyField,
	cumqty *field.CumQtyField,
	avgpx *field.AvgPxField) Message {
	builder := Message{Message: quickfix.NewMessage()}
	builder.Header.Set(field.NewBeginString(enum.BeginStringFIX42))
	builder.Header.Set(field.NewMsgType("8"))
	builder.Body.Set(orderid)
	builder.Body.Set(execid)
	builder.Body.Set(exectranstype)
	builder.Body.Set(exectype)
	builder.Body.Set(ordstatus)
	builder.Body.Set(symbol)
	builder.Body.Set(side)
	builder.Body.Set(leavesqty)
	builder.Body.Set(cumqty)
	builder.Body.Set(avgpx)
	return builder
}

示例#6
文件: unmarshal_test.go 项目: dbudworth/quickfix

func TestUnmarshal_RepeatingGroups(t *testing.T) {
	type Group1 struct {
		StringField1 string  `fix:"8"`
		StringField2 *string `fix:"9"`
	}

	type Group2 struct {
		IntField1 int `fix:"1"`
		IntField2 int `fix:"2"`
	}

	type Message struct {
		FIXMsgType  string   `fix:"0"`
		GroupField1 []Group1 `fix:"100"`
		StringField string   `fix:"112"`
		GroupField2 []Group2 `fix:"101"`
	}

	fixMsg := quickfix.NewMessage()
	fixMsg.Body.SetField(quickfix.Tag(112), quickfix.FIXString("world"))

	group1Template := quickfix.GroupTemplate{
		quickfix.GroupElement(quickfix.Tag(8)),
		quickfix.GroupElement(quickfix.Tag(9)),
	}

	group1 := quickfix.RepeatingGroup{Tag: quickfix.Tag(100), GroupTemplate: group1Template}
	group1.Add().SetField(quickfix.Tag(8), quickfix.FIXString("hello")).SetField(quickfix.Tag(9), quickfix.FIXString("world"))
	group1.Add().SetField(quickfix.Tag(8), quickfix.FIXString("goodbye"))
	group1.Add().SetField(quickfix.Tag(8), quickfix.FIXString("OHHAI")).SetField(quickfix.Tag(9), quickfix.FIXString("world"))
	fixMsg.Body.SetGroup(group1)

	var msgOut Message
	quickfix.Unmarshal(fixMsg, &msgOut)

	if msgOut.StringField != "world" {
		t.Errorf("Expected '%v' got '%v'", "world", msgOut.StringField)
	}

	if len(msgOut.GroupField1) != 3 {
		t.Errorf("Expected group size '%v' got '%v'", 3, len(msgOut.GroupField1))
	}

	if msgOut.GroupField1[0].StringField1 != "hello" {
		t.Errorf("Expected %v got %v", "hello", msgOut.GroupField1[0].StringField1)
	}

	if *(msgOut.GroupField1[0].StringField2) != "world" {
		t.Errorf("Expected %v got %v", "world", *(msgOut.GroupField1[0].StringField2))
	}

	if msgOut.GroupField1[1].StringField1 != "goodbye" {
		t.Errorf("Expected %v got %v", "goodbye", msgOut.GroupField1[1].StringField1)
	}

	if msgOut.GroupField1[1].StringField2 != nil {
		t.Errorf("Expected stringfield 2 to be nil, got %v", *(msgOut.GroupField1[1].StringField2))
	}
}

示例#7
文件: SecurityTypeRequest.go 项目: jfyuen/quickfix

//New returns an initialized Message with specified required fields for SecurityTypeRequest.
func New(
	securityreqid *field.SecurityReqIDField) Message {
	builder := Message{Message: quickfix.NewMessage()}
	builder.Header.Set(field.NewBeginString(enum.BeginStringFIX44))
	builder.Header.Set(field.NewMsgType("v"))
	builder.Body.Set(securityreqid)
	return builder
}

示例#8
文件: MarketDataRequestReject.go 项目: jfyuen/quickfix

//New returns an initialized Message with specified required fields for MarketDataRequestReject.
func New(
	mdreqid *field.MDReqIDField) Message {
	builder := Message{Message: quickfix.NewMessage()}
	builder.Header.Set(field.NewBeginString(enum.BeginStringFIX43))
	builder.Header.Set(field.NewMsgType("Y"))
	builder.Body.Set(mdreqid)
	return builder
}

示例#9
文件: BidResponse.go 项目: jfyuen/quickfix

//New returns an initialized Message with specified required fields for BidResponse.
func New(
	nobidcomponents *field.NoBidComponentsField) Message {
	builder := Message{Message: quickfix.NewMessage()}
	builder.Header.Set(field.NewBeginString(enum.BeginStringFIX42))
	builder.Header.Set(field.NewMsgType("l"))
	builder.Body.Set(nobidcomponents)
	return builder
}

示例#10
文件: SecurityStatus.go 项目: jfyuen/quickfix

//New returns an initialized Message with specified required fields for SecurityStatus.
func New(
	symbol *field.SymbolField) Message {
	builder := Message{Message: quickfix.NewMessage()}
	builder.Header.Set(field.NewBeginString(enum.BeginStringFIX42))
	builder.Header.Set(field.NewMsgType("f"))
	builder.Body.Set(symbol)
	return builder
}

示例#11
文件: SequenceReset.go 项目: jfyuen/quickfix

//New returns an initialized Message with specified required fields for SequenceReset.
func New(
	newseqno *field.NewSeqNoField) Message {
	builder := Message{Message: quickfix.NewMessage()}
	builder.Header.Set(field.NewBeginString(enum.BeginStringFIX43))
	builder.Header.Set(field.NewMsgType("4"))
	builder.Body.Set(newseqno)
	return builder
}

示例#12
文件: MarketDataSnapshotFullRefresh.go 项目: jfyuen/quickfix

//New returns an initialized Message with specified required fields for MarketDataSnapshotFullRefresh.
func New(
	nomdentries *field.NoMDEntriesField) Message {
	builder := Message{Message: quickfix.NewMessage()}
	builder.Header.Set(field.NewBeginString(enum.BeginStringFIX43))
	builder.Header.Set(field.NewMsgType("W"))
	builder.Body.Set(nomdentries)
	return builder
}

示例#13
文件: ListStatusRequest.go 项目: jfyuen/quickfix

//New returns an initialized Message with specified required fields for ListStatusRequest.
func New(
	listid *field.ListIDField) Message {
	builder := Message{Message: quickfix.NewMessage()}
	builder.Header.Set(field.NewBeginString(enum.BeginStringFIX40))
	builder.Header.Set(field.NewMsgType("M"))
	builder.Body.Set(listid)
	return builder
}

示例#14
文件: QuoteAcknowledgement.go 项目: jfyuen/quickfix

//New returns an initialized Message with specified required fields for QuoteAcknowledgement.
func New(
	quoteackstatus *field.QuoteAckStatusField) Message {
	builder := Message{Message: quickfix.NewMessage()}
	builder.Header.Set(field.NewBeginString(enum.BeginStringFIX42))
	builder.Header.Set(field.NewMsgType("b"))
	builder.Body.Set(quoteackstatus)
	return builder
}

示例#15
文件: Reject.go 项目: jfyuen/quickfix

//New returns an initialized Message with specified required fields for Reject.
func New(
	refseqnum *field.RefSeqNumField) Message {
	builder := Message{Message: quickfix.NewMessage()}
	builder.Header.Set(field.NewBeginString(enum.BeginStringFIX40))
	builder.Header.Set(field.NewMsgType("3"))
	builder.Body.Set(refseqnum)
	return builder
}

示例#16
文件: TestRequest.go 项目: jfyuen/quickfix

//New returns an initialized Message with specified required fields for TestRequest.
func New(
	testreqid *field.TestReqIDField) Message {
	builder := Message{Message: quickfix.NewMessage()}
	builder.Header.Set(field.NewBeginString(enum.BeginStringFIX42))
	builder.Header.Set(field.NewMsgType("1"))
	builder.Body.Set(testreqid)
	return builder
}

示例#17
文件: Quote.go 项目: jfyuen/quickfix

//New returns an initialized Message with specified required fields for Quote.
func New(
	quoteid *field.QuoteIDField) Message {
	builder := Message{Message: quickfix.NewMessage()}
	builder.Header.Set(field.NewBeginString(enum.BeginStringFIX44))
	builder.Header.Set(field.NewMsgType("S"))
	builder.Body.Set(quoteid)
	return builder
}

示例#18
文件: QuoteCancel.go 项目: jfyuen/quickfix

//New returns an initialized Message with specified required fields for QuoteCancel.
func New(
	quotecanceltype *field.QuoteCancelTypeField) Message {
	builder := Message{Message: quickfix.NewMessage()}
	builder.Header.Set(field.NewBeginString(enum.BeginStringFIXT11))
	builder.Header.Set(field.NewDefaultApplVerID(enum.ApplVerID_FIX50SP2))
	builder.Header.Set(field.NewMsgType("Z"))
	builder.Body.Set(quotecanceltype)
	return builder
}

示例#19
文件: StreamAssignmentReport.go 项目: jfyuen/quickfix

//New returns an initialized Message with specified required fields for StreamAssignmentReport.
func New(
	streamasgnrptid *field.StreamAsgnRptIDField) Message {
	builder := Message{Message: quickfix.NewMessage()}
	builder.Header.Set(field.NewBeginString(enum.BeginStringFIXT11))
	builder.Header.Set(field.NewDefaultApplVerID(enum.ApplVerID_FIX50SP2))
	builder.Header.Set(field.NewMsgType("CD"))
	builder.Body.Set(streamasgnrptid)
	return builder
}

示例#20
文件: MassQuoteAcknowledgement.go 项目: jfyuen/quickfix

//New returns an initialized Message with specified required fields for MassQuoteAcknowledgement.
func New(
	quotestatus *field.QuoteStatusField) Message {
	builder := Message{Message: quickfix.NewMessage()}
	builder.Header.Set(field.NewBeginString(enum.BeginStringFIXT11))
	builder.Header.Set(field.NewDefaultApplVerID(enum.ApplVerID_FIX50))
	builder.Header.Set(field.NewMsgType("b"))
	builder.Body.Set(quotestatus)
	return builder
}

示例#21
文件: BidResponse.go 项目: jfyuen/quickfix

//New returns an initialized Message with specified required fields for BidResponse.
func New(
	nobidcomponents *field.NoBidComponentsField) Message {
	builder := Message{Message: quickfix.NewMessage()}
	builder.Header.Set(field.NewBeginString(enum.BeginStringFIXT11))
	builder.Header.Set(field.NewDefaultApplVerID(enum.ApplVerID_FIX50SP2))
	builder.Header.Set(field.NewMsgType("l"))
	builder.Body.Set(nobidcomponents)
	return builder
}

示例#22
文件: MarketDataSnapshotFullRefresh.go 项目: jfyuen/quickfix

//New returns an initialized Message with specified required fields for MarketDataSnapshotFullRefresh.
func New(
	nomdentries *field.NoMDEntriesField) Message {
	builder := Message{Message: quickfix.NewMessage()}
	builder.Header.Set(field.NewBeginString(enum.BeginStringFIXT11))
	builder.Header.Set(field.NewDefaultApplVerID(enum.ApplVerID_FIX50SP1))
	builder.Header.Set(field.NewMsgType("W"))
	builder.Body.Set(nomdentries)
	return builder
}

示例#23
文件: UserNotification.go 项目: jfyuen/quickfix

//New returns an initialized Message with specified required fields for UserNotification.
func New(
	userstatus *field.UserStatusField) Message {
	builder := Message{Message: quickfix.NewMessage()}
	builder.Header.Set(field.NewBeginString(enum.BeginStringFIXT11))
	builder.Header.Set(field.NewDefaultApplVerID(enum.ApplVerID_FIX50SP2))
	builder.Header.Set(field.NewMsgType("CB"))
	builder.Body.Set(userstatus)
	return builder
}

示例#24
文件: SecurityTypeRequest.go 项目: jfyuen/quickfix

//New returns an initialized Message with specified required fields for SecurityTypeRequest.
func New(
	securityreqid *field.SecurityReqIDField) Message {
	builder := Message{Message: quickfix.NewMessage()}
	builder.Header.Set(field.NewBeginString(enum.BeginStringFIXT11))
	builder.Header.Set(field.NewDefaultApplVerID(enum.ApplVerID_FIX50))
	builder.Header.Set(field.NewMsgType("v"))
	builder.Body.Set(securityreqid)
	return builder
}

示例#25
文件: ApplicationMessageRequestAck.go 项目: jfyuen/quickfix

//New returns an initialized Message with specified required fields for ApplicationMessageRequestAck.
func New(
	applresponseid *field.ApplResponseIDField) Message {
	builder := Message{Message: quickfix.NewMessage()}
	builder.Header.Set(field.NewBeginString(enum.BeginStringFIXT11))
	builder.Header.Set(field.NewDefaultApplVerID(enum.ApplVerID_FIX50SP2))
	builder.Header.Set(field.NewMsgType("BX"))
	builder.Body.Set(applresponseid)
	return builder
}

示例#26
文件: AllocationReportAck.go 项目: jfyuen/quickfix

//New returns an initialized Message with specified required fields for AllocationReportAck.
func New(
	allocreportid *field.AllocReportIDField) Message {
	builder := Message{Message: quickfix.NewMessage()}
	builder.Header.Set(field.NewBeginString(enum.BeginStringFIXT11))
	builder.Header.Set(field.NewDefaultApplVerID(enum.ApplVerID_FIX50SP2))
	builder.Header.Set(field.NewMsgType("AT"))
	builder.Body.Set(allocreportid)
	return builder
}

示例#27
文件: PartyDetailsListReport.go 项目: jfyuen/quickfix

//New returns an initialized Message with specified required fields for PartyDetailsListReport.
func New(
	partydetailslistreportid *field.PartyDetailsListReportIDField) Message {
	builder := Message{Message: quickfix.NewMessage()}
	builder.Header.Set(field.NewBeginString(enum.BeginStringFIXT11))
	builder.Header.Set(field.NewDefaultApplVerID(enum.ApplVerID_FIX50SP2))
	builder.Header.Set(field.NewMsgType("CG"))
	builder.Body.Set(partydetailslistreportid)
	return builder
}

示例#28
文件: ListStatusRequest.go 项目: jfyuen/quickfix

//New returns an initialized Message with specified required fields for ListStatusRequest.
func New(
	listid *field.ListIDField) Message {
	builder := Message{Message: quickfix.NewMessage()}
	builder.Header.Set(field.NewBeginString(enum.BeginStringFIXT11))
	builder.Header.Set(field.NewDefaultApplVerID(enum.ApplVerID_FIX50))
	builder.Header.Set(field.NewMsgType("M"))
	builder.Body.Set(listid)
	return builder
}

示例#29
文件: TradingSessionListUpdateReport.go 项目: jfyuen/quickfix

//New returns an initialized Message with specified required fields for TradingSessionListUpdateReport.
func New(
	notradingsessions *field.NoTradingSessionsField) Message {
	builder := Message{Message: quickfix.NewMessage()}
	builder.Header.Set(field.NewBeginString(enum.BeginStringFIXT11))
	builder.Header.Set(field.NewDefaultApplVerID(enum.ApplVerID_FIX50SP2))
	builder.Header.Set(field.NewMsgType("BS"))
	builder.Body.Set(notradingsessions)
	return builder
}

示例#30
文件: OrderStatusRequest.go 项目: jfyuen/quickfix

//New returns an initialized Message with specified required fields for OrderStatusRequest.
func New(
	side *field.SideField) Message {
	builder := Message{Message: quickfix.NewMessage()}
	builder.Header.Set(field.NewBeginString(enum.BeginStringFIXT11))
	builder.Header.Set(field.NewDefaultApplVerID(enum.ApplVerID_FIX50SP2))
	builder.Header.Set(field.NewMsgType("H"))
	builder.Body.Set(side)
	return builder
}

展开阅读全文