conyer

var BuildQueuingConsumer = cony.NewConsumer(
	BuildQueuingPhaseQueue,
	cony.AutoAck(),
	cony.AutoTag(),
	cony.Qos(20),
)

var BuildQueuingPhaseQueue = &cony.Queue{
	Name:       "pipeline_build_queuing_phase",
	Durable:    true,
	AutoDelete: false,
	Exclusive:  false,
	Args:       nil,
}

var BuildQueuingPublisher = cony.NewPublisher(UciInternalExchange.Name, string(pipeline.BuildQueuing))

var Cli *cony.Client

var UciInternalExchange = cony.Exchange{
	Name:       "uci.internal.exchange",
	Kind:       "direct",
	Durable:    true,
	AutoDelete: false,
	Args:       nil,
}

var UciInternalExchangeAndBuildQueuingPhaseQueueBinding = cony.Binding{
	Queue:    BuildQueuingPhaseQueue,
	Exchange: UciInternalExchange,
	Key:      string(pipeline.BuildQueuing),
	Args:     nil,
}

var UciInternalExchangeAndWaitForBorrowingPhaseQueueBinding = cony.Binding{
	Queue:    WaitForBorrowingPhaseQueue,
	Exchange: UciInternalExchange,
	Key:      string(pipeline.WaitForBorrowing),
	Args:     nil,
}

var UciInternalExchangeAndWaitForDispatchingPhaseQueueBinding = cony.Binding{
	Queue:    WaitForDispatchingPhaseQueue,
	Exchange: UciInternalExchange,
	Key:      string(pipeline.WaitForDispatching),
	Args:     nil,
}

var WaitForBorrowingConsumer = cony.NewConsumer(
	WaitForBorrowingPhaseQueue,
	cony.AutoAck(),
	cony.AutoTag(),
	cony.Qos(20),
)

var WaitForBorrowingPhaseQueue = &cony.Queue{
	Name:       "pipeline_wait_for_borrowing_phase",
	Durable:    true,
	AutoDelete: false,
	Exclusive:  false,
	Args:       nil,
}

var WaitForBorrowingPublisher = cony.NewPublisher(UciInternalExchange.Name, string(pipeline.WaitForBorrowing))

var WaitForDispatchingConsumer = cony.NewConsumer(
	WaitForDispatchingPhaseQueue,
	cony.AutoAck(),
	cony.AutoTag(),
	cony.Qos(20),
)

var WaitForDispatchingPhaseQueue = &cony.Queue{
	Name:       "pipeline_wait_for_dispatching_phase",
	Durable:    true,
	AutoDelete: false,
	Exclusive:  false,
	Args:       nil,
}

var WaitForDispatchingPublisher = cony.NewPublisher(UciInternalExchange.Name, string(pipeline.WaitForDispatching))