|
@@ -33,20 +33,20 @@ func NewController(rabbithost string) (*Controller, error) {
|
|
producer := msgQueue.NewRabbitMqProducer(admin, "default")
|
|
producer := msgQueue.NewRabbitMqProducer(admin, "default")
|
|
consumer := msgQueue.NewRabbitConsumer(admin, "MAIN")
|
|
consumer := msgQueue.NewRabbitConsumer(admin, "MAIN")
|
|
_ = consumer.Subscribe()
|
|
_ = consumer.Subscribe()
|
|
- // timer
|
|
|
|
- t := rule.NewTimer()
|
|
|
|
- t.Run()
|
|
|
|
-
|
|
|
|
- // ifttt
|
|
|
|
- ttt := rule.NewIfttt()
|
|
|
|
|
|
+ //// timer
|
|
|
|
+ //t := rule.NewTimer()
|
|
|
|
+ //t.Run()
|
|
|
|
+ //
|
|
|
|
+ //// ifttt
|
|
|
|
+ //ttt := rule.NewIfttt()
|
|
if err := producer.Init(); err != nil {
|
|
if err := producer.Init(); err != nil {
|
|
return nil, err
|
|
return nil, err
|
|
}
|
|
}
|
|
|
|
|
|
return &Controller{
|
|
return &Controller{
|
|
producer: producer,
|
|
producer: producer,
|
|
- timer: t,
|
|
|
|
- ift: ttt,
|
|
|
|
|
|
+ // timer: t,
|
|
|
|
+ // ift: ttt,
|
|
consumer: consumer,
|
|
consumer: consumer,
|
|
cluster: &ClusterService{producer: producer},
|
|
cluster: &ClusterService{producer: producer},
|
|
pool: grpool.New(),
|
|
pool: grpool.New(),
|