diff --git a/gateway/manifest.go b/gateway/manifest.go
index 123ca9b..c77dea4 100644
--- a/gateway/manifest.go
+++ b/gateway/manifest.go
@@ -112,9 +112,9 @@ func (c *Gateway) cacheManifest(info *PathInfo) (int, error) {
 					msg := fmt.Sprintf("%s/%s@%s", info.Host, info.Image, digest)
 					_, err := c.queueClient.Create(context.Background(), msg, 0)
 					if err != nil {
-						c.logger.Warn("failed add message to queue", "msg", msg, "error", err)
+						c.logger.Warn("failed add message to queue", "msg", msg, "tag", info.Manifests, "error", err)
 					} else {
-						c.logger.Info("Add message to queue", "msg", msg, "digest", digest)
+						c.logger.Info("Add message to queue", "msg", msg, "tag", info.Manifests)
 					}
 					digest = cachedDigest
 				}
diff --git a/queue/client/client.go b/queue/client/client.go
index 09fb697..cd687ff 100644
--- a/queue/client/client.go
+++ b/queue/client/client.go
@@ -85,7 +85,7 @@ func (c *MessageClient) Create(ctx context.Context, content string, priority int
 	}
 	defer resp.Body.Close()
 
-	if resp.StatusCode != http.StatusCreated {
+	if resp.StatusCode != http.StatusCreated && resp.StatusCode != http.StatusOK {
 		return MessageResponse{}, handleErrorResponse(resp)
 	}