Remove unreachable code in amqp-rpc.go.
This commit is contained in:
parent
85e81901ae
commit
213af33864
|
|
@ -225,8 +225,6 @@ func (rpc *AmqpRpcClient) DispatchSync(method string, body []byte) (response []b
|
||||||
err = errors.New("AMQP-RPC timeout")
|
err = errors.New("AMQP-RPC timeout")
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
err = errors.New("Unknown error in SyncDispatch")
|
|
||||||
return
|
|
||||||
}
|
}
|
||||||
|
|
||||||
func (rpc *AmqpRpcClient) SyncDispatchWithTimeout(method string, body []byte, ttl time.Duration) (response []byte, err error) {
|
func (rpc *AmqpRpcClient) SyncDispatchWithTimeout(method string, body []byte, ttl time.Duration) (response []byte, err error) {
|
||||||
|
|
|
||||||
Loading…
Reference in New Issue