Skip to content

Instantly share code, notes, and snippets.

@kunjee17
Last active October 25, 2015 18:12
Show Gist options
  • Save kunjee17/3e6d4c6f263a3c543b89 to your computer and use it in GitHub Desktop.
Save kunjee17/3e6d4c6f263a3c543b89 to your computer and use it in GitHub Desktop.
[<CLIMutableAttribute>]
[<AliasAttribute("hello")>]
type HelloDb =
{ Name : string }
[<LiteralAttribute>]
let connStr = "Server = localhost; Port = 5432; Database = database; User Id = username; password = password;"
let dbfactory = OrmLiteConnectionFactory(connStr, PostgreSqlDialect.Provider)
let agent =
MailboxProcessor.Start(fun inbox ->
//let db = dbfactory.Open(); persistance open connection.
let rec messageLoop() =
async {
let! (msg : Hello) = inbox.Receive()
do use db = dbfactory.Open()
//do some processing
db.InsertAsync(msg)
|> Async.AwaitTask
|> ignore
printfn "%A" msg.Name
do! Async.Sleep(rnd.Next(100, 1000))
return! messageLoop()
}
messageLoop())
agent.Post {Name:"Kunjan"}
//How can use this agent to insert data. Because if they are queue I guess it is ok to use persistance open connection. Here I am not doing it
//but I guess that very much possible
@swlaschin
Copy link

Looks good to me. That SO question has good answers too!

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment