Skip to content

N
nebula
Commit 935782f5 authored by inphi's avatar inphi
Browse files
Options

recover from pub errors

parent 3e016ae8
Hide whitespace changes
Inline Side-by-side
Showing with 2 additions and 0 deletions
l2geth/rollup/pub/google.go
View file @ 935782f5
...@@ -51,6 +51,8 @@ func (p *GooglePublisher) Publish(ctx context.Context, msg []byte) error { ...@@ -51,6 +51,8 @@ func (p *GooglePublisher) Publish(ctx context.Context, msg []byte) error {
Data: msg, Data: msg,
OrderingKey: messageOrderingKey, OrderingKey: messageOrderingKey,
} }
// If there was an error previously, clear it out to allow publishing to work again
p.topic.ResumePublish(messageOrderingKey)
result := p.topic.Publish(ctx, &pmsg) result := p.topic.Publish(ctx, &pmsg)
_, err := result.Get(ctx) _, err := result.Get(ctx)
return err return err
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment