raven

var (
	// EXCHANGE is the default exchange
	EXCHANGE = "h2o"
	// REPLY_EXCHANGE is the exchange where replies go to
	REPLY_EXCHANGE = "h2o.direct"
	// TOPIC_EXCHANGE is the topic exchange
	TOPIC_EXCHANGE = "h2o.topic"
	// HOSTNAME is the hostname of rabbitmq
	HOSTNAME = "localhost"
	// USERNAME is the username to connect to rabbitmq with
	USERNAME = "hailo"
	// PASSWORD is the password to connect to rabbitmq with
	PASSWORD = "hailo"
	// PORT is the rabbitmq port
	PORT = flag.Int("amqp-port", 5672, "<port> to connect to for AMQP")
	// ADMINPORT is the port of the admin interface
	ADMINPORT = flag.Int("amqp-admin-port", 15672, "<port> to connect to for AMQP")
)

var (
	// AmqpUri is the URI to connect to rabbit, made up of username, host etc
	AmqpUri string
	// Connection wraps a standard AMQP connection
	Connection *AMQPConnection
	// Publisher represents the channel we send messages on
	Publisher *AMQPChannel
	// Consumer represents the channel we consume message on
	Consumer  *AMQPChannel
	Connected bool
)