Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Msgpack content type 0.12 #1505

Closed
wants to merge 233 commits into from
Closed
Show file tree
Hide file tree
Changes from 1 commit
Commits
Show all changes
233 commits
Select commit Hold shift + click to select a range
53459ad
Add `config_set_desc`
okkez Oct 16, 2015
59225ed
Add `desc` method
okkez Oct 16, 2015
76d5292
Add descriptions to in_dummy plugin parameters
okkez Oct 16, 2015
99e30ec
Doc: update README with Slack Team info
edsiper Oct 21, 2015
95e0151
Don't use popular name to prevent field overwrite when enable_ruby is…
repeatedly Oct 26, 2015
e90135a
in_monitor_agent emits plugins info to use exisiting plugins. fix #667
repeatedly Sep 4, 2015
64b613f
Log shutdown plugin info to check shutdown sequence
repeatedly Oct 27, 2015
fce745f
Tempfile should be binary mode
repeatedly Oct 28, 2015
988dbe8
Forgot to add v0.12 test in travis-ci
repeatedly Oct 29, 2015
aac0b72
Add Engine#msgpack_factory for v0.14 compatibility
repeatedly Oct 29, 2015
c3185fc
Use *args to forward all method arguments
repeatedly Oct 30, 2015
267cbb1
Merge pull request #693 from fluent/add-msgpack-factory-api
repeatedly Nov 2, 2015
d671123
Update test-unit gem to 3.1.4
repeatedly Nov 4, 2015
f03ee90
v0.12.17
repeatedly Nov 4, 2015
694af8b
Merge pull request #701 from cosmo0920/add-descriptions-out_file
repeatedly Nov 13, 2015
a9131db
Merge pull request #707 from fluent/forward-reject-empty
repeatedly Nov 24, 2015
6772784
Merge pull request #708 from fluent/support-process-name-configuration
repeatedly Nov 25, 2015
4e7e801
Merge pull request #702 from cosmo0920/add-parser-test-driver
repeatedly Nov 25, 2015
aa80092
Merge pull request #710 from tagomoris/safe-detach-process
repeatedly Nov 25, 2015
1080a53
Merge pull request #713 from okkez/add-descriptions-filter-record-tra…
sonots Nov 27, 2015
8214726
Merge pull request #714 from okkez/add-descriptions-filter-stdout
sonots Nov 27, 2015
f8b9f0c
Merge pull request #715 from okkez/add-description-to-log-level
sonots Nov 27, 2015
199cd75
Merge pull request #716 from okkez/add-descriptions-in-exec
sonots Nov 27, 2015
e5c19b4
Merge pull request #717 from okkez/add-descriptions-in-forward
sonots Nov 27, 2015
85013f9
Merge pull request #720 from okkez/add-descriptions-in-tcp
sonots Nov 27, 2015
fffddc0
Merge pull request #723 from okkez/add-descriptions-out-copy
sonots Nov 27, 2015
98cedf2
Merge pull request #722 from okkez/add-descriptions-buffer
sonots Nov 27, 2015
2bf6235
Merge pull request #721 from okkez/add-descriptions-base-input
sonots Nov 27, 2015
ed1701b
Merge pull request #724 from fluent/fix_delayed_forwarder
repeatedly Nov 28, 2015
552d101
Merge pull request #718 from okkez/add-descriptions-in-http
repeatedly Dec 3, 2015
c1dd17e
Merge pull request #727 from okkez/add-descriptions-in-unix
repeatedly Dec 3, 2015
4524970
Merge pull request #728 from okkez/add-descriptions-out-exec-filter
repeatedly Dec 3, 2015
6f4fe9c
Merge pull request #729 from okkez/add-descriptions-out-forward
repeatedly Dec 3, 2015
cdaddc4
Merge pull request #730 from okkez/add-descriptions-out-stdout
repeatedly Dec 3, 2015
5391dd1
Merge pull request #732 from okkez/add-descriptions-in-syslog
repeatedly Dec 3, 2015
a6904e3
Merge pull request #712 from cosmo0920/add-formatter-test-driver
repeatedly Dec 3, 2015
2b20c3f
Merge pull request #706 from okkez/show-plugin-config-ancestors
repeatedly Dec 3, 2015
9456270
Merge pull request #719 from okkez/add-descriptions-in-tail
repeatedly Dec 4, 2015
aace26c
Merge pull request #704 from fluent/support-text-parser-in-exec
repeatedly Dec 4, 2015
0d3f856
Merge pull request #733 from cosmo0920/desc-out-exec
repeatedly Dec 4, 2015
24ce769
Merge pull request #734 from icyfork/in_tail-exclude_all_unreadable_f…
repeatedly Dec 7, 2015
d288762
test should not use v0.14 assert
repeatedly Dec 8, 2015
f2b92e7
Update travis to follow master branch
repeatedly Dec 8, 2015
4f6ecff
Merge pull request #526 from sabottenda/fix-in_exec-shutdown
repeatedly Dec 8, 2015
1e46058
v0.12.18
repeatedly Dec 9, 2015
4ca4cad
Merge pull request #743 from skippy/standardize-input-logging
repeatedly Dec 10, 2015
b96be61
Merge pull request #747 from fluent/fix-fluent-cat
repeatedly Dec 16, 2015
cd01f11
Add fluent/time.rb placeholder for v0.14
repeatedly Dec 21, 2015
d179ee9
Merge pull request #748 from fluent/support-oj-in-json-parser
repeatedly Dec 18, 2015
316d3de
Merge pull request #745 from fluent/add-block-action-to-buffer
repeatedly Dec 20, 2015
3e26b97
0.12 doesn't have EventTime
repeatedly Dec 21, 2015
920645a
v0.12.19
repeatedly Dec 21, 2015
232c38a
Merge pull request #766 from sonots/fast_record_transformer
sonots Jan 8, 2016
8a246d3
Merge pull request #757 from riywo/patch-1
repeatedly Dec 27, 2015
7f6b47a
Merge pull request #761 from okkez/suppress-warning
sonots Dec 29, 2015
d063ac8
Merge pull request #759 from okkez/add-descriptions-output
sonots Dec 29, 2015
b835c07
Merge pull request #760 from okkez/add-descriptions-for-time-sliced-o…
sonots Dec 29, 2015
2e94560
Merge pull request #765 from fluent/fix-regression-of-unused-paramete…
repeatedly Jan 6, 2016
03865d4
Merge pull request #763 from cosmo0920/travis-ruby-2.3.0
repeatedly Jan 6, 2016
c3b7d86
Merge pull request #762 from fluent/input_output_test_driver_num_waits
repeatedly Jan 6, 2016
3611106
Merge pull request #778 from fluent/fix-773
repeatedly Jan 17, 2016
2346830
Merge pull request #775 from kikumoto/multiline_periodic_flush
repeatedly Jan 17, 2016
413738b
Merge pull request #781 from ysksn/add_some_objects
repeatedly Jan 21, 2016
b4bc709
Merge pull request #776 from fluent/add-skip-invalid-event
repeatedly Jan 23, 2016
d20398c
v0.12 doesn't have EventTime
repeatedly Jan 25, 2016
e89da82
v0.12.20
repeatedly Jan 25, 2016
0da3442
Merge pull request #791 from fluent/use-error-stream-in-tsoutput-emit
repeatedly Feb 4, 2016
aee8086
Merge pull request #797 from fluent/skip-broken-event-in-tsoutput
repeatedly Feb 9, 2016
d1ba7d8
Merge pull request #794 from fluent/separate-system-config
tagomoris Feb 9, 2016
eb1478d
Merge pull request #795 from fluent/hash-syntax
tagomoris Feb 9, 2016
14bfef2
Merge pull request #805 from cosmo0920/v0.12-separate-system-config
repeatedly Feb 16, 2016
9beac48
Merge pull request #806 from cosmo0920/v0.12-hash-syntax
repeatedly Feb 16, 2016
6802dc2
Fix to do `require` for required files straightforward, per files
tagomoris Feb 9, 2016
8484c77
Merge pull request #808 from okkez/fix-dependencies-between-files-v0.12
repeatedly Mar 2, 2016
212f4f8
Merge pull request #788 from dwoo4dwoo/reduce_tail_opens
repeatedly Feb 12, 2016
51786e6
Merge pull request #802 from fluent/fix-in_monitor_agent-debug
repeatedly Feb 14, 2016
be46bbf
Merge pull request #809 from okkez/dont-require-rubygems
tagomoris Feb 19, 2016
dd0a2f3
Merge pull request #811 from dwoo4dwoo/disable_watch_timer
repeatedly Feb 27, 2016
a1e2005
Merge pull request #816 from fluent/fix_record_transformer_race
repeatedly Mar 1, 2016
1471632
Merge pull request #817 from fluent/relax_auto_typecast
repeatedly Mar 2, 2016
27cf781
FileWrapper is introduced since v0.14. Don't use in v0.12
repeatedly Mar 2, 2016
41d1724
Merge pull request #810 from fluent/fix-in_tail-for-bqle
repeatedly Mar 2, 2016
c90a1b2
Merge pull request #821 from fluent/enum-list-must-be-of-symbols
repeatedly Mar 2, 2016
a9dfedd
Merge pull request #822 from fluent/fix-set-system-config-in-sighup
repeatedly Mar 2, 2016
556cc58
Add missing require
okkez Mar 3, 2016
c1e736c
Add missing require
cosmo0920 Mar 3, 2016
46f825f
Add missing require
cosmo0920 Mar 3, 2016
3759231
Merge pull request #823 from okkez/add-missing-require
repeatedly Mar 3, 2016
ff0738f
Add missing require
cosmo0920 Mar 3, 2016
3b3c267
Merge pull request #826 from cosmo0920/add-missing-require-for-filter
repeatedly Mar 3, 2016
2eab62b
Merge pull request #824 from cosmo0920/add-missing-require-for-versio…
repeatedly Mar 3, 2016
d0cdded
Merge pull request #825 from cosmo0920/add-missing-require-for-mixin
repeatedly Mar 3, 2016
b585e9f
Add missing require
okkez Mar 4, 2016
c028103
Merge pull request #828 from okkez/add-missing-require-for-input-plug…
repeatedly Mar 4, 2016
dae7268
v0.12.21
repeatedly Mar 4, 2016
386ff3e
Merge pull request #845 from fluent/fix-missing-fcntl
repeatedly Mar 11, 2016
282af78
v0.12.22
repeatedly Mar 11, 2016
a227d97
Merge pull request #891 from cosmo0920/fix-broken-fluent-debug-command
tagomoris Apr 11, 2016
73b5471
Merge pull request #894 from cosmo0920/fix-broken-fluent-debug-comman…
repeatedly Apr 11, 2016
099ae2d
Add test for log related class and module
okkez Apr 28, 2016
25a51a1
Fix logger on Fluent::StringUtil to use $log.
toyama0919 Apr 20, 2016
49bdb09
fix assigning an object with unconsistent API
tagomoris Apr 22, 2016
a34f668
Fix string-scrub dependency on ruby > 2
errm May 4, 2016
c6a46d4
Merge pull request #933 from errm/v0.12
repeatedly May 4, 2016
dcdbda2
v0.12.23
repeatedly May 4, 2016
2050bd7
Add support for drop_oldest_chunk when buffer queue is full
varunkumta May 4, 2016
edc4354
Fix string-scrub dependency
okkez May 9, 2016
6e8e0ed
Add missing require when we use Ruby 2.0 or 1.9.3
okkez May 9, 2016
93661a1
Add simplified syntax for hash and array
tagomoris Mar 31, 2016
87e17d9
Fix option name from type to value_type (type is already used by para…
tagomoris Mar 31, 2016
1a2638a
add test cases for LCSV
tagomoris Mar 31, 2016
2188635
fix misleading name
tagomoris Apr 4, 2016
2443758
Merge pull request #937 from okkez/fix-string-scrub-dependency
repeatedly May 9, 2016
7031bfa
Merge pull request #934 from varunkumta/v0.12
repeatedly May 11, 2016
4d82f0d
Merge pull request #927 from okkez/backport-913
repeatedly May 16, 2016
a710558
Merge pull request #925 from okkez/backport-909
repeatedly May 16, 2016
21ea8a5
Merge pull request #926 from okkez/backport-907
repeatedly May 16, 2016
4e0032f
add error class definition which is used but not defined yet
tagomoris Apr 27, 2016
e96e88b
Merge pull request #953 from okkez/add-missing-error-class
repeatedly May 16, 2016
1665c54
Merge pull request #882 from HatsuneMiku3939/in-http-add-access-contr…
repeatedly Apr 5, 2016
1c923ce
Merge pull request #889 from miyakawataku/encoding-param-for-tail-plugin
repeatedly Apr 20, 2016
31c7d01
Merge pull request #908 from yuuki1224/patch-2
repeatedly Apr 20, 2016
2c461a1
Merge pull request #951 from fluent/tail_path
repeatedly May 16, 2016
688db77
Add support for emit_config to in_monitor_agent
varunkumta May 17, 2016
fc67f7c
Merge pull request #963 from varunkumta/v0.12
repeatedly May 18, 2016
d1b5902
Merge pull request #957 from fluent/fix_test_in_tail
sonots May 16, 2016
94835eb
travis-ci: Move 1.9.3 test to allow_failures
repeatedly May 19, 2016
b7415c2
Merge pull request #929 from llby/support-multiline-string-in-quoted-…
repeatedly May 10, 2016
5e491f8
v0.12.24
repeatedly May 20, 2016
9335556
Make the detach process forward interval configurable
May 23, 2016
91bf682
Revert: Fix string-scrub dependency #937 (only gemspec)
sonots May 24, 2016
6059d56
Use Config.time_value instead of to_f
May 24, 2016
f87d9a5
Merge pull request #982 from cbroglie/v0.12
repeatedly May 24, 2016
0ba2dd7
Merge pull request #986 from sonots/fix_string_scrub_for_ruby_2.0
repeatedly May 24, 2016
bd53e87
v0.12.25
repeatedly May 25, 2016
fec6898
fix test drivers to work well for blocks with d.emit, and ObjectBuffe…
tagomoris Apr 27, 2016
e8200aa
fix test with added (missing) error definition
tagomoris Apr 27, 2016
dcfa064
Define `ForwardOutput#format_stream` for test
okkez May 30, 2016
3608377
Merge pull request #954 from okkez/fix-test-for-out_forward
repeatedly May 30, 2016
43c42a9
Fix regression of not require sigdump
repeatedly May 30, 2016
dc4e6d7
v0.12.26
repeatedly May 30, 2016
35cb7b1
Fix regression of fluent-debug command. fix #1035
repeatedly Jun 10, 2016
377b99c
Merge pull request #1046 from fluent/fix-fluent-debug
repeatedly Jun 10, 2016
da58b73
Merge pull request #939 from okkez/backport-875
repeatedly Jun 15, 2016
65ea435
Merge pull request #1051 from HatsuneMiku3939/in_http_x_forwarded-for
repeatedly Jun 15, 2016
3e5e4e8
Merge pull request #950 from llby/add-include-support-for-ruby-dsl
tagomoris Jun 16, 2016
8db2a39
fix test driver for TimeSlicedOutput
tagomoris Apr 26, 2016
75dfa1e
fix to use TimeSlicedOutputTestDriver in tests of out_file
tagomoris Apr 26, 2016
4a6d5dc
Merge pull request #941 from okkez/backport-916
repeatedly Jul 1, 2016
7820151
Merge pull request #1127 from fluent/configurable-body-size-limit-for…
tagomoris Jul 28, 2016
17fa0d6
Add json 2.0 or later error message to regexp
cosmo0920 Jul 29, 2016
f1d12c2
Fix wrong message for unsupported parameter. fix #1039
repeatedly Jul 29, 2016
414bf9b
Merge pull request #1128 from cosmo0920/backport-1127
repeatedly Aug 1, 2016
24f8fdb
Merge pull request #1132 from fluent/fix-1039
repeatedly Aug 2, 2016
1be5b7b
Merge pull request #1043 from cosmo0920/use-at-type-in-example-conf
repeatedly Jun 9, 2016
1f7cdff
v0.12.27
repeatedly Aug 3, 2016
b1e5a3a
Merge pull request #1147 from edevil/use_string_oj
repeatedly Aug 8, 2016
1371c11
Merge pull request #807 from fluent/add-source-host-key-to-forward
repeatedly Aug 10, 2016
1f261c7
v0.12.28
repeatedly Aug 15, 2016
c804a5b
Use link to refer v0.10 changelog
repeatedly Aug 15, 2016
3e7dc6c
Port parser filter to v0.12
repeatedly Sep 5, 2016
baea2c1
Move require to top and fix comment out
repeatedly Sep 5, 2016
5f0c0b9
Merge pull request #1186 from fluent/deprecated-parameter
tagomoris Aug 29, 2016
c719830
Fix constant name and removing useless log line
repeatedly Sep 5, 2016
de89b15
Remove unused test classes
repeatedly Sep 5, 2016
6334763
Merge pull request #1204 from fluent/backport-1186
repeatedly Sep 5, 2016
262caf3
Merge pull request #1203 from fluent/port-parser-filter-v012
repeatedly Sep 5, 2016
1fba5bc
Merge pull request #1176 from sonots/prevent_overwriting_reserved_pla…
repeatedly Aug 21, 2016
7ba559b
Add from_encoding parameter to in_tail plugin (#1067)
footaku Aug 18, 2016
1e49ea6
Merge pull request #1202 from fluent/raise-configuration-errors-for-m…
tagomoris Sep 2, 2016
eb6bb0a
Fix test to use v0.12 test helper
repeatedly Sep 5, 2016
cd45819
v0.12.29
repeatedly Sep 6, 2016
703ee38
Port 1239 oj mode changes to v0.12
repeatedly Nov 2, 2016
d915afa
Merge pull request #1304 from fluent/port-1239-to-v0.12
repeatedly Nov 4, 2016
04311ac
Port #1317 into v0.12
repeatedly Nov 24, 2016
fb368a1
Add Fluent::Test::Helpers module for easy to write tests
repeatedly Nov 24, 2016
ff86024
Merge pull request #1322 from fluent/add-test-helpers-for-v0.14-compat
repeatedly Nov 24, 2016
dbc5392
Port #1331 into v0.12
repeatedly Nov 29, 2016
a702b48
Merge pull request #1325 from fluent/optimize-split-lines-in_tail
tagomoris Nov 28, 2016
5a1a245
filter_parser: Add emit_invalid_record_to_error parameter
repeatedly Nov 30, 2016
de06ec8
Merge pull request #1339 from fluent/apply-v0.14-changes-to-filter-pa…
repeatedly Dec 1, 2016
0c44166
v0.12.30
repeatedly Dec 1, 2016
0d5b434
ensure to sleep even if command or parsing fails
Dec 2, 2016
8ec6af0
add tests for the case of invalid command given
Dec 2, 2016
b68a05d
formatter_csv: Change fields parameter to required
repeatedly Dec 9, 2016
8376ea4
Add slow_flush_threshold parameter
repeatedly Dec 13, 2016
856708b
Rename to slow_flush_log_threshold
repeatedly Dec 13, 2016
6e31e61
Change to larger value to suppress warning for external services
repeatedly Dec 13, 2016
06707c9
raise ConfigError when fields are empty
repeatedly Dec 13, 2016
c78bc7f
Reduce memory allocation in each format call
repeatedly Dec 13, 2016
e5fbc57
Merge pull request #1361 from fluent/change-csv-field-to-required
repeatedly Dec 14, 2016
c26a308
Add : to log
repeatedly Dec 14, 2016
8b3fe04
Merge pull request #1366 from fluent/log-slow-flush
repeatedly Dec 14, 2016
1863653
Merge pull request #1351 from knqyf263/add_options
repeatedly Dec 8, 2016
419fd9e
Update development gems to follow v0.14
repeatedly Dec 14, 2016
55f0d0f
v0.12.31
repeatedly Dec 14, 2016
649f7ba
check log lines instead of stderr for counting command exectuion
autopp Dec 15, 2016
93b8edb
Merge pull request #1348 from autopp/ensure_sleep_in_exec
repeatedly Dec 16, 2016
cbf8fc2
port query parameter with_ivars to v0.12
autopp Jan 5, 2017
60b6bd9
Merge pull request #1402 from autopp/port-1393-to-v0.12
repeatedly Jan 7, 2017
f57a6aa
Merge pull request #1421 from jitran/emit-unmatched-lines
repeatedly Jan 25, 2017
c66ef65
Merge pull request #1433 from fluent/move-remove-keys-to-last
repeatedly Jan 26, 2017
13f7313
Port #1420 to v0.12
repeatedly Feb 2, 2017
f80d73c
Merge pull request #1447 from fluent/port-add_newline-to-v012
repeatedly Feb 2, 2017
e50a98c
Allow msgpack v1
repeatedly Feb 2, 2017
be13675
travis-ci: Update testing ruby versions
repeatedly Feb 2, 2017
956714c
travis: Remove ruby 2.2 test from osx
repeatedly Feb 2, 2017
3ed652d
Merge pull request #1448 from fluent/update-v0.12-setting
repeatedly Feb 2, 2017
2ad2dca
Merge pull request #1387 from CSharpRU/get-real-retry-info-from-buffe…
repeatedly Dec 25, 2016
cd164b4
in_monitor_agent: optimize with_retry code
repeatedly Feb 2, 2017
b1b3c8f
Merge branch 'v0.12' of github.com:fluent/fluentd into v0.12
repeatedly Feb 2, 2017
79a2cbe
v0.12.32
repeatedly Feb 3, 2017
2249683
in_forward: backport source / address key features
repeatedly Mar 3, 2017
9fee2fb
Merge pull request #1490 from fluent/backport-add-xxx-key-to-in_forward
repeatedly Mar 3, 2017
c279a3e
Merge pull request #1477 from okkez/fix-undefined-conversion-error
repeatedly Mar 2, 2017
0fe9916
Merge pull request #1479 from sergeyfedotov/allow_escape_sequence
repeatedly Mar 2, 2017
d4f92a5
Fix tests of TSVParser
repeatedly Mar 3, 2017
6fc58dd
Merge pull request #1478 from okkez/add-log-concat-method
repeatedly Feb 21, 2017
ba84f03
Merge pull request #1464 from angry-cellophane/master
repeatedly Feb 14, 2017
8ff1b8d
Merge pull request #1474 from t-osakada/watch_only_recently_modified_…
repeatedly Feb 17, 2017
2c83da3
Fix tests of CSVParser
repeatedly Mar 4, 2017
db71a89
Backport #1492 to v0.12
cosmo0920 Mar 9, 2017
eaf8b99
Remove needless assignment
cosmo0920 Mar 9, 2017
3c80765
Merge pull request #1487 from t-osakada/skip_refresh_on_startup
repeatedly Mar 6, 2017
99110c7
Remove needless if condition
cosmo0920 Mar 9, 2017
58a44e8
Set default time_format value for rfc5424 when users do not set time_…
cosmo0920 Mar 9, 2017
223d249
Add a rfc5424 test case without time_format conf key
cosmo0920 Mar 9, 2017
67910e5
Add Development section for developers
repeatedly Mar 9, 2017
2481157
Merge pull request #1495 from cosmo0920/backport-#1492-v0.12
repeatedly Mar 9, 2017
fb743e3
v0.12.33
repeatedly Mar 9, 2017
d0a7b2f
Fix typo of v0.12.33 ChangeLog
repeatedly Mar 10, 2017
6c4b90f
Add syslog parser message_format tests to in_syslog
repeatedly Mar 10, 2017
a36090d
msgpack format chosen with content-type header
jdconley Mar 16, 2017
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Prev Previous commit
msgpack format chosen with content-type header
  • Loading branch information
jdconley committed Mar 16, 2017
commit a36090d3c9d6185bf9e10c5bb71186548a627a31
2 changes: 2 additions & 0 deletions lib/fluent/plugin/in_http.rb
Original file line number Diff line number Diff line change
Expand Up @@ -355,6 +355,8 @@ def on_message_complete
params.update WEBrick::HTTPUtils.parse_form_data(@body, boundary)
elsif @content_type =~ /^application\/json/
params['json'] = @body
elsif @content_type =~ /^application\/msgpack/
params['msgpack'] = @body
end
path_info = uri.path

Expand Down
16 changes: 16 additions & 0 deletions test/plugin/test_in_http.rb
Original file line number Diff line number Diff line change
Expand Up @@ -205,6 +205,22 @@ def test_application_json
end
end

def test_application_msgpack
d = create_driver

time = Time.parse("2011-01-02 13:14:15 UTC").to_i

d.expect_emit "tag1", time, {"a"=>1}
d.expect_emit "tag2", time, {"a"=>2}

d.run do
d.expected_emits.each {|tag,time,record|
res = post("/#{tag}?time=#{time.to_s}", record.to_msgpack, {"content-type"=>"application/msgpack; charset=utf-8"})
assert_equal "200", res.code
}
end
end

def test_msgpack
d = create_driver

Expand Down