Revision bb3876b5 src/main/scala/gr/grnet/aquarium/service/RabbitMQService.scala
| b/src/main/scala/gr/grnet/aquarium/service/RabbitMQService.scala | ||
|---|---|---|
| 46 | 46 |
import gr.grnet.aquarium.connector.rabbitmq.service.PayloadHandlerPostNotifier |
| 47 | 47 |
import gr.grnet.aquarium.connector.rabbitmq.conf.RabbitMQKeys.RabbitMQConfKeys |
| 48 | 48 |
import gr.grnet.aquarium.connector.rabbitmq.conf.RabbitMQKeys |
| 49 |
import gr.grnet.aquarium.connector.handler.{SynchronousPayloadHandlerExecutor, ResourceEventPayloadHandler, IMEventPayloadHandler}
|
|
| 50 |
import gr.grnet.aquarium.util.json.JsonSupport |
|
| 49 |
import gr.grnet.aquarium.connector.handler.{ResourceEventPayloadHandler, IMEventPayloadHandler}
|
|
| 51 | 50 |
|
| 52 | 51 |
/** |
| 53 | 52 |
* The service that is responsible to handle `RabbitMQ` connectivity. |
| ... | ... | |
| 98 | 97 |
|
| 99 | 98 |
val imHandler = new IMEventPayloadHandler(aquarium, logger) |
| 100 | 99 |
|
| 101 |
val futureExecutor = new SynchronousPayloadHandlerExecutor |
|
| 102 |
|
|
| 103 | 100 |
// (e)xchange:(r)outing key:(q) |
| 104 | 101 |
|
| 105 | 102 |
// These two are to trigger an error if the property does not exist |
| ... | ... | |
| 144 | 141 |
aquarium, |
| 145 | 142 |
rccc, |
| 146 | 143 |
rcHandler, |
| 147 |
futureExecutor, |
|
| 148 | 144 |
postNotifier |
| 149 | 145 |
) |
| 150 | 146 |
} |
| ... | ... | |
| 160 | 156 |
aquarium, |
| 161 | 157 |
imcc, |
| 162 | 158 |
imHandler, |
| 163 |
futureExecutor, |
|
| 164 | 159 |
postNotifier |
| 165 | 160 |
) |
| 166 | 161 |
} |
Also available in: Unified diff