38 files changed, 358 insertions, 358 deletions

diff --git a/tests/benchmarks/deadletters/q.go b/tests/benchmarks/deadletters/fiinha.go
index 0c203bb..9c0b641 100644
--- a/tests/benchmarks/deadletters/q.go
+++ b/tests/benchmarks/deadletters/fiinha.go
@@ -1,4 +1,4 @@
-package q
+package fiinha
 
 import (
 	"flag"
diff --git a/tests/benchmarks/lookup/q.go b/tests/benchmarks/lookup/fiinha.go
index 0c203bb..9c0b641 100644
--- a/tests/benchmarks/lookup/q.go
+++ b/tests/benchmarks/lookup/fiinha.go
@@ -1,4 +1,4 @@
-package q
+package fiinha
 
 import (
 	"flag"
diff --git a/tests/benchmarks/multiple-consumers/q.go b/tests/benchmarks/multiple-consumers/fiinha.go
index 0c203bb..9c0b641 100644
--- a/tests/benchmarks/multiple-consumers/q.go
+++ b/tests/benchmarks/multiple-consumers/fiinha.go
@@ -1,4 +1,4 @@
-package q
+package fiinha
 
 import (
 	"flag"
diff --git a/tests/benchmarks/multiple-produces/q.go b/tests/benchmarks/multiple-produces/fiinha.go
index 0c203bb..9c0b641 100644
--- a/tests/benchmarks/multiple-produces/q.go
+++ b/tests/benchmarks/multiple-produces/fiinha.go
@@ -1,4 +1,4 @@
-package q
+package fiinha
 
 import (
 	"flag"
diff --git a/tests/benchmarks/reaper/fiinha.go b/tests/benchmarks/reaper/fiinha.go
new file mode 100644
index 0000000..9c0b641
--- /dev/null
+++ b/tests/benchmarks/reaper/fiinha.go
@@ -0,0 +1,24 @@
+package fiinha
+
+import (
+	"flag"
+	"time"
+)
+
+
+
+var nFlag = flag.Int(
+	"n",
+	1_000,
+	"The number of iterations to execute",
+)
+
+func MainTest() {
+	// FIXME
+	flag.Parse()
+	n := *nFlag
+
+	for i := 0; i < n; i++ {
+		time.Sleep(time.Millisecond * 1)
+	}
+}
diff --git a/tests/benchmarks/reaper/q.go b/tests/benchmarks/reaper/q.go
deleted file mode 100644
index 0c203bb..0000000
--- a/tests/benchmarks/reaper/q.go
+++ /dev/null
@@ -1,24 +0,0 @@
-package q
-
-import (
-	"flag"
-	"time"
-)
-
-
-
-var nFlag = flag.Int(
-	"n",
-	1_000,
-	"The number of iterations to execute",
-)
-
-func MainTest() {
-	// FIXME
-	flag.Parse()
-	n := *nFlag
-
-	for i := 0; i < n; i++ {
-		time.Sleep(time.Millisecond * 1)
-	}
-}
diff --git a/tests/benchmarks/replay/fiinha.go b/tests/benchmarks/replay/fiinha.go
new file mode 100644
index 0000000..9c0b641
--- /dev/null
+++ b/tests/benchmarks/replay/fiinha.go
@@ -0,0 +1,24 @@
+package fiinha
+
+import (
+	"flag"
+	"time"
+)
+
+
+
+var nFlag = flag.Int(
+	"n",
+	1_000,
+	"The number of iterations to execute",
+)
+
+func MainTest() {
+	// FIXME
+	flag.Parse()
+	n := *nFlag
+
+	for i := 0; i < n; i++ {
+		time.Sleep(time.Millisecond * 1)
+	}
+}
diff --git a/tests/benchmarks/replay/q.go b/tests/benchmarks/replay/q.go
deleted file mode 100644
index 0c203bb..0000000
--- a/tests/benchmarks/replay/q.go
+++ /dev/null
@@ -1,24 +0,0 @@
-package q
-
-import (
-	"flag"
-	"time"
-)
-
-
-
-var nFlag = flag.Int(
-	"n",
-	1_000,
-	"The number of iterations to execute",
-)
-
-func MainTest() {
-	// FIXME
-	flag.Parse()
-	n := *nFlag
-
-	for i := 0; i < n; i++ {
-		time.Sleep(time.Millisecond * 1)
-	}
-}
diff --git a/tests/benchmarks/single-consumer/fiinha.go b/tests/benchmarks/single-consumer/fiinha.go
new file mode 100644
index 0000000..9c0b641
--- /dev/null
+++ b/tests/benchmarks/single-consumer/fiinha.go
@@ -0,0 +1,24 @@
+package fiinha
+
+import (
+	"flag"
+	"time"
+)
+
+
+
+var nFlag = flag.Int(
+	"n",
+	1_000,
+	"The number of iterations to execute",
+)
+
+func MainTest() {
+	// FIXME
+	flag.Parse()
+	n := *nFlag
+
+	for i := 0; i < n; i++ {
+		time.Sleep(time.Millisecond * 1)
+	}
+}
diff --git a/tests/benchmarks/single-consumer/q.go b/tests/benchmarks/single-consumer/q.go
deleted file mode 100644
index 0c203bb..0000000
--- a/tests/benchmarks/single-consumer/q.go
+++ /dev/null
@@ -1,24 +0,0 @@
-package q
-
-import (
-	"flag"
-	"time"
-)
-
-
-
-var nFlag = flag.Int(
-	"n",
-	1_000,
-	"The number of iterations to execute",
-)
-
-func MainTest() {
-	// FIXME
-	flag.Parse()
-	n := *nFlag
-
-	for i := 0; i < n; i++ {
-		time.Sleep(time.Millisecond * 1)
-	}
-}
diff --git a/tests/benchmarks/single-producer/fiinha.go b/tests/benchmarks/single-producer/fiinha.go
new file mode 100644
index 0000000..9c0b641
--- /dev/null
+++ b/tests/benchmarks/single-producer/fiinha.go
@@ -0,0 +1,24 @@
+package fiinha
+
+import (
+	"flag"
+	"time"
+)
+
+
+
+var nFlag = flag.Int(
+	"n",
+	1_000,
+	"The number of iterations to execute",
+)
+
+func MainTest() {
+	// FIXME
+	flag.Parse()
+	n := *nFlag
+
+	for i := 0; i < n; i++ {
+		time.Sleep(time.Millisecond * 1)
+	}
+}
diff --git a/tests/benchmarks/single-producer/q.go b/tests/benchmarks/single-producer/q.go
deleted file mode 100644
index 0c203bb..0000000
--- a/tests/benchmarks/single-producer/q.go
+++ /dev/null
@@ -1,24 +0,0 @@
-package q
-
-import (
-	"flag"
-	"time"
-)
-
-
-
-var nFlag = flag.Int(
-	"n",
-	1_000,
-	"The number of iterations to execute",
-)
-
-func MainTest() {
-	// FIXME
-	flag.Parse()
-	n := *nFlag
-
-	for i := 0; i < n; i++ {
-		time.Sleep(time.Millisecond * 1)
-	}
-}
diff --git a/tests/benchmarks/subscribe/fiinha.go b/tests/benchmarks/subscribe/fiinha.go
new file mode 100644
index 0000000..9c0b641
--- /dev/null
+++ b/tests/benchmarks/subscribe/fiinha.go
@@ -0,0 +1,24 @@
+package fiinha
+
+import (
+	"flag"
+	"time"
+)
+
+
+
+var nFlag = flag.Int(
+	"n",
+	1_000,
+	"The number of iterations to execute",
+)
+
+func MainTest() {
+	// FIXME
+	flag.Parse()
+	n := *nFlag
+
+	for i := 0; i < n; i++ {
+		time.Sleep(time.Millisecond * 1)
+	}
+}
diff --git a/tests/benchmarks/subscribe/q.go b/tests/benchmarks/subscribe/q.go
deleted file mode 100644
index 0c203bb..0000000
--- a/tests/benchmarks/subscribe/q.go
+++ /dev/null
@@ -1,24 +0,0 @@
-package q
-
-import (
-	"flag"
-	"time"
-)
-
-
-
-var nFlag = flag.Int(
-	"n",
-	1_000,
-	"The number of iterations to execute",
-)
-
-func MainTest() {
-	// FIXME
-	flag.Parse()
-	n := *nFlag
-
-	for i := 0; i < n; i++ {
-		time.Sleep(time.Millisecond * 1)
-	}
-}
diff --git a/tests/benchmarks/unsubscribe/fiinha.go b/tests/benchmarks/unsubscribe/fiinha.go
new file mode 100644
index 0000000..9c0b641
--- /dev/null
+++ b/tests/benchmarks/unsubscribe/fiinha.go
@@ -0,0 +1,24 @@
+package fiinha
+
+import (
+	"flag"
+	"time"
+)
+
+
+
+var nFlag = flag.Int(
+	"n",
+	1_000,
+	"The number of iterations to execute",
+)
+
+func MainTest() {
+	// FIXME
+	flag.Parse()
+	n := *nFlag
+
+	for i := 0; i < n; i++ {
+		time.Sleep(time.Millisecond * 1)
+	}
+}
diff --git a/tests/benchmarks/unsubscribe/q.go b/tests/benchmarks/unsubscribe/q.go
deleted file mode 100644
index 0c203bb..0000000
--- a/tests/benchmarks/unsubscribe/q.go
+++ /dev/null
@@ -1,24 +0,0 @@
-package q
-
-import (
-	"flag"
-	"time"
-)
-
-
-
-var nFlag = flag.Int(
-	"n",
-	1_000,
-	"The number of iterations to execute",
-)
-
-func MainTest() {
-	// FIXME
-	flag.Parse()
-	n := *nFlag
-
-	for i := 0; i < n; i++ {
-		time.Sleep(time.Millisecond * 1)
-	}
-}
diff --git a/tests/benchmarks/waiter/fiinha.go b/tests/benchmarks/waiter/fiinha.go
new file mode 100644
index 0000000..9c0b641
--- /dev/null
+++ b/tests/benchmarks/waiter/fiinha.go
@@ -0,0 +1,24 @@
+package fiinha
+
+import (
+	"flag"
+	"time"
+)
+
+
+
+var nFlag = flag.Int(
+	"n",
+	1_000,
+	"The number of iterations to execute",
+)
+
+func MainTest() {
+	// FIXME
+	flag.Parse()
+	n := *nFlag
+
+	for i := 0; i < n; i++ {
+		time.Sleep(time.Millisecond * 1)
+	}
+}
diff --git a/tests/benchmarks/waiter/q.go b/tests/benchmarks/waiter/q.go
deleted file mode 100644
index 0c203bb..0000000
--- a/tests/benchmarks/waiter/q.go
+++ /dev/null
@@ -1,24 +0,0 @@
-package q
-
-import (
-	"flag"
-	"time"
-)
-
-
-
-var nFlag = flag.Int(
-	"n",
-	1_000,
-	"The number of iterations to execute",
-)
-
-func MainTest() {
-	// FIXME
-	flag.Parse()
-	n := *nFlag
-
-	for i := 0; i < n; i++ {
-		time.Sleep(time.Millisecond * 1)
-	}
-}
diff --git a/tests/q.go b/tests/fiinha.go
index 565ca25..a6ae315 100644
--- a/tests/q.go
+++ b/tests/fiinha.go
@@ -1,4 +1,4 @@
-package q
+package fiinha
 
 import (
 	"bytes"
@@ -5635,8 +5635,8 @@ func test_getopt() {
 		_,    _,       rc2 := getopt(argv2, commandsMap, &w2)
 		args, command, rc3 := getopt(argv3, commandsMap, &w3)
 		expectedArgs := argsT{
-			databasePath: "q.db",
-			prefix:       "q",
+			databasePath: "fiinha.db",
+			prefix:       "fiinha",
 			command:      "bad",
 			allArgs:      argv3,
 			args:         argv3[2:],
@@ -5662,8 +5662,8 @@ func test_getopt() {
 			&w,
 		)
 		expectedArgs := argsT{
-			databasePath: "q.db",
-			prefix:       "q",
+			databasePath: "fiinha.db",
+			prefix:       "fiinha",
 			command:      "good",
 			allArgs:      []string{"$0", "good"},
 			args:         []string{},
@@ -5699,7 +5699,7 @@ func test_getopt() {
 		args, command, rc := getopt(argv, commandsMap, &w)
 		expectedArgs := argsT{
 			databasePath: "F",
-			prefix:       "q",
+			prefix:       "fiinha",
 			command:      "good",
 			allArgs:      argv,
 			args:         []string{"-f", "-f", "SUB"},
diff --git a/tests/functional/consume-one-produce-many/q.go b/tests/functional/consume-one-produce-many/fiinha.go
index 48d66d3..6a3ca47 100644
--- a/tests/functional/consume-one-produce-many/q.go
+++ b/tests/functional/consume-one-produce-many/fiinha.go
@@ -1,4 +1,4 @@
-package q
+package fiinha
 
 func MainTest() {
 	// FIXME
diff --git a/tests/functional/consumer-with-deadletter/q.go b/tests/functional/consumer-with-deadletter/fiinha.go
index a79ad5b..7d88e0e 100644
--- a/tests/functional/consumer-with-deadletter/q.go
+++ b/tests/functional/consumer-with-deadletter/fiinha.go
@@ -1,4 +1,4 @@
-package q
+package fiinha
 
 import (
 	"errors"
diff --git a/tests/functional/custom-prefix/q.go b/tests/functional/custom-prefix/fiinha.go
index 48d66d3..6a3ca47 100644
--- a/tests/functional/custom-prefix/q.go
+++ b/tests/functional/custom-prefix/fiinha.go
@@ -1,4 +1,4 @@
-package q
+package fiinha
 
 func MainTest() {
 	// FIXME
diff --git a/tests/functional/distinct-consumers-separate-instances/q.go b/tests/functional/distinct-consumers-separate-instances/fiinha.go
index 48d66d3..6a3ca47 100644
--- a/tests/functional/distinct-consumers-separate-instances/q.go
+++ b/tests/functional/distinct-consumers-separate-instances/fiinha.go
@@ -1,4 +1,4 @@
-package q
+package fiinha
 
 func MainTest() {
 	// FIXME
diff --git a/tests/functional/flow-id/q.go b/tests/functional/flow-id/fiinha.go
index 48d66d3..6a3ca47 100644
--- a/tests/functional/flow-id/q.go
+++ b/tests/functional/flow-id/fiinha.go
@@ -1,4 +1,4 @@
-package q
+package fiinha
 
 func MainTest() {
 	// FIXME
diff --git a/tests/functional/idempotency/fiinha.go b/tests/functional/idempotency/fiinha.go
new file mode 100644
index 0000000..6a3ca47
--- /dev/null
+++ b/tests/functional/idempotency/fiinha.go
@@ -0,0 +1,5 @@
+package fiinha
+
+func MainTest() {
+	// FIXME
+}
diff --git a/tests/functional/idempotency/q.go b/tests/functional/idempotency/q.go
deleted file mode 100644
index 48d66d3..0000000
--- a/tests/functional/idempotency/q.go
+++ /dev/null
@@ -1,5 +0,0 @@
-package q
-
-func MainTest() {
-	// FIXME
-}
diff --git a/tests/functional/new-instance-takeover/q.go b/tests/functional/new-instance-takeover/fiinha.go
index 76ed59f..5fdb9b4 100644
--- a/tests/functional/new-instance-takeover/q.go
+++ b/tests/functional/new-instance-takeover/fiinha.go
@@ -1,4 +1,4 @@
-package q
+package fiinha
 
 import (
 	"runtime"
diff --git a/tests/functional/wait-after-publish/q.go b/tests/functional/wait-after-publish/fiinha.go
index b70d27e..a60a57b 100644
--- a/tests/functional/wait-after-publish/q.go
+++ b/tests/functional/wait-after-publish/fiinha.go
@@ -1,4 +1,4 @@
-package q
+package fiinha
 
 import (
 	"runtime"
diff --git a/tests/functional/waiter/fiinha.go b/tests/functional/waiter/fiinha.go
new file mode 100644
index 0000000..6a3ca47
--- /dev/null
+++ b/tests/functional/waiter/fiinha.go
@@ -0,0 +1,5 @@
+package fiinha
+
+func MainTest() {
+	// FIXME
+}
diff --git a/tests/functional/waiter/q.go b/tests/functional/waiter/q.go
deleted file mode 100644
index 48d66d3..0000000
--- a/tests/functional/waiter/q.go
+++ /dev/null
@@ -1,5 +0,0 @@
-package q
-
-func MainTest() {
-	// FIXME
-}
diff --git a/tests/fuzz/api-check/q.go b/tests/fuzz/api-check/fiinha.go
index f8b2ab4..86801de 100644
--- a/tests/fuzz/api-check/q.go
+++ b/tests/fuzz/api-check/fiinha.go
@@ -1,4 +1,4 @@
-package q
+package fiinha
 
 import (
 	"os"
diff --git a/tests/fuzz/queries-check/q.go b/tests/fuzz/cli-check/fiinha.go
index 5c872e5..1cb6f37 100644
--- a/tests/fuzz/queries-check/q.go
+++ b/tests/fuzz/cli-check/fiinha.go
@@ -1,4 +1,4 @@
-package q
+package fiinha
 
 import (
 	"os"
diff --git a/tests/fuzz/equal-produced-consumed-order-check/q.go b/tests/fuzz/equal-produced-consumed-order-check/fiinha.go
index 8b95aef..ef2e72a 100644
--- a/tests/fuzz/equal-produced-consumed-order-check/q.go
+++ b/tests/fuzz/equal-produced-consumed-order-check/fiinha.go
@@ -1,4 +1,4 @@
-package q
+package fiinha
 
 import (
 	"os"
diff --git a/tests/fuzz/exactly-once-check/q.go b/tests/fuzz/exactly-once-check/fiinha.go
index d483ad8..6ac1fb1 100644
--- a/tests/fuzz/exactly-once-check/q.go
+++ b/tests/fuzz/exactly-once-check/fiinha.go
@@ -1,4 +1,4 @@
-package q
+package fiinha
 
 import (
 	"os"
diff --git a/tests/fuzz/cli-check/q.go b/tests/fuzz/queries-check/fiinha.go
index 5c872e5..1cb6f37 100644
--- a/tests/fuzz/cli-check/q.go
+++ b/tests/fuzz/queries-check/fiinha.go
@@ -1,4 +1,4 @@
-package q
+package fiinha
 
 import (
 	"os"
diff --git a/tests/fuzz/total-order-check/q.go b/tests/fuzz/total-order-check/fiinha.go
index 67af544..cb5aa61 100644
--- a/tests/fuzz/total-order-check/q.go
+++ b/tests/fuzz/total-order-check/fiinha.go
@@ -1,4 +1,4 @@
-package q
+package fiinha
 
 import (
 	"os"
diff --git a/tests/main.go b/tests/main.go
index 893132e..789b267 100644
--- a/tests/main.go
+++ b/tests/main.go
@@ -1,7 +1,7 @@
 package main
 
-import "q"
+import "fiinha"
 
 func main() {
-	q.MainTest()
+	fiinha.MainTest()
 }
diff --git a/tests/queries.sql b/tests/queries.sql
index e790d41..241f419 100644
--- a/tests/queries.sql
+++ b/tests/queries.sql
@@ -1,59 +1,59 @@
 
 -- createTables.sql:
 --   write:
-		CREATE TABLE IF NOT EXISTS "q_payloads" (
+		CREATE TABLE IF NOT EXISTS "fiinha_payloads" (
 			id           INTEGER NOT NULL PRIMARY KEY AUTOINCREMENT,
 			timestamp    TEXT    NOT NULL DEFAULT (strftime('%Y-%m-%dT%H:%M:%f000000Z', 'now')),
 			topic        TEXT    NOT NULL,
 			payload      BLOB    NOT NULL
 		) STRICT;
-		CREATE INDEX IF NOT EXISTS "q_payloads_topic"
-			ON "q_payloads"(topic);
+		CREATE INDEX IF NOT EXISTS "fiinha_payloads_topic"
+			ON "fiinha_payloads"(topic);
 
-		CREATE TABLE IF NOT EXISTS "q_messages" (
+		CREATE TABLE IF NOT EXISTS "fiinha_messages" (
 			id           INTEGER NOT NULL PRIMARY KEY AUTOINCREMENT,
 			timestamp    TEXT    NOT NULL DEFAULT (strftime('%Y-%m-%dT%H:%M:%f000000Z', 'now')),
 			uuid         BLOB    NOT NULL UNIQUE,
 			flow_id      BLOB    NOT NULL,
 			payload_id   INTEGER NOT NULL
-				REFERENCES "q_payloads"(id)
+				REFERENCES "fiinha_payloads"(id)
 		) STRICT;
-		CREATE INDEX IF NOT EXISTS "q_messages_flow_id"
-			ON "q_messages"(flow_id);
+		CREATE INDEX IF NOT EXISTS "fiinha_messages_flow_id"
+			ON "fiinha_messages"(flow_id);
 
-		CREATE TABLE IF NOT EXISTS "q_offsets" (
+		CREATE TABLE IF NOT EXISTS "fiinha_offsets" (
 			id           INTEGER NOT NULL PRIMARY KEY AUTOINCREMENT,
 			timestamp    TEXT    NOT NULL DEFAULT (strftime('%Y-%m-%dT%H:%M:%f000000Z', 'now')),
 			consumer     TEXT    NOT NULL,
 			message_id   INTEGER NOT NULL
-				REFERENCES "q_messages"(id),
+				REFERENCES "fiinha_messages"(id),
 			instance_id  INTEGER NOT NULL,
 			UNIQUE (consumer, message_id)
 		) STRICT;
-		CREATE INDEX IF NOT EXISTS "q_offsets_consumer"
-			ON "q_offsets"(consumer);
+		CREATE INDEX IF NOT EXISTS "fiinha_offsets_consumer"
+			ON "fiinha_offsets"(consumer);
 
-		CREATE TABLE IF NOT EXISTS "q_deadletters" (
+		CREATE TABLE IF NOT EXISTS "fiinha_deadletters" (
 			id           INTEGER NOT NULL PRIMARY KEY AUTOINCREMENT,
 			uuid         BLOB    NOT NULL UNIQUE,
 			consumer     TEXT    NOT NULL,
 			message_id   INTEGER NOT NULL
-				REFERENCES "q_messages"(id),
+				REFERENCES "fiinha_messages"(id),
 			instance_id  INTEGER NOT NULL,
 			UNIQUE (consumer, message_id)
 		) STRICT;
-		CREATE INDEX IF NOT EXISTS "q_deadletters_consumer"
-			ON "q_deadletters"(consumer);
+		CREATE INDEX IF NOT EXISTS "fiinha_deadletters_consumer"
+			ON "fiinha_deadletters"(consumer);
 
-		CREATE TABLE IF NOT EXISTS "q_replays" (
+		CREATE TABLE IF NOT EXISTS "fiinha_replays" (
 			id           INTEGER NOT NULL PRIMARY KEY AUTOINCREMENT,
 			deadletter_id INTEGER NOT NULL UNIQUE
-				REFERENCES "q_deadletters"(id) ,
+				REFERENCES "fiinha_deadletters"(id) ,
 			message_id    INTEGER NOT NULL UNIQUE
-				REFERENCES "q_messages"(id)
+				REFERENCES "fiinha_messages"(id)
 		) STRICT;
 
-		CREATE TABLE IF NOT EXISTS "q_owners" (
+		CREATE TABLE IF NOT EXISTS "fiinha_owners" (
 			id           INTEGER NOT NULL PRIMARY KEY AUTOINCREMENT,
 			topic        TEXT    NOT NULL,
 			consumer     TEXT    NOT NULL,
@@ -61,16 +61,16 @@
 			UNIQUE (topic, consumer)
 		) STRICT;
 
-		CREATE TRIGGER IF NOT EXISTS "q_check_instance_owns_topic"
-			BEFORE INSERT ON "q_offsets"
+		CREATE TRIGGER IF NOT EXISTS "fiinha_check_instance_owns_topic"
+			BEFORE INSERT ON "fiinha_offsets"
 			WHEN NEW.instance_id != (
-				SELECT owner_id FROM "q_owners"
+				SELECT owner_id FROM "fiinha_owners"
 				WHERE topic = (
-					SELECT "q_payloads".topic
-					FROM "q_payloads"
-					JOIN "q_messages" ON "q_payloads".id =
-						"q_messages".payload_id
-					WHERE "q_messages".id = NEW.message_id
+					SELECT "fiinha_payloads".topic
+					FROM "fiinha_payloads"
+					JOIN "fiinha_messages" ON "fiinha_payloads".id =
+						"fiinha_messages".payload_id
+					WHERE "fiinha_messages".id = NEW.message_id
 				) AND consumer = NEW.consumer
 			)
 		BEGIN
@@ -80,16 +80,16 @@
 			);
 		END;
 
-		CREATE TRIGGER IF NOT EXISTS "q_check_can_publish_deadletter"
-			BEFORE INSERT ON "q_deadletters"
+		CREATE TRIGGER IF NOT EXISTS "fiinha_check_can_publish_deadletter"
+			BEFORE INSERT ON "fiinha_deadletters"
 			WHEN NEW.instance_id != (
-				SELECT owner_id FROM "q_owners"
+				SELECT owner_id FROM "fiinha_owners"
 				WHERE topic = (
-					SELECT "q_payloads".topic
-					FROM "q_payloads"
-					JOIN "q_messages" ON "q_payloads".id =
-						"q_messages".payload_id
-					WHERE "q_messages".id = NEW.message_id
+					SELECT "fiinha_payloads".topic
+					FROM "fiinha_payloads"
+					JOIN "fiinha_messages" ON "fiinha_payloads".id =
+						"fiinha_messages".payload_id
+					WHERE "fiinha_messages".id = NEW.message_id
 				) AND consumer = NEW.consumer
 			)
 		BEGIN
@@ -106,7 +106,7 @@
 
 -- take.sql:
 --   write:
-		INSERT INTO "q_owners" (topic, consumer, owner_id)
+		INSERT INTO "fiinha_owners" (topic, consumer, owner_id)
 		VALUES (?, ?, ?)
 		ON CONFLICT (topic, consumer) DO
 			UPDATE SET owner_id=excluded.owner_id;
@@ -118,15 +118,15 @@
 
 -- publish.sql:
 --   write:
-		INSERT INTO "q_payloads" (topic, payload)
+		INSERT INTO "fiinha_payloads" (topic, payload)
 		VALUES (?, ?);
 
-		INSERT INTO "q_messages" (uuid, flow_id, payload_id)
+		INSERT INTO "fiinha_messages" (uuid, flow_id, payload_id)
 		VALUES (?, ?, last_insert_rowid());
 	
 
 --    read:
-		SELECT id, timestamp FROM "q_messages"
+		SELECT id, timestamp FROM "fiinha_messages"
 		WHERE uuid = ?;
 	
 
@@ -137,17 +137,17 @@
 
 --    read:
 		SELECT
-			"q_messages".id,
-			"q_messages".timestamp,
-			"q_messages".uuid,
-			"q_payloads".payload
-		FROM "q_messages"
-		JOIN "q_payloads" ON
-			"q_payloads".id = "q_messages".payload_id
+			"fiinha_messages".id,
+			"fiinha_messages".timestamp,
+			"fiinha_messages".uuid,
+			"fiinha_payloads".payload
+		FROM "fiinha_messages"
+		JOIN "fiinha_payloads" ON
+			"fiinha_payloads".id = "fiinha_messages".payload_id
 		WHERE
-			"q_payloads".topic   = ? AND
-			"q_messages".flow_id = ?
-		ORDER BY "q_messages".id DESC
+			"fiinha_payloads".topic   = ? AND
+			"fiinha_messages".flow_id = ?
+		ORDER BY "fiinha_messages".id DESC
 		LIMIT 1;
 	
 
@@ -159,27 +159,27 @@
 --    read:
 		SELECT
 			(
-				SELECT owner_id FROM "q_owners"
+				SELECT owner_id FROM "fiinha_owners"
 				WHERE
 					topic    = ? AND
 					consumer = ?
 					LIMIT 1
 			) AS owner_id,
-			"q_messages".id,
-			"q_messages".timestamp,
-			"q_messages".uuid,
-			"q_messages".flow_id,
-			"q_payloads".payload
-		FROM "q_messages"
-		JOIN "q_payloads" ON
-			"q_payloads".id = "q_messages".payload_id
+			"fiinha_messages".id,
+			"fiinha_messages".timestamp,
+			"fiinha_messages".uuid,
+			"fiinha_messages".flow_id,
+			"fiinha_payloads".payload
+		FROM "fiinha_messages"
+		JOIN "fiinha_payloads" ON
+			"fiinha_payloads".id = "fiinha_messages".payload_id
 		WHERE
-			"q_payloads".topic = ? AND
-			"q_messages".id NOT IN (
-				SELECT message_id FROM "q_offsets"
+			"fiinha_payloads".topic = ? AND
+			"fiinha_messages".id NOT IN (
+				SELECT message_id FROM "fiinha_offsets"
 				WHERE consumer = ?
 			)
-		ORDER BY "q_messages".id ASC
+		ORDER BY "fiinha_messages".id ASC
 		LIMIT 1;
 	
 
@@ -190,26 +190,26 @@
 
 --    read:
 		SELECT
-			"q_messages".id,
-			"q_messages".timestamp,
-			"q_messages".uuid,
-			"q_messages".flow_id,
-			"q_payloads".topic,
-			"q_payloads".payload
-		FROM "q_messages"
-		JOIN "q_payloads" ON
-			"q_payloads".id = "q_messages".payload_id
+			"fiinha_messages".id,
+			"fiinha_messages".timestamp,
+			"fiinha_messages".uuid,
+			"fiinha_messages".flow_id,
+			"fiinha_payloads".topic,
+			"fiinha_payloads".payload
+		FROM "fiinha_messages"
+		JOIN "fiinha_payloads" ON
+			"fiinha_payloads".id = "fiinha_messages".payload_id
 		WHERE
-			"q_payloads".topic = ? AND
-			"q_messages".id NOT IN (
-				SELECT message_id FROM "q_offsets"
+			"fiinha_payloads".topic = ? AND
+			"fiinha_messages".id NOT IN (
+				SELECT message_id FROM "fiinha_offsets"
 				WHERE consumer = ?
 			)
-		ORDER BY "q_messages".id ASC;
+		ORDER BY "fiinha_messages".id ASC;
 	
 
 --   owner:
-		SELECT owner_id FROM "q_owners"
+		SELECT owner_id FROM "fiinha_owners"
 		WHERE
 			topic    = ? AND
 			consumer = ?;
@@ -217,8 +217,8 @@
 
 -- commit.sql:
 --   write:
-		INSERT INTO "q_offsets" (consumer, message_id, instance_id)
-		VALUES (?, (SELECT id FROM "q_messages" WHERE uuid = ?), ?);
+		INSERT INTO "fiinha_offsets" (consumer, message_id, instance_id)
+		VALUES (?, (SELECT id FROM "fiinha_messages" WHERE uuid = ?), ?);
 	
 
 --    read:
@@ -227,13 +227,13 @@
 
 -- toDead.sql:
 --   write:
-		INSERT INTO "q_offsets"
+		INSERT INTO "fiinha_offsets"
 			(      consumer, message_id, instance_id)
-		VALUES (   ?, (SELECT id FROM "q_messages" WHERE uuid = ?), ?);
+		VALUES (   ?, (SELECT id FROM "fiinha_messages" WHERE uuid = ?), ?);
 
-		INSERT INTO "q_deadletters"
+		INSERT INTO "fiinha_deadletters"
 			(uuid, consumer, message_id, instance_id)
-		VALUES (?, ?, (SELECT id FROM "q_messages" WHERE uuid = ?), ?);
+		VALUES (?, ?, (SELECT id FROM "fiinha_messages" WHERE uuid = ?), ?);
 	
 
 --    read:
@@ -242,34 +242,34 @@
 
 -- replay.sql:
 --   write:
-		INSERT INTO "q_messages" (uuid, flow_id, payload_id)
+		INSERT INTO "fiinha_messages" (uuid, flow_id, payload_id)
 			SELECT
 				?,
-				"q_messages".flow_id,
-				"q_messages".payload_id
-			FROM "q_messages"
-			JOIN "q_deadletters" ON
-				"q_messages".id = "q_deadletters".message_id
-			WHERE "q_deadletters".uuid = ?;
+				"fiinha_messages".flow_id,
+				"fiinha_messages".payload_id
+			FROM "fiinha_messages"
+			JOIN "fiinha_deadletters" ON
+				"fiinha_messages".id = "fiinha_deadletters".message_id
+			WHERE "fiinha_deadletters".uuid = ?;
 
-		INSERT INTO "q_replays" (deadletter_id, message_id)
+		INSERT INTO "fiinha_replays" (deadletter_id, message_id)
 		VALUES (
-			(SELECT id FROM "q_deadletters" WHERE uuid = ?),
+			(SELECT id FROM "fiinha_deadletters" WHERE uuid = ?),
 			last_insert_rowid()
 		);
 	
 
 --    read:
 		SELECT
-			"q_messages".id,
-			"q_messages".timestamp,
-			"q_messages".flow_id,
-			"q_payloads".topic,
-			"q_payloads".payload
-		FROM "q_messages"
-		JOIN "q_payloads" ON
-			"q_payloads".id = "q_messages".payload_id
-		WHERE "q_messages".uuid = ?;
+			"fiinha_messages".id,
+			"fiinha_messages".timestamp,
+			"fiinha_messages".flow_id,
+			"fiinha_payloads".topic,
+			"fiinha_payloads".payload
+		FROM "fiinha_messages"
+		JOIN "fiinha_payloads" ON
+			"fiinha_payloads".id = "fiinha_messages".payload_id
+		WHERE "fiinha_messages".uuid = ?;
 	
 
 --   owner:
@@ -279,24 +279,24 @@
 
 --    read:
 		SELECT
-			"q_deadletters".uuid,
-			"q_offsets".timestamp,
-			"q_messages".uuid
-		FROM "q_deadletters"
-		JOIN "q_offsets" ON
-			"q_deadletters".message_id = "q_offsets".message_id
-		JOIN "q_messages" ON
-			"q_deadletters".message_id = "q_messages".id
-		JOIN "q_payloads" ON
-			"q_messages".payload_id = "q_payloads".id
+			"fiinha_deadletters".uuid,
+			"fiinha_offsets".timestamp,
+			"fiinha_messages".uuid
+		FROM "fiinha_deadletters"
+		JOIN "fiinha_offsets" ON
+			"fiinha_deadletters".message_id = "fiinha_offsets".message_id
+		JOIN "fiinha_messages" ON
+			"fiinha_deadletters".message_id = "fiinha_messages".id
+		JOIN "fiinha_payloads" ON
+			"fiinha_messages".payload_id = "fiinha_payloads".id
 		WHERE
-			"q_payloads".topic = ? AND
-			"q_deadletters".consumer = ? AND
-			"q_offsets".consumer = ? AND
-			"q_deadletters".id NOT IN (
-				SELECT deadletter_id FROM "q_replays"
+			"fiinha_payloads".topic = ? AND
+			"fiinha_deadletters".consumer = ? AND
+			"fiinha_offsets".consumer = ? AND
+			"fiinha_deadletters".id NOT IN (
+				SELECT deadletter_id FROM "fiinha_replays"
 			)
-		ORDER BY "q_deadletters".id ASC
+		ORDER BY "fiinha_deadletters".id ASC
 		LIMIT 1;
 	
 
@@ -307,30 +307,30 @@
 
 --    read:
 		SELECT
-			"q_deadletters".uuid,
-			"q_deadletters".message_id,
-			"q_offsets".timestamp,
-			"q_offsets".consumer,
-			"q_messages".timestamp,
-			"q_messages".uuid,
-			"q_messages".flow_id,
-			"q_payloads".topic,
-			"q_payloads".payload
-		FROM "q_deadletters"
-		JOIN "q_offsets" ON
-			"q_deadletters".message_id = "q_offsets".message_id
-		JOIN "q_messages" ON
-			"q_deadletters".message_id = "q_messages".id
-		JOIN "q_payloads" ON
-			"q_messages".payload_id = "q_payloads".id
+			"fiinha_deadletters".uuid,
+			"fiinha_deadletters".message_id,
+			"fiinha_offsets".timestamp,
+			"fiinha_offsets".consumer,
+			"fiinha_messages".timestamp,
+			"fiinha_messages".uuid,
+			"fiinha_messages".flow_id,
+			"fiinha_payloads".topic,
+			"fiinha_payloads".payload
+		FROM "fiinha_deadletters"
+		JOIN "fiinha_offsets" ON
+			"fiinha_deadletters".message_id = "fiinha_offsets".message_id
+		JOIN "fiinha_messages" ON
+			"fiinha_deadletters".message_id = "fiinha_messages".id
+		JOIN "fiinha_payloads" ON
+			"fiinha_messages".payload_id = "fiinha_payloads".id
 		WHERE
-			"q_payloads".topic = ? AND
-			"q_deadletters".consumer = ? AND
-			"q_offsets".consumer = ? AND
-			"q_deadletters".id NOT IN (
-				SELECT deadletter_id FROM "q_replays"
+			"fiinha_payloads".topic = ? AND
+			"fiinha_deadletters".consumer = ? AND
+			"fiinha_offsets".consumer = ? AND
+			"fiinha_deadletters".id NOT IN (
+				SELECT deadletter_id FROM "fiinha_replays"
 			)
-		ORDER BY "q_deadletters".id ASC;
+		ORDER BY "fiinha_deadletters".id ASC;
 	
 
 --   owner:
@@ -341,10 +341,10 @@
 --    read:
 		SELECT
 			COUNT(1) as size
-		FROM "q_messages"
-		JOIN "q_payloads" ON
-			"q_messages".payload_id = "q_payloads".id
-		WHERE "q_payloads".topic = ?;
+		FROM "fiinha_messages"
+		JOIN "fiinha_payloads" ON
+			"fiinha_messages".payload_id = "fiinha_payloads".id
+		WHERE "fiinha_payloads".topic = ?;
 	
 
 --   owner:
@@ -355,14 +355,14 @@
 --    read:
 		SELECT
 			COUNT(1) as count
-		FROM "q_messages"
-		JOIN "q_offsets" ON
-			"q_messages".id = "q_offsets".message_id
-		JOIN "q_payloads" ON
-			"q_messages".payload_id = "q_payloads".id
+		FROM "fiinha_messages"
+		JOIN "fiinha_offsets" ON
+			"fiinha_messages".id = "fiinha_offsets".message_id
+		JOIN "fiinha_payloads" ON
+			"fiinha_messages".payload_id = "fiinha_payloads".id
 		WHERE
-			"q_payloads".topic = ? AND
-			"q_offsets".consumer = ?;
+			"fiinha_payloads".topic = ? AND
+			"fiinha_offsets".consumer = ?;
 	
 
 --   owner:
@@ -372,13 +372,13 @@
 
 --    read:
 		SELECT 1 as data
-		FROM "q_messages"
-		JOIN "q_payloads" ON
-			"q_payloads".id = "q_messages".payload_id
+		FROM "fiinha_messages"
+		JOIN "fiinha_payloads" ON
+			"fiinha_payloads".id = "fiinha_messages".payload_id
 		WHERE
-			"q_payloads".topic = ? AND
-			"q_messages".id NOT IN (
-				SELECT message_id FROM "q_offsets"
+			"fiinha_payloads".topic = ? AND
+			"fiinha_messages".id NOT IN (
+				SELECT message_id FROM "fiinha_offsets"
 				WHERE consumer = ?
 			)
 		LIMIT 1;