ericacm

class ProviderTokenServices(dataSource: DataSource) extends JdbcOAuth2ProviderTokenServices(dataSource) with InitializingBean {
  var log: Logger = LoggerFactory.getLogger(this.getClass.getName)

  @Autowired var domainManager: DomainManager = _
  @Autowired var schedulerService: SchedulerService = _

  @Value("${providerTokenServices.pruneSchedule:0 0 12 * * *}")
  var pruneSchedule: String = _

  override def storeAccessToken(token: OAuth2AccessToken, authentication: OAuth2Authentication[_ <: Authentication, _ <: Authentication]) {

momania

import akka.amqp.AMQP._
import akka.amqp._
import akka.actor._
import java.util.concurrent.{TimeUnit, CountDownLatch}
import util.Random

object LoadBalancingDemo {

  def main(args: Array[String]) {