diff options
Diffstat (limited to 'src')
| -rw-r--r-- | src/fiinha.go (renamed from src/q.go) | 12 | ||||
| -rw-r--r-- | src/main.go | 4 |
2 files changed, 8 insertions, 8 deletions
@@ -1,4 +1,4 @@ -package q +package fiinha import ( "database/sql" @@ -18,7 +18,7 @@ import ( const ( - defaultPrefix = "q" + defaultPrefix = "fiinha" reaperSkipCount = 1000 notOwnerErrorFmt = "%v owns %#v as %#v, not us (%v)" rollbackErrorFmt = "rollback error: %w; while executing: %w" @@ -1944,7 +1944,7 @@ func makeConsumeOneFn( err := callback(asPublicMessage(message)) if err != nil { g.Info( - "consumer failed", "q-consumer", + "consumer failed", "fiinha-consumer", "topic", data.topic, "consumer", data.name, "error", err, @@ -1971,7 +1971,7 @@ func makeConsumeAllFn( err := eachFn(data.topic, data.name, consumeOneFn) if err != nil { g.Warning( - "eachFn failed", "q-consume-all", + "eachFn failed", "fiinha-consume-all", "topic", data.topic, "consumer", data.name, "error", err, @@ -2391,13 +2391,13 @@ func getopt( fs.SetOutput(w) databasePath := fs.String( "f", - "q.db", + "fiinha.db", "The path to the file where the queue is kept", ) prefix := fs.String( "p", defaultPrefix, - "The q prefix of the table names", + "The fiinha prefix of the table names", ) if fs.Parse(argv) != nil { usage(argv0, w) diff --git a/src/main.go b/src/main.go index 51faffa..af67e07 100644 --- a/src/main.go +++ b/src/main.go @@ -1,7 +1,7 @@ package main -import "q" +import "fiinha" func main() { - q.Main() + fiinha.Main() } |