[
https://issues.apache.org/jira/browse/PROTON-2055?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Justin Ross updated PROTON-2055:
--------------------------------
Description:
{noformat}
def on_container_start(container)
conn = container.connect(@conn_url)
opts = {
source: {
address: @address,
capabilities: {
:queue => nil
}
}
}
conn.open_receiver(opts=opts)
end
{noformat}
{noformat}
> Command 'ruby auto-create/queue-receive.rb amqp://127.0.0.1:49897 q1 1'
> returned non-zero exit status 1
— Output —
> SEND: Opened sender for target address 'q1'
> SEND: Sent message 'abc'
> /usr/share/gems/gems/qpid_proton-0.26.0/lib/codec/data.rb:210:in `null':
> expected null, got symbol (TypeError)
> from /usr/share/gems/gems/qpid_proton-0.26.0/lib/codec/mapping.rb:166:in
> `block in put'
> from /usr/share/gems/gems/qpid_proton-0.26.0/lib/codec/mapping.rb:158:in
> `each_pair'
> from /usr/share/gems/gems/qpid_proton-0.26.0/lib/codec/mapping.rb:158:in
> `put'
> from /usr/share/gems/gems/qpid_proton-0.26.0/lib/codec/data.rb:223:in
> `object='
> from /usr/share/gems/gems/qpid_proton-0.26.0/lib/codec/data.rb:228:in `<<'
> from /usr/share/gems/gems/qpid_proton-0.26.0/lib/core/terminus.rb:240:in
> `block in apply'
> from /usr/share/gems/gems/qpid_proton-0.26.0/lib/core/terminus.rb:231:in
> `each_pair'
> from /usr/share/gems/gems/qpid_proton-0.26.0/lib/core/terminus.rb:231:in
> `apply'
> from /usr/share/gems/gems/qpid_proton-0.26.0/lib/core/receiver.rb:51:in
> `open'
> from /usr/share/gems/gems/qpid_proton-0.26.0/lib/core/session.rb:117:in
> `open_receiver'
> from /usr/share/gems/gems/qpid_proton-0.26.0/lib/core/connection.rb:216:in
> `open_receiver'
> from auto-create/queue-receive.rb:46:in `on_container_start'
> from /usr/share/gems/gems/qpid_proton-0.26.0/lib/handler/adapter.rb:74:in
> `forward'
> from
> /usr/share/gems/gems/qpid_proton-0.26.0/lib/handler/messaging_adapter.rb:27:in
> `delegate'
> from
> /usr/share/gems/gems/qpid_proton-0.26.0/lib/handler/messaging_adapter.rb:38:in
> `on_container_start'
> from /usr/share/gems/gems/qpid_proton-0.26.0/lib/core/container.rb:375:in
> `block in run_one'
> from /usr/share/gems/gems/qpid_proton-0.26.0/lib/core/container.rb:432:in
> `maybe_panic'
> from /usr/share/gems/gems/qpid_proton-0.26.0/lib/core/container.rb:375:in
> `run_one'
> from /usr/share/gems/gems/qpid_proton-0.26.0/lib/core/container.rb:197:in
> `run'
> from auto-create/queue-receive.rb:79:in `<main>'
{noformat}
was:
{{ def on_container_start(container)
conn = container.connect(@conn_url)
opts = {
source: {
address: @address,
capabilities: {
:queue => nil
}
}
}
conn.open_receiver(opts=opts)
end
}}
{{> Command 'ruby auto-create/queue-receive.rb amqp://127.0.0.1:49897 q1 1'
returned non-zero exit status 1
--- Output ---
> SEND: Opened sender for target address 'q1'
> SEND: Sent message 'abc'
> /usr/share/gems/gems/qpid_proton-0.26.0/lib/codec/data.rb:210:in `null':
> expected null, got symbol (TypeError)
> from
> /usr/share/gems/gems/qpid_proton-0.26.0/lib/codec/mapping.rb:166:in `block in
> put'
> from
> /usr/share/gems/gems/qpid_proton-0.26.0/lib/codec/mapping.rb:158:in
> `each_pair'
> from
> /usr/share/gems/gems/qpid_proton-0.26.0/lib/codec/mapping.rb:158:in `put'
> from /usr/share/gems/gems/qpid_proton-0.26.0/lib/codec/data.rb:223:in
> `object='
> from /usr/share/gems/gems/qpid_proton-0.26.0/lib/codec/data.rb:228:in
> `<<'
> from
> /usr/share/gems/gems/qpid_proton-0.26.0/lib/core/terminus.rb:240:in `block in
> apply'
> from
> /usr/share/gems/gems/qpid_proton-0.26.0/lib/core/terminus.rb:231:in
> `each_pair'
> from
> /usr/share/gems/gems/qpid_proton-0.26.0/lib/core/terminus.rb:231:in `apply'
> from /usr/share/gems/gems/qpid_proton-0.26.0/lib/core/receiver.rb:51:in
> `open'
> from /usr/share/gems/gems/qpid_proton-0.26.0/lib/core/session.rb:117:in
> `open_receiver'
> from
> /usr/share/gems/gems/qpid_proton-0.26.0/lib/core/connection.rb:216:in
> `open_receiver'
> from auto-create/queue-receive.rb:46:in `on_container_start'
> from
> /usr/share/gems/gems/qpid_proton-0.26.0/lib/handler/adapter.rb:74:in `forward'
> from
> /usr/share/gems/gems/qpid_proton-0.26.0/lib/handler/messaging_adapter.rb:27:in
> `delegate'
> from
> /usr/share/gems/gems/qpid_proton-0.26.0/lib/handler/messaging_adapter.rb:38:in
> `on_container_start'
> from
> /usr/share/gems/gems/qpid_proton-0.26.0/lib/core/container.rb:375:in `block
> in run_one'
> from
> /usr/share/gems/gems/qpid_proton-0.26.0/lib/core/container.rb:432:in
> `maybe_panic'
> from
> /usr/share/gems/gems/qpid_proton-0.26.0/lib/core/container.rb:375:in `run_one'
> from
> /usr/share/gems/gems/qpid_proton-0.26.0/lib/core/container.rb:197:in `run'
> from auto-create/queue-receive.rb:79:in `<main>'}}
> [ruby] Failure adding hash entry with null value
> ------------------------------------------------
>
> Key: PROTON-2055
> URL: https://issues.apache.org/jira/browse/PROTON-2055
> Project: Qpid Proton
> Issue Type: Bug
> Reporter: Justin Ross
> Priority: Major
>
>
> {noformat}
> def on_container_start(container)
> conn = container.connect(@conn_url)
> opts = {
> source: {
> address: @address,
> capabilities: {
> :queue => nil
> }
> }
> }
>
> conn.open_receiver(opts=opts)
> end
> {noformat}
> {noformat}
> > Command 'ruby auto-create/queue-receive.rb amqp://127.0.0.1:49897 q1 1'
> > returned non-zero exit status 1
> — Output —
> > SEND: Opened sender for target address 'q1'
> > SEND: Sent message 'abc'
> > /usr/share/gems/gems/qpid_proton-0.26.0/lib/codec/data.rb:210:in `null':
> expected null, got symbol (TypeError)
> > from /usr/share/gems/gems/qpid_proton-0.26.0/lib/codec/mapping.rb:166:in
> `block in put'
> > from /usr/share/gems/gems/qpid_proton-0.26.0/lib/codec/mapping.rb:158:in
> `each_pair'
> > from /usr/share/gems/gems/qpid_proton-0.26.0/lib/codec/mapping.rb:158:in
> `put'
> > from /usr/share/gems/gems/qpid_proton-0.26.0/lib/codec/data.rb:223:in
> `object='
> > from /usr/share/gems/gems/qpid_proton-0.26.0/lib/codec/data.rb:228:in `<<'
> > from /usr/share/gems/gems/qpid_proton-0.26.0/lib/core/terminus.rb:240:in
> `block in apply'
> > from /usr/share/gems/gems/qpid_proton-0.26.0/lib/core/terminus.rb:231:in
> `each_pair'
> > from /usr/share/gems/gems/qpid_proton-0.26.0/lib/core/terminus.rb:231:in
> `apply'
> > from /usr/share/gems/gems/qpid_proton-0.26.0/lib/core/receiver.rb:51:in
> `open'
> > from /usr/share/gems/gems/qpid_proton-0.26.0/lib/core/session.rb:117:in
> `open_receiver'
> > from /usr/share/gems/gems/qpid_proton-0.26.0/lib/core/connection.rb:216:in
> `open_receiver'
> > from auto-create/queue-receive.rb:46:in `on_container_start'
> > from /usr/share/gems/gems/qpid_proton-0.26.0/lib/handler/adapter.rb:74:in
> `forward'
> > from
> /usr/share/gems/gems/qpid_proton-0.26.0/lib/handler/messaging_adapter.rb:27:in
> `delegate'
> > from
> /usr/share/gems/gems/qpid_proton-0.26.0/lib/handler/messaging_adapter.rb:38:in
> `on_container_start'
> > from /usr/share/gems/gems/qpid_proton-0.26.0/lib/core/container.rb:375:in
> `block in run_one'
> > from /usr/share/gems/gems/qpid_proton-0.26.0/lib/core/container.rb:432:in
> `maybe_panic'
> > from /usr/share/gems/gems/qpid_proton-0.26.0/lib/core/container.rb:375:in
> `run_one'
> > from /usr/share/gems/gems/qpid_proton-0.26.0/lib/core/container.rb:197:in
> `run'
> > from auto-create/queue-receive.rb:79:in `<main>'
> {noformat}
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
