diff --git a/internal/storage/vault.go b/internal/storage/vault.go index b858628..81a50de 100644 --- a/internal/storage/vault.go +++ b/internal/storage/vault.go @@ -211,7 +211,7 @@ func CreateVault(ID string, storageHandler *StorageHandler) (*Vault, error) { ID, //== topicName func(ctx context.Context, id peer.ID, msg *pubsub.Message) bool { if id == storageHandler.Host.ID() { - return false + return true } Logger.Debugf("PubSubmsg TOPIC: %s, PEER: %s\n", ID, id)