parent
4c63923238
commit
b0553c1b8d
@ -0,0 +1,14 @@
|
||||
package main
|
||||
|
||||
import (
|
||||
"log"
|
||||
)
|
||||
|
||||
import (
|
||||
"github.com/meatballhat/box-o-sand/sylvilagus/go/sylvilagus"
|
||||
)
|
||||
|
||||
func main() {
|
||||
log.Println("Would be using AMQP_URI =", sylvilagus.AMQP_URI)
|
||||
log.Println("OH HAI RPC")
|
||||
}
|
@ -0,0 +1,33 @@
|
||||
package sylvilagus
|
||||
|
||||
import (
|
||||
"log"
|
||||
)
|
||||
|
||||
import (
|
||||
"github.com/streadway/amqp"
|
||||
)
|
||||
|
||||
func CreateRPCTopology(connection *amqp.Connection) (channel *amqp.Channel, err error) {
|
||||
if channel, err = connection.Channel(); err != nil {
|
||||
log.Println("Failed to get channel!: ", err)
|
||||
return nil, err
|
||||
}
|
||||
|
||||
if err = channel.ExchangeDeclare("rpc", "direct", true, false, false, false, nil); err != nil {
|
||||
log.Println("Failed to declare exchange!: ", err)
|
||||
return nil, err
|
||||
}
|
||||
|
||||
if _, err = channel.QueueDeclare("ping", false, false, false, false, nil); err != nil {
|
||||
log.Println("Failed to declare queue!: ", err)
|
||||
return nil, err
|
||||
}
|
||||
|
||||
if err = channel.QueueBind("ping", "ping", "rpc", false, nil); err != nil {
|
||||
log.Println("Failed to bind to queue!: ", err)
|
||||
return nil, err
|
||||
}
|
||||
|
||||
return channel, nil
|
||||
}
|
@ -0,0 +1,14 @@
|
||||
package sylvilagus
|
||||
|
||||
import (
|
||||
"log"
|
||||
"os"
|
||||
)
|
||||
|
||||
var AMQP_URI = os.Getenv("SYLVILAGUS_AMQP_URI")
|
||||
|
||||
func init() {
|
||||
if len(AMQP_URI) < 1 {
|
||||
log.Fatal("SYLVILAGUS_AMQP_URI is not defined!")
|
||||
}
|
||||
}
|
Loading…
Reference in new issue