mirror of
https://github.com/eosswedenorg/thalos
synced 2026-07-04 12:03:41 +02:00
app/ship_processor.go: in encodeQueue() should check for err == nil, not err != nil.
This commit is contained in:
parent
315d7e19c9
commit
6ca9f408f9
1 changed files with 1 additions and 1 deletions
|
|
@ -56,7 +56,7 @@ func (processor *ShipProcessor) queueMessage(channel transport.ChannelInterface,
|
||||||
}
|
}
|
||||||
|
|
||||||
func (processor *ShipProcessor) encodeQueue(channel transport.ChannelInterface, v interface{}) bool {
|
func (processor *ShipProcessor) encodeQueue(channel transport.ChannelInterface, v interface{}) bool {
|
||||||
if payload, err := processor.encode(v); err != nil {
|
if payload, err := processor.encode(v); err == nil {
|
||||||
return processor.queueMessage(channel, payload)
|
return processor.queueMessage(channel, payload)
|
||||||
}
|
}
|
||||||
return false
|
return false
|
||||||
|
|
|
||||||
Loading…
Add table
Add a link
Reference in a new issue