cloudevents
/
sdk-javascript
mirror of https://github.com/cloudevents/sdk-javascript.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

curly 

Signed-off-by: Fabio José <fabiojose@gmail.com>
This commit is contained in:
Fabio José 2018-12-17 21:46:47 -02:00
parent 6088f5978a
commit a0596af829
1 changed files with 7 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
lib/bindings/http/binary_0_1.js
View File

@ -16,17 +16,20 @@ HTTPBinary.prototype.emit = function(cloudevent){
// Always set stuff in _config // Always set stuff in _config
var _headers = _config["headers"]; var _headers = _config["headers"];
if(cloudevent.getContenttype()) if(cloudevent.getContenttype()) {
_headers["Content-Type"] = cloudevent.getContenttype(); _headers["Content-Type"] = cloudevent.getContenttype();
}
_headers["CE-EventType"] = cloudevent.getType(); _headers["CE-EventType"] = cloudevent.getType();
if(cloudevent.getEventTypeVersion()) if(cloudevent.getEventTypeVersion()) {
_headers["CE-EventTypeVersion"] = cloudevent.getEventTypeVersion(); _headers["CE-EventTypeVersion"] = cloudevent.getEventTypeVersion();
}
_headers["CE-CloudEventsVersion"] = cloudevent.getSpecversion(); _headers["CE-CloudEventsVersion"] = cloudevent.getSpecversion();
_headers["CE-Source"] = cloudevent.getSource(); _headers["CE-Source"] = cloudevent.getSource();
_headers["CE-EventID"] = cloudevent.getId(); _headers["CE-EventID"] = cloudevent.getId();
if(cloudevent.getTime()) if(cloudevent.getTime()) {
_headers["CE-EventTime"] = cloudevent.getTime(); _headers["CE-EventTime"] = cloudevent.getTime();
}
_headers["CE-SchemaURL"] = cloudevent.getSchemaurl(); _headers["CE-SchemaURL"] = cloudevent.getSchemaurl();
// Set the cloudevent payload // Set the cloudevent payload